kube

Documentation

Index

• type ConfigMapWatcher
  • func NewConfigMapWatcher(client kubernetes.Interface, namespace, selectorStr string, ...) (*ConfigMapWatcher, error)
  • func (c *ConfigMapWatcher) Run(ctx context.Context)

Types

type ConfigMapWatcher

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

func NewConfigMapWatcher

func NewConfigMapWatcher(client kubernetes.Interface, namespace, selectorStr string, configs chan<- provider.EgressConfig) (*ConfigMapWatcher, error)

func (*ConfigMapWatcher) Run

func (c *ConfigMapWatcher) Run(ctx context.Context)