From f8b947a00ba2bd1812d1b2618ab80e86e3fee209 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Mon, 29 Jun 2015 22:02:21 -0700 Subject: [PATCH] storage: fix small issues --- storage/kvstore.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/storage/kvstore.go b/storage/kvstore.go index a06bb4de7..4c24b463e 100644 --- a/storage/kvstore.go +++ b/storage/kvstore.go @@ -44,6 +44,10 @@ type store struct { stopc chan struct{} } +func New(path string) KV { + return newStore(path) +} + func newStore(path string) *store { s := &store{ b: backend.New(path, batchInterval, batchLimit), @@ -285,7 +289,7 @@ func (s *store) rangeKeys(key, end []byte, limit, rangeRev int64) (kvs []storage log.Fatalf("storage: cannot unmarshal event: %v", err) } if e.Type == storagepb.PUT { - kvs = append(kvs, e.Kv) + kvs = append(kvs, *e.Kv) } if limit > 0 && len(kvs) >= int(limit) { break @@ -309,7 +313,7 @@ func (s *store) put(key, value []byte, rev int64) { ver = ver + 1 event := storagepb.Event{ Type: storagepb.PUT, - Kv: storagepb.KeyValue{ + Kv: &storagepb.KeyValue{ Key: key, Value: value, CreateIndex: c, @@ -388,7 +392,7 @@ func (s *store) delete(key []byte, mainrev int64) bool { event := storagepb.Event{ Type: storagepb.DELETE, - Kv: storagepb.KeyValue{ + Kv: &storagepb.KeyValue{ Key: key, }, }