dynamicwatcher

Documentation

Overview

package dynamic watcher provides a way to watch for changes in kubernetes resources the function Start takes a kubernetes clientset and a list of DynamicWatcherConfig and starts a watcher for each configuration

Index

• func Start(k *kubernetesclient.K8sClientsets, configs []DynamicWatcherConfig, ...) error
• type DynamicWatcher
  • func (c *DynamicWatcher) Run(stop <-chan struct{})
• type DynamicWatcherConfig
• type WatcherConfig

Functions

func Start

func Start(k *kubernetesclient.K8sClientsets, configs []DynamicWatcherConfig, stop chan struct{}) error

Function starts dynamic watchers for provided configurations

Types

type DynamicWatcher

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

func (*DynamicWatcher) Run

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

type DynamicWatcherConfig

type DynamicWatcherConfig interface {
	WatcherConfig() WatcherConfig
}

type WatcherConfig

type WatcherConfig struct {
	ResourceDef schema.GroupVersionResource
	Add         func(obj any, isInInitialList bool)
	Delete      func(obj any)
	Update      func(oldObj any, newObj any)
}