watchertest

Documentation

Index

• type NotifyWatcher
  • func NewNotifyWatcher(ch <-chan struct{}) *NotifyWatcher
  • func (w *NotifyWatcher) Changes() <-chan struct{}
  • func (w *NotifyWatcher) Err() error
  • func (w *NotifyWatcher) Kill()
  • func (w *NotifyWatcher) KillErr(err error)
  • func (w *NotifyWatcher) Stop() error
  • func (w *NotifyWatcher) Wait() error
• type StringsWatcher
  • func NewStringsWatcher(ch chan []string) *StringsWatcher
  • func (w *StringsWatcher) Changes() <-chan []string
  • func (w *StringsWatcher) Err() error
  • func (w *StringsWatcher) Kill()
  • func (w *StringsWatcher) Stop() error
  • func (w *StringsWatcher) Wait() error

Types

type NotifyWatcher

type NotifyWatcher struct {
	// contains filtered or unexported fields
}

func NewNotifyWatcher

func NewNotifyWatcher(ch <-chan struct{}) *NotifyWatcher

func (*NotifyWatcher) Changes

func (w *NotifyWatcher) Changes() <-chan struct{}

func (*NotifyWatcher) Err

func (w *NotifyWatcher) Err() error

func (*NotifyWatcher) Kill

func (w *NotifyWatcher) Kill()

func (*NotifyWatcher) KillErr

func (w *NotifyWatcher) KillErr(err error)

KillErr can be used to kill the worker with an error, to simulate a failing watcher.

func (*NotifyWatcher) Stop

func (w *NotifyWatcher) Stop() error

func (*NotifyWatcher) Wait

func (w *NotifyWatcher) Wait() error

type StringsWatcher

type StringsWatcher struct {
	T tomb.Tomb
	C chan []string
}

StringsWatcher is an implementation of state.StringsWatcher that can be manipulated, for testing.

func NewStringsWatcher

func NewStringsWatcher(ch chan []string) *StringsWatcher

NewStringsWatcher returns a new StringsWatcher that returns the given channel in its "Changes" method. NewStringsWatcher takes ownership of the channel, closing it when it is stopped.

func (*StringsWatcher) Changes

func (w *StringsWatcher) Changes() <-chan []string

Changes is part of the state.StringsWatcher interface.

func (*StringsWatcher) Err

func (w *StringsWatcher) Err() error

Err is part of the state.StringsWatcher interface.

func (*StringsWatcher) Kill

func (w *StringsWatcher) Kill()

Kill is part of the state.StringsWatcher interface.

func (*StringsWatcher) Stop

func (w *StringsWatcher) Stop() error

Stop is part of the state.StringsWatcher interface.

func (*StringsWatcher) Wait

func (w *StringsWatcher) Wait() error

Wait is part of the state.StringsWatcher interface.