Versions in this module Expand all Collapse all v1 v1.4.0 Oct 17, 2016 Changes in this version + type Broadcaster struct + func NewBroadcaster(queueLength int, fullChannelBehavior FullChannelBehavior) *Broadcaster + func (m *Broadcaster) Action(action EventType, obj runtime.Object) + func (m *Broadcaster) Shutdown() + func (m *Broadcaster) Watch() Interface + func (m *Broadcaster) WatchWithPrefix(queuedEvents []Event) Interface + type ConditionFunc func(event Event) (bool, error) + type Decoder interface + Close func() + Decode func() (action EventType, object runtime.Object, err error) + type Event struct + Object runtime.Object + Type EventType + func Until(timeout time.Duration, watcher Interface, conditions ...ConditionFunc) (*Event, error) + type EventType string + const Added + const Deleted + const Error + const Modified + type FakeWatcher struct + Stopped bool + func NewFake() *FakeWatcher + func NewFakeWithChanSize(size int) *FakeWatcher + func (f *FakeWatcher) Action(action EventType, obj runtime.Object) + func (f *FakeWatcher) Add(obj runtime.Object) + func (f *FakeWatcher) Delete(lastValue runtime.Object) + func (f *FakeWatcher) Error(errValue runtime.Object) + func (f *FakeWatcher) IsStopped() bool + func (f *FakeWatcher) Modify(obj runtime.Object) + func (f *FakeWatcher) Reset() + func (f *FakeWatcher) ResultChan() <-chan Event + func (f *FakeWatcher) Stop() + type FilterFunc func(in Event) (out Event, keep bool) + type FullChannelBehavior int + const DropIfChannelFull + const WaitIfChannelFull + type Interface interface + ResultChan func() <-chan Event + Stop func() + func Filter(w Interface, f FilterFunc) Interface + func NewEmptyWatch() Interface + type Recorder struct + func NewRecorder(w Interface) *Recorder + func (r *Recorder) Events() []Event + type StreamWatcher struct + func NewStreamWatcher(d Decoder) *StreamWatcher + func (sw *StreamWatcher) ResultChan() <-chan Event + func (sw *StreamWatcher) Stop()
Go to main page