diff --git a/store/store.go b/store/store.go index 74f28f32..fcd0c987 100644 --- a/store/store.go +++ b/store/store.go @@ -7,14 +7,6 @@ import ( "time" ) -type EventType int - -const ( - EventTypeUnknown = iota - EventTypeConnect - EventTypeDisconnect -) - var ( ErrWatcherStopped = errors.New("watcher stopped") // ErrNotConnected is returned when a store is not connected @@ -29,11 +21,6 @@ var ( DefaultSeparator = "/" ) -type Event interface { - Error() error - Type() EventType -} - // Store is a data storage interface type Store interface { // Name returns store name @@ -119,13 +106,6 @@ func NewWatchOptions(opts ...WatchOption) (WatchOptions, error) { return options, err } -type Watcher interface { - // Next is a blocking call - Next() (Event, error) - // Stop stops the watcher - Stop() -} - func Watch(context.Context) (Watcher, error) { return nil, nil }