Package versioned contains the versioned types for watch.

Filter passes all events through f before allowing them to pass on.

NewBroadcaster creates a new Broadcaster.

NewEmptyWatch returns a watch interface that returns no results and is closed.

NewRecorder wraps an Interface and records any changes sent across it.

NewStreamWatcher creates a StreamWatcher from the given decoder.

Until reads items from the watch until each provided condition succeeds, and then returns the last watch encountered.

Broadcaster distributes event notifications among any number of watchers.

Event represents a single event to a watched resource.

FakeWatcher lets you test anything that consumes a watch.Interface; threadsafe.

RaceFreeFakeWatcher lets you test anything that consumes a watch.Interface; threadsafe.

Recorder records all events that are sent from the watch until it is closed.

StreamWatcher turns any stream for which you can write a Decoder interface into a watch.Interface.

Decoder allows StreamWatcher to watch any stream for which a Decoder can be written.

Interface can be implemented by anything that knows how to watch and report changes.

ConditionFunc returns true if the condition has been reached, false if it has not been reached yet, or an error if the condition cannot be checked and should terminate.

EventType defines the possible types of events.

FilterFunc should take an event, possibly modify it in some way, and return the modified event.

FullChannelBehavior controls how the Broadcaster reacts if a watcher's watch channel is full.