configmapwatcher

Documentation

Index

• type Controller
  • func NewController(client kube.Client, namespace, name string, callback func(*v1.ConfigMap)) *Controller
  • func (c *Controller) HasSynced() bool
  • func (c *Controller) Run(stop <-chan struct{})

Types

type Controller

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

Controller watches a ConfigMap and calls the given callback when the ConfigMap changes. The ConfigMap is passed to the callback, or nil if it doesn't exist.

func NewController

func NewController(client kube.Client, namespace, name string, callback func(*v1.ConfigMap)) *Controller

NewController returns a new ConfigMap watcher controller.

func (*Controller) HasSynced

func (c *Controller) HasSynced() bool

HasSynced returns whether the underlying cache has synced and the callback has been called at least once.

func (*Controller) Run

func (c *Controller) Run(stop <-chan struct{})