watcher

Documentation

Index

• Variables
• type K8sWatcher
  • func NewK8sWatcher(ns string, cfmName string, masterUrl string, kubeconfig string) (*K8sWatcher, error)
  • func (c *K8sWatcher) GetConfigMap(ctx context.Context) (map[string]*config.InjectionConfig, error)
  • func (c *K8sWatcher) WatchConfigMap(ctx context.Context, notify chan<- interface{}) error
  • func (c *K8sWatcher) WatchNamespace(ctx context.Context, webhookEnabledLabel map[string]string, ...) error
• type NamespaceEvent

Variables

var ErrWatcheChannelClosed = errors.New("watcher channel has close")

Types

type K8sWatcher

type K8sWatcher struct {
	Namespace  string
	CfmName    string
	MasterURL  string
	KubeConfig string
	// contains filtered or unexported fields
}

func NewK8sWatcher

func NewK8sWatcher(ns string, cfmName string, masterUrl string, kubeconfig string) (*K8sWatcher, error)

func (*K8sWatcher) GetConfigMap

func (c *K8sWatcher) GetConfigMap(ctx context.Context) (map[string]*config.InjectionConfig, error)

func (*K8sWatcher) WatchConfigMap

func (c *K8sWatcher) WatchConfigMap(ctx context.Context, notify chan<- interface{}) error

func (*K8sWatcher) WatchNamespace

func (c *K8sWatcher) WatchNamespace(ctx context.Context, webhookEnabledLabel map[string]string, ch chan<- NamespaceEvent) error

type NamespaceEvent

type NamespaceEvent struct {
	Namespace string
	Type      watch.EventType
}