package configmapwatcher

import "istio.io/istio/pkg/kube/configmapwatcher"

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{})

Package Files ¶

configmapwatcher.go

type Controller ¶ Uses

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 ¶ Uses

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

NewController returns a new ConfigMap watcher controller.

func (*Controller) HasSynced ¶ Uses

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 ¶ Uses

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