controller

Documentation

Index

• func NewController(stop <-chan bool)
• type KubeResourceWatcher
  • func (watcher *KubeResourceWatcher) HasSynced() bool
  • func (watcher *KubeResourceWatcher) LastSyncResourceVersion() string
  • func (watcher *KubeResourceWatcher) Watch(term <-chan struct{})

Functions

func NewController

func NewController(stop <-chan bool)

NewController starts a controller for watching Kubernetes objects.

Types

type KubeResourceWatcher

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

KubeResourceWatcher contains the informer that watches Kubernetes objects and the queue that processes updates.

func (*KubeResourceWatcher) HasSynced

func (watcher *KubeResourceWatcher) HasSynced() bool

HasSynced determines whether the informer has synced

func (*KubeResourceWatcher) LastSyncResourceVersion

func (watcher *KubeResourceWatcher) LastSyncResourceVersion() string

LastSyncResourceVersion returns the last sync resource version

func (*KubeResourceWatcher) Watch

func (watcher *KubeResourceWatcher) Watch(term <-chan struct{})

Watch tells the KubeResourceWatcher to start waiting for events