From 11507d54619ff06e7d95c1dd347f1f9667c95a2c Mon Sep 17 00:00:00 2001 From: supercocoa Date: Thu, 6 Aug 2020 14:38:20 +0800 Subject: [PATCH] fix zookeeper node's lastIndex when list child nodes --- store/zookeeper/zookeeper.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/store/zookeeper/zookeeper.go b/store/zookeeper/zookeeper.go index ff8d4ebe..0ba1e8c1 100644 --- a/store/zookeeper/zookeeper.go +++ b/store/zookeeper/zookeeper.go @@ -237,7 +237,7 @@ func (s *Zookeeper) WatchTree(directory string, stopCh <-chan struct{}) (<-chan // List child nodes of a given directory func (s *Zookeeper) List(directory string) ([]*store.KVPair, error) { - keys, stat, err := s.client.Children(s.normalize(directory)) + keys, _, err := s.client.Children(s.normalize(directory)) if err != nil { if err == zk.ErrNoNode { return nil, store.ErrKeyNotFound @@ -261,7 +261,7 @@ func (s *Zookeeper) List(directory string) ([]*store.KVPair, error) { kv = append(kv, &store.KVPair{ Key: key, Value: []byte(pair.Value), - LastIndex: uint64(stat.Version), + LastIndex: uint64(pair.LastIndex), }) }