test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-30 02:48:45 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

Fix bug that max time cant be marshaled

Browse Source 
Signed-off-by: rain <boyan.wang@zilliz.com>
This commit is contained in:
rain 2020-09-08 10:01:30 +08:00 committed by yefu.chen
parent 81e70ee6c9
commit c9c7c78340
1 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
pkg/master/server.go
View File

@ -2,12 +2,14 @@ package master
import (
"fmt"
"log"
"time"
"github.com/czs007/suvlim/pkg/master/common"
"github.com/czs007/suvlim/pkg/master/informer"
"github.com/czs007/suvlim/pkg/master/kv"
"github.com/czs007/suvlim/pkg/master/mock"
"go.etcd.io/etcd/clientv3"
)
@ -39,13 +41,20 @@ func CollectionController() {
defer cli.Close()
kvbase := kv.NewEtcdKVBase(cli, common.ETCD_ROOT_PATH)
c := mock.FakeCreateCollection(uint64(3333))
s := mock.FakeCreateSegment(uint64(11111), c, time.Now(), time.Unix(1<<63-1, 0))
s := mock.FakeCreateSegment(uint64(11111), c, time.Now(), time.Unix(1<<36-1, 0))
collectionData, _ := mock.Collection2JSON(c)
segmentData, _ := mock.Segment2JSON(s)
kvbase.Save("test-collection", collectionData)
kvbase.Save("test-segment", segmentData)
fmt.Println(kvbase.Load("test-collection"))
fmt.Println(kvbase.Load("test-segment"))
segmentData, err := mock.Segment2JSON(s)
if err != nil {
log.Fatal(err)
}
err = kvbase.Save("test-collection", collectionData)
if err != nil {
log.Fatal(err)
}
err = kvbase.Save("test-segment", segmentData)
if err != nil {
log.Fatal(err)
}
}
func Sync() {