watcher

Documentation

Index

• type ConfigMapCallback
• type ConfigMapEntryCallback
  • func (cb *ConfigMapEntryCallback) OnChange(configMap *v1.ConfigMap)
• type ConfigMapWatcher
  • func NewConfigMapWatcher(kubeClient kubernetes.Interface, ns string, callbacks []ConfigMapCallback, ...) (*ConfigMapWatcher, error)
  • func SetupConfigMapWatchers(ns string, configAgent *config.Agent, pluginAgent *plugins.ConfigAgent) (*ConfigMapWatcher, error)
  • func (w *ConfigMapWatcher) IsStopped() bool
  • func (w *ConfigMapWatcher) Stop()

Types

type ConfigMapCallback

type ConfigMapCallback interface {
	OnChange(configMap *v1.ConfigMap)
}

ConfigMapCallback represents a callback

type ConfigMapEntryCallback

type ConfigMapEntryCallback struct {
	Name     string
	Key      string
	Callback func(string)
	// contains filtered or unexported fields
}

ConfigMapEntryCallback invokes a callback if the value changes

func (*ConfigMapEntryCallback) OnChange

func (cb *ConfigMapEntryCallback) OnChange(configMap *v1.ConfigMap)

OnChange invokes the callback function if the value is not empty and changes

type ConfigMapWatcher

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

ConfigMapWatcher callbacks for changes to a config map

func NewConfigMapWatcher

func NewConfigMapWatcher(kubeClient kubernetes.Interface, ns string, callbacks []ConfigMapCallback, stopCh <-chan struct{}) (*ConfigMapWatcher, error)

NewConfigMapWatcher creates a new watcher of ConfigMap resources which lists them all synchronously then asynchronously processes watch events

func SetupConfigMapWatchers

func SetupConfigMapWatchers(ns string, configAgent *config.Agent, pluginAgent *plugins.ConfigAgent) (*ConfigMapWatcher, error)

SetupConfigMapWatchers takes a config agent and plugin agent, each potentially nil, and sets up the appropriate watchers for them.

func (*ConfigMapWatcher) IsStopped

func (w *ConfigMapWatcher) IsStopped() bool

IsStopped checks if configmap watcher is stopped

func (*ConfigMapWatcher) Stop

func (w *ConfigMapWatcher) Stop()

Stop stops the configmap watcher