kube_events_manager

type KubeEventsManager interface {
	WithContext(ctx context.Context)
	WithKubeClient(client kube.KubernetesClient)
	AddMonitor(monitorConfig *MonitorConfig) (*KubeEvent, error)
	HasMonitor(monitorId string) bool
	GetMonitor(monitorId string) Monitor
	StartMonitor(monitorId string)
	Start()

	StopMonitor(configId string) error
	Ch() chan KubeEvent
}

type Monitor interface {
	WithKubeClient(client kube.KubernetesClient)
	WithConfig(config *MonitorConfig)
	WithKubeEventCb(eventCb func(KubeEvent))
	CreateInformers() error
	Start(context.Context)
	Stop()
	GetExistedObjects() []ObjectAndFilterResult
	GetConfig() *MonitorConfig
}

type MonitorConfig struct {
	Metadata struct {
		MonitorId string
		DebugName string
		LogLabels map[string]string
	}
	EventTypes        []WatchEventType
	ApiVersion        string
	Kind              string
	NameSelector      *NameSelector
	NamespaceSelector *NamespaceSelector
	LabelSelector     *metav1.LabelSelector
	FieldSelector     *FieldSelector
	JqFilter          string
	LogEntry          *log.Entry
	Mode              KubeEventMode
}

type NamespaceInformer interface {
	WithKubeClient(client kube.KubernetesClient)
	CreateSharedInformer(addFn func(string), delFn func(string)) error
	GetExistedObjects() map[string]bool
	Run(stopCh <-chan struct{})
	Stop()
}

type ResourceInformer interface {
	WithKubeClient(client kube.KubernetesClient)
	WithNamespace(string)
	WithName(string)
	WithKubeEventCb(eventCb func(KubeEvent))
	CreateSharedInformer() error
	GetExistedObjects() []ObjectAndFilterResult
	Run(stopCh <-chan struct{})
	Stop()
}