k8s

Documentation

Index

• type ConfigMapWatcher
  • func New(namespace, name string) (*ConfigMapWatcher, error)
  • func (w *ConfigMapWatcher) Get(ctx context.Context) (v1.ConfigMap, error)
  • func (w *ConfigMapWatcher) StartWatching(ctx context.Context, dst chan<- v1.ConfigMap) error
• type TypedEventHandler
  • func (t TypedEventHandler[T]) OnAdd(obj interface{}, isInInitialList bool)
  • func (t TypedEventHandler[T]) OnDelete(obj interface{})
  • func (t TypedEventHandler[T]) OnUpdate(oldObj, newObj interface{})

Types

type ConfigMapWatcher

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

func New

func New(namespace, name string) (*ConfigMapWatcher, error)

func (*ConfigMapWatcher) Get

func (w *ConfigMapWatcher) Get(ctx context.Context) (v1.ConfigMap, error)

func (*ConfigMapWatcher) StartWatching

func (w *ConfigMapWatcher) StartWatching(ctx context.Context, dst chan<- v1.ConfigMap) error

StartWatching pushes instances of the identified configuration map found in a target Kuberentes cluster.

type TypedEventHandler

type TypedEventHandler[T any] struct {
	AddFunc    func(T)
	UpdateFunc func(T, T)
	DeleteFunc func(T)
}

func (TypedEventHandler[T]) OnAdd

func (t TypedEventHandler[T]) OnAdd(obj interface{}, isInInitialList bool)

OnAdd calls AddFunc if it's not nil.

func (TypedEventHandler[T]) OnDelete

func (t TypedEventHandler[T]) OnDelete(obj interface{})

OnDelete calls DeleteFunc if it's not nil.

func (TypedEventHandler[T]) OnUpdate

func (t TypedEventHandler[T]) OnUpdate(oldObj, newObj interface{})

OnUpdate calls UpdateFunc if it's not nil.