subscriber

type Keyer interface {
	Key() string
}

type Manager struct {
	sync.Mutex
	sync.WaitGroup
	// contains filtered or unexported fields
}

type Streamer interface {
	Do(send chan *structs.Action, subscribeCh chan interface{}, destroyCh chan interface{}) (structs.Response, error)
	Key() string
	IsMutable() bool
	BackendType() string
}

type Subscription interface {
	Subscribe(key string) chan interface{}
	Subscribed(key string) bool
	Unsubscribe(key string) bool
}

type Watcher interface {
	Do() (structs.Response, error)
	Key() string
	IsMutable() bool
	BackendType() string
}