watcher

Documentation

Index

• type K8sStringsWatcherFilterFunc
• type KubernetesNotifyWatcher
  • func NewKubernetesNotifyWatcher(informer cache.SharedIndexInformer, name string, clock jujuclock.Clock) (KubernetesNotifyWatcher, error)
• type KubernetesStringsWatcher
  • func NewKubernetesStringsWatcher(informer cache.SharedIndexInformer, name string, clock jujuclock.Clock, ...) (KubernetesStringsWatcher, error)
• type NewK8sStringsWatcherFunc
• type NewK8sWatcherFunc
• type WatchEvent

Types

type K8sStringsWatcherFilterFunc

type K8sStringsWatcherFilterFunc func(evt WatchEvent, obj interface{}) (string, bool)

type KubernetesNotifyWatcher

type KubernetesNotifyWatcher interface {
	watcher.CoreWatcher
	Changes() watcher.NotifyChannel
}

func NewKubernetesNotifyWatcher

func NewKubernetesNotifyWatcher(informer cache.SharedIndexInformer, name string, clock jujuclock.Clock) (KubernetesNotifyWatcher, error)

type KubernetesStringsWatcher

type KubernetesStringsWatcher interface {
	watcher.CoreWatcher
	Changes() watcher.StringsChannel
}

func NewKubernetesStringsWatcher

func NewKubernetesStringsWatcher(informer cache.SharedIndexInformer, name string, clock jujuclock.Clock,
	initialEvents []string, filterFunc K8sStringsWatcherFilterFunc) (KubernetesStringsWatcher, error)

type NewK8sStringsWatcherFunc

type NewK8sStringsWatcherFunc func(
	informer cache.SharedIndexInformer,
	name string,
	clock jujuclock.Clock, initialEvents []string,
	filterFunc K8sStringsWatcherFilterFunc) (KubernetesStringsWatcher, error)

NewK8sStringsWatcherFunc defines a function which returns a k8s string watcher based on the supplied config

type NewK8sWatcherFunc

type NewK8sWatcherFunc func(
	informer cache.SharedIndexInformer,
	name string,
	clock jujuclock.Clock) (KubernetesNotifyWatcher, error)

NewK8sWatcherFunc defines a function which returns a k8s watcher based on the supplied config.

type WatchEvent

type WatchEvent string

var (
	WatchEventAdd    WatchEvent = "add"
	WatchEventDelete WatchEvent = "delete"
	WatchEventUpdate WatchEvent = "update"
)