Browse Source

storage: fix WatchableKV interface

We delete endRev from the watch functionality, so the interface needs
to be fixed.
Yicheng Qin 10 years ago
parent
commit
2673e657e6
2 changed files with 2 additions and 3 deletions
  1. 1 2
      storage/kv.go
  2. 1 1
      storage/kv_test.go

+ 1 - 2
storage/kv.go

@@ -97,9 +97,8 @@ type WatchableKV interface {
 	// event history can be watched unless compacted.
 	// If `prefix` is true, watch observes all events whose key prefix could be the given `key`.
 	// If `startRev` <=0, watch observes events after currentRev.
-	// If `endRev` <=0, watch observes events until watch is cancelled.
 	//
 	// Canceling the watcher releases resources associated with it, so code
 	// should always call cancel as soon as watch is done.
-	Watcher(key []byte, prefix bool, startRev, endRev int64) (Watcher, CancelFunc)
+	Watcher(key []byte, prefix bool, startRev int64) (Watcher, CancelFunc)
 }

+ 1 - 1
storage/kv_test.go

@@ -730,7 +730,7 @@ func TestKVSnapshot(t *testing.T) {
 }
 
 func TestWatchableKVWatch(t *testing.T) {
-	s := newWatchableStore(tmpPath)
+	s := WatchableKV(newWatchableStore(tmpPath))
 	defer cleanup(s, tmpPath)
 
 	wa, cancel := s.Watcher([]byte("foo"), true, 0)