diff --git a/pkg/store/consul.go b/pkg/store/consul.go index c0d45a767a..37ef86e8db 100644 --- a/pkg/store/consul.go +++ b/pkg/store/consul.go @@ -137,7 +137,7 @@ func (s *Consul) List(prefix string) ([]*KVEntry, error) { } // DeleteRange deletes a range of values at "directory" -func (s *Consul) DeleteRange(prefix string) error { +func (s *Consul) DeleteTree(prefix string) error { _, err := s.client.KV().DeleteTree(s.normalize(prefix), nil) return err } diff --git a/pkg/store/etcd.go b/pkg/store/etcd.go index 73c8e6df6f..eb4bcfd76d 100644 --- a/pkg/store/etcd.go +++ b/pkg/store/etcd.go @@ -208,7 +208,7 @@ func (s *Etcd) List(prefix string) ([]*KVEntry, error) { } // DeleteRange deletes a range of values at "directory" -func (s *Etcd) DeleteRange(prefix string) error { +func (s *Etcd) DeleteTree(prefix string) error { if _, err := s.client.Delete(normalize(prefix), true); err != nil { return err } diff --git a/pkg/store/store.go b/pkg/store/store.go index 055cb49afb..2fec94e237 100644 --- a/pkg/store/store.go +++ b/pkg/store/store.go @@ -57,7 +57,7 @@ type Store interface { List(prefix string) ([]*KVEntry, error) // Delete range of keys based on prefix - DeleteRange(prefix string) error + DeleteTree(prefix string) error // Watch key namespaces WatchRange(prefix string, filter string, heartbeat time.Duration, callback WatchCallback) error diff --git a/pkg/store/zookeeper.go b/pkg/store/zookeeper.go index 12b628d766..cda538c6df 100644 --- a/pkg/store/zookeeper.go +++ b/pkg/store/zookeeper.go @@ -155,7 +155,7 @@ func (s *Zookeeper) List(prefix string) ([]*KVEntry, error) { } // DeleteRange deletes a range of values at "directory" -func (s *Zookeeper) DeleteRange(prefix string) error { +func (s *Zookeeper) DeleteTree(prefix string) error { err := s.client.Delete(normalize(prefix), -1) return err }