Documentation ¶
Overview ¶
Package watch implements better watch semantics on top of etcd. See this issue for the reasoning behind the package: https://github.com/coreos/etcd/issues/7362
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Event ¶
type Event struct { Key []byte Value []byte Type EventType Rev int64 Ver int64 Err error Template proto.Message }
Event is an event that occurred to an item in etcd.
type Option ¶
type Option func(WatchOptions) WatchOptions
Option is a function that modifies the set of options to use when watching
type WatchOptions ¶
type WatchOptions struct { SortTarget etcd.SortTarget SortOrder etcd.SortOrder IncludePut bool IncludeDelete bool }
WatchOptions is a set of options that can be used when watching
func DefaultWatchOptions ¶
func DefaultWatchOptions() WatchOptions
func IgnoreDelete ¶
func IgnoreDelete(opt WatchOptions) WatchOptions
IgnoreDelete discards DELETE events from the watcher
func IgnorePut ¶
func IgnorePut(opt WatchOptions) WatchOptions
IgnorePut discards PUT events from the watcher
func SumOptions ¶
func SumOptions(opts ...Option) WatchOptions
type Watcher ¶
type Watcher interface { // Watch returns a channel that delivers events Watch() <-chan *Event // Close this channel when you are done receiving events Close() }
Watcher ...
func MakeEtcdWatcher ¶
MakeEtcdWatcher returns a Watcher that uses the given event channel and done channel internally to deliver events and signal closure, respectively.
Click to show internal directories.
Click to hide internal directories.