watcher

Documentation

Index

• type BreakpointWatcher
  • func NewBreakpointWatcher(lhClient versioned.Interface, ns string, logger *logrus.Entry) (*BreakpointWatcher, error)
  • func (w *BreakpointWatcher) GetBreakpoints() []*v1alpha1.LighthouseBreakpoint
  • func (w *BreakpointWatcher) IsStopped() bool
  • func (w *BreakpointWatcher) Stop()
• 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 BreakpointWatcher

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

BreakpointWatcher lists and watches for breakpoints and caches them in memory

func NewBreakpointWatcher

func NewBreakpointWatcher(lhClient versioned.Interface, ns string, logger *logrus.Entry) (*BreakpointWatcher, error)

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

func (*BreakpointWatcher) GetBreakpoints

func (w *BreakpointWatcher) GetBreakpoints() []*v1alpha1.LighthouseBreakpoint

GetBreakpoints returns the current breakpoints

func (*BreakpointWatcher) IsStopped

func (w *BreakpointWatcher) IsStopped() bool

IsStopped checks if the watcher is stopped

func (*BreakpointWatcher) Stop

func (w *BreakpointWatcher) Stop()

Stop stops the watcher watcher

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