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
 }