watcher

Documentation

Index

• type WatchNotifyFunctions
• type Watcher
  • func (w *Watcher) Destroy()
  • func (w *Watcher) Start(notifyF WatchNotifyFunctions, gvr schema.GroupVersionResource, ...) error
  • func (w *Watcher) Stop()
• type WatcherInterface
  • func NewWatcher(k8sClient dynamic.Interface, preList bool) WatcherInterface

Types

type WatchNotifyFunctions

type WatchNotifyFunctions struct {
	AddFunc    func(obj *unstructured.Unstructured)
	UpdateFunc func(obj *unstructured.Unstructured)
	DeleteFunc func(obj *unstructured.Unstructured)
	OnError    func(err error)
}

type Watcher

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

func (*Watcher) Destroy

func (w *Watcher) Destroy()

func (*Watcher) Start

func (w *Watcher) Start(notifyF WatchNotifyFunctions, gvr schema.GroupVersionResource, listOptions metav1.ListOptions) error

func (*Watcher) Stop

func (w *Watcher) Stop()

type WatcherInterface

type WatcherInterface interface {
	Start(notifyF WatchNotifyFunctions, gvr schema.GroupVersionResource, listOptions metav1.ListOptions) error
	Stop()
	Destroy()
}

func NewWatcher

func NewWatcher(k8sClient dynamic.Interface, preList bool) WatcherInterface