kubernetes

type ConversionEventHandler[TObj Object] struct {
	Target TypedResourceEventHandler[TObj]
}

type ConversionStage string

type NewListWatcherFunc func(resourceInterface dynamic.NamespaceableResourceInterface) cache.ListerWatcher

type Object interface {
	metaV1.Object
	runtime.Object
}

type PodReference struct {
	Namespace string `json:"namespace"`
	Pod       string `json:"pod"`
}

type ResourceFilter[TObj Object] func(TObj) bool

type TypedFilteringResourceEventHandler[TObj Object] struct {
	FilterFunc ResourceFilter[TObj]
	Handler    TypedResourceEventHandler[TObj]
}

type TypedResourceEventHandler[TObj Object] interface {
	OnAdd(obj TObj)
	OnUpdate(oldObj, newObj TObj)
	OnDelete(obj TObj)
	OnDeleteUnknown(i interface{}, key string)
	OnConversionError(i interface{}, stage ConversionStage, conversionError error)
}

type TypedResourceEventHandlerFuncs[TObj Object] struct {
	OnAddFunc             func(obj TObj)
	OnUpdateFunc          func(oldObj, newObj TObj)
	OnDeleteFunc          func(obj TObj)
	OnDeleteUnknownFunc   func(i interface{}, key string)
	OnConversionErrorFunc func(i interface{}, stage ConversionStage, conversionError error)
}

type TypedSharedIndexInformer[TObj Object] interface {
	cache.SharedIndexInformer
	AddTypedEventHandler(handler TypedResourceEventHandler[TObj])
}