kubernetes/staging/src/k8s.io/apimachinery/pkg/watch/watch.go

type Interface …

type EventType …

const Added …

const Modified …

const Deleted …

const Bookmark …

const Error …

var DefaultChanSize …

type Event …

type emptyWatch …

// NewEmptyWatch returns a watch interface that returns no results and is closed.
// May be used in certain error conditions where no information is available but
// an error is not warranted.
func NewEmptyWatch() Interface { … }

// Stop implements Interface
func (w emptyWatch) Stop() { … }

// ResultChan implements Interface
func (w emptyWatch) ResultChan() <-chan Event { … }

type FakeWatcher …

func NewFake() *FakeWatcher { … }

func NewFakeWithChanSize(size int, blocking bool) *FakeWatcher { … }

// Stop implements Interface.Stop().
func (f *FakeWatcher) Stop() { … }

func (f *FakeWatcher) IsStopped() bool { … }

// Reset prepares the watcher to be reused.
func (f *FakeWatcher) Reset() { … }

func (f *FakeWatcher) ResultChan() <-chan Event { … }

// Add sends an add event.
func (f *FakeWatcher) Add(obj runtime.Object) { … }

// Modify sends a modify event.
func (f *FakeWatcher) Modify(obj runtime.Object) { … }

// Delete sends a delete event.
func (f *FakeWatcher) Delete(lastValue runtime.Object) { … }

// Error sends an Error event.
func (f *FakeWatcher) Error(errValue runtime.Object) { … }

// Action sends an event of the requested type, for table-based testing.
func (f *FakeWatcher) Action(action EventType, obj runtime.Object) { … }

type RaceFreeFakeWatcher …

func NewRaceFreeFake() *RaceFreeFakeWatcher { … }

// Stop implements Interface.Stop().
func (f *RaceFreeFakeWatcher) Stop() { … }

func (f *RaceFreeFakeWatcher) IsStopped() bool { … }

// Reset prepares the watcher to be reused.
func (f *RaceFreeFakeWatcher) Reset() { … }

func (f *RaceFreeFakeWatcher) ResultChan() <-chan Event { … }

// Add sends an add event.
func (f *RaceFreeFakeWatcher) Add(obj runtime.Object) { … }

// Modify sends a modify event.
func (f *RaceFreeFakeWatcher) Modify(obj runtime.Object) { … }

// Delete sends a delete event.
func (f *RaceFreeFakeWatcher) Delete(lastValue runtime.Object) { … }

// Error sends an Error event.
func (f *RaceFreeFakeWatcher) Error(errValue runtime.Object) { … }

// Action sends an event of the requested type, for table-based testing.
func (f *RaceFreeFakeWatcher) Action(action EventType, obj runtime.Object) { … }

type ProxyWatcher …

var _ …

// NewProxyWatcher creates new ProxyWatcher by wrapping a channel
func NewProxyWatcher(ch chan Event) *ProxyWatcher { … }

// Stop implements Interface
func (pw *ProxyWatcher) Stop() { … }

// Stopping returns true if Stop() has been called
func (pw *ProxyWatcher) Stopping() bool { … }

// ResultChan implements Interface
func (pw *ProxyWatcher) ResultChan() <-chan Event { … }

// StopChan returns stop channel
func (pw *ProxyWatcher) StopChan() <-chan struct{ … }

type MockWatcher …

var _ …

// Stop calls StopFunc
func (mw MockWatcher) Stop() { … }

// ResultChan calls ResultChanFunc
func (mw MockWatcher) ResultChan() <-chan Event { … }