|
@@ -93,7 +93,7 @@ func (c *WatchCommand) CommandName() string {
|
|
|
|
|
|
|
|
func (c *WatchCommand) Apply(server *raft.Server) (interface{}, error) {
|
|
func (c *WatchCommand) Apply(server *raft.Server) (interface{}, error) {
|
|
|
// create a new watcher
|
|
// create a new watcher
|
|
|
- watcher := store.CreateWatcher()
|
|
|
|
|
|
|
+ watcher := store.NewWatcher()
|
|
|
|
|
|
|
|
// add to the watchers list
|
|
// add to the watchers list
|
|
|
etcdStore.AddWatcher(c.Key, watcher, c.SinceIndex)
|
|
etcdStore.AddWatcher(c.Key, watcher, c.SinceIndex)
|