k8s

Documentation

Index

• type IK8sEventHandler
• type IK8sInformer
  • func NewK8sDynamicInformer(ctx context.Context, logger *zap.Logger, config config.IConfig, ...) (IK8sInformer, error)
• type K8sInformerFilter

Types

type IK8sEventHandler

type IK8sEventHandler interface {
	CustomWatchErrorHandler(r *cache.Reflector, err error)
	OnAddObject(obj interface{})
	OnUpdateObject(oldObj, newObj interface{})
	OnDeleteObject(obj interface{})
}

type IK8sInformer

type IK8sInformer interface {
	Run()
}

func NewK8sDynamicInformer

func NewK8sDynamicInformer(
	ctx context.Context,
	logger *zap.Logger,
	config config.IConfig,
	handler IK8sEventHandler,
	filter K8sInformerFilter,
) (IK8sInformer, error)

type K8sInformerFilter

type K8sInformerFilter struct {
	dig.In
	Resource  string `name:"k8s_resource"`
	Namespace string `name:"k8s_resource_namespace"`
}