Versions in this module Expand all Collapse all v0 v0.0.2 Mar 17, 2022 v0.0.1 Nov 8, 2021 Changes in this version + var DefaultChanSize int32 = 100 + type Broadcaster struct + func NewBroadcaster(queueLength int, fullChannelBehavior FullChannelBehavior) *Broadcaster + func NewLongQueueBroadcaster(queueLength int, fullChannelBehavior FullChannelBehavior) *Broadcaster + func (m *Broadcaster) Action(action EventType, obj runtime.Object) + func (m *Broadcaster) ActionOrDrop(action EventType, obj runtime.Object) bool + func (m *Broadcaster) Shutdown() + func (m *Broadcaster) Watch() Interface + func (m *Broadcaster) WatchWithPrefix(queuedEvents []Event) Interface + type Decoder interface + Close func() + Decode func() (action EventType, obj runtime.Object, err error) + type Event struct + Object runtime.Object + Type EventType + type EventType string + const Added + const Bookmark + const Deleted + const Error + const Modified + type FakeWatcher struct + func NewFake() *FakeWatcher + func NewFakeWithChanSize(size int, blocking bool) *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 ProxyWatcher struct + func NewProxyWatcher(ch chan Event) *ProxyWatcher + func (pw *ProxyWatcher) ResultChan() <-chan Event + func (pw *ProxyWatcher) Stop() + func (pw *ProxyWatcher) StopChan() <-chan struct{} + func (pw *ProxyWatcher) Stopping() bool + type RaceFreeFakeWatcher struct + Stopped bool + func NewRaceFreeFake() *RaceFreeFakeWatcher + func (f *RaceFreeFakeWatcher) Action(action EventType, obj runtime.Object) + func (f *RaceFreeFakeWatcher) Add(obj runtime.Object) + func (f *RaceFreeFakeWatcher) Delete(lastValue runtime.Object) + func (f *RaceFreeFakeWatcher) Error(errValue runtime.Object) + func (f *RaceFreeFakeWatcher) IsStopped() bool + func (f *RaceFreeFakeWatcher) Modify(obj runtime.Object) + func (f *RaceFreeFakeWatcher) Reset() + func (f *RaceFreeFakeWatcher) ResultChan() <-chan Event + func (f *RaceFreeFakeWatcher) Stop() + type Recorder struct + func NewRecorder(w Interface) *Recorder + func (r *Recorder) Events() []Event + type Reporter interface + AsObject func(err error) interface{} + type StreamWatcher struct + func NewStreamWatcher(d Decoder, r Reporter) *StreamWatcher + func (sw *StreamWatcher) ResultChan() <-chan Event + func (sw *StreamWatcher) Stop()
Go to main page