Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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"
)

Source Files

Directories

Path Synopsis
test