watcher

Documentation

Index

• type ManifestWorkWatcher
  • func NewManifestWorkWatcher() *ManifestWorkWatcher
  • func (mw *ManifestWorkWatcher) Receive(evt watch.Event)
  • func (mw *ManifestWorkWatcher) ResultChan() <-chan watch.Event
  • func (mw *ManifestWorkWatcher) Stop()

Types

type ManifestWorkWatcher

type ManifestWorkWatcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ManifestWorkWatcher implements the watch.Interface. It returns a chan which will receive all the events.

func NewManifestWorkWatcher

func NewManifestWorkWatcher() *ManifestWorkWatcher

func (*ManifestWorkWatcher) Receive

func (mw *ManifestWorkWatcher) Receive(evt watch.Event)

Receive a event from the work client and sends down the result channel.

func (*ManifestWorkWatcher) ResultChan

func (mw *ManifestWorkWatcher) ResultChan() <-chan watch.Event

ResultChan implements Interface.

func (*ManifestWorkWatcher) Stop

func (mw *ManifestWorkWatcher) Stop()

Stop implements Interface.