diff --git a/storage/watchable_store.go b/storage/watchable_store.go index 2f0a0578e..708c76279 100644 --- a/storage/watchable_store.go +++ b/storage/watchable_store.go @@ -131,7 +131,7 @@ func (s *watchableStore) Put(key, value []byte, lease lease.LeaseID) (rev int64) Type: storagepb.PUT, Kv: &changes[0], } - s.handle(rev, []storagepb.Event{ev}) + s.notify(rev, []storagepb.Event{ev}) return rev } @@ -156,7 +156,7 @@ func (s *watchableStore) DeleteRange(key, end []byte) (n, rev int64) { Type: storagepb.DELETE, Kv: &change} } - s.handle(rev, evs) + s.notify(rev, evs) return n, rev } @@ -191,7 +191,7 @@ func (s *watchableStore) TxnEnd(txnID int64) error { } } - s.handle(s.store.Rev(), evs) + s.notify(s.store.Rev(), evs) s.mu.Unlock() return nil @@ -370,11 +370,6 @@ func (s *watchableStore) syncWatchers() { slowWatcherGauge.Set(float64(len(s.unsynced))) } -// handle handles the change of the happening event on all watchers. -func (s *watchableStore) handle(rev int64, evs []storagepb.Event) { - s.notify(rev, evs) -} - // notify notifies the fact that given event at the given rev just happened to // watchers that watch on the key of the event. func (s *watchableStore) notify(rev int64, evs []storagepb.Event) {