milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip ci] Add comment for etcd_kv.go (#12449) 

Signed-off-by: shaoyue.chen <shaoyue.chen@zilliz.com>
pull/12461/head
shaoyue 2021-11-30 16:58:14 +08:00 committed by GitHub
parent 448475d1fc
commit bbdd1dbef9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/kv/etcd/etcd_kv.go
View File

@ -308,6 +308,7 @@ func (kv *EtcdKV) WatchWithPrefix(key string) clientv3.WatchChan {
return rch
}
// WatchWithRevision starts watching a key with revision, returns a watch channel.
func (kv *EtcdKV) WatchWithRevision(key string, revision int64) clientv3.WatchChan {
start := time.Now()
key = path.Join(kv.rootPath, key)
@ -316,6 +317,7 @@ func (kv *EtcdKV) WatchWithRevision(key string, revision int64) clientv3.WatchCh
return rch
}
// MultiRemoveWithPrefix removes the keys with given prefix.
func (kv *EtcdKV) MultiRemoveWithPrefix(keys []string) error {
start := time.Now()
ops := make([]clientv3.Op, 0, len(keys))
@ -331,6 +333,7 @@ func (kv *EtcdKV) MultiRemoveWithPrefix(keys []string) error {
return err
}
// MultiSaveAndRemoveWithPrefix saves kv in @saves and removes the keys with given prefix in @removals.
func (kv *EtcdKV) MultiSaveAndRemoveWithPrefix(saves map[string]string, removals []string) error {
start := time.Now()
ops := make([]clientv3.Op, 0, len(saves))
@ -414,6 +417,7 @@ func (kv *EtcdKV) CompareVersionAndSwap(key string, version int64, target string
return nil
}
// CheckElapseAndWarn checks the elapsed time and warns if it is too long.
func CheckElapseAndWarn(start time.Time, message string) bool {
elapsed := time.Since(start)
if elapsed.Milliseconds() > 2000 {