watcher

Documentation

Index

• type Watch
  • func NewWatch(namespace string, kc *kubeclient.KubeClient, watchers ...watch.Interface) *Watch
  • func (w Watch) ListenWatcher(onEvent func(obj watch.Event))
  • func (w *Watch) SetFilters(filters []watch.EventType) *Watch
  • func (w Watch) StartWatcher()
  • func (w Watch) StopWatch()

Types

type Watch

type Watch struct {
	Client       *kubeclient.KubeClient
	ResultStream chan watch.Event
	Namespace    string
	Watchers     []watch.Interface
	WatchFilters []watch.EventType
}

func NewWatch

func NewWatch(namespace string, kc *kubeclient.KubeClient, watchers ...watch.Interface) *Watch

func (Watch) ListenWatcher

func (w Watch) ListenWatcher(onEvent func(obj watch.Event))

func (*Watch) SetFilters

func (w *Watch) SetFilters(filters []watch.EventType) *Watch

func (Watch) StartWatcher

func (w Watch) StartWatcher()

func (Watch) StopWatch

func (w Watch) StopWatch()