event

type BaseHandler interface {
	OnCreate(*corev1.Event)
	OnUpdate(*corev1.Event)
	OnDelete(*corev1.Event)
}

type CacheController interface {
	Cache() CacheReader
	Ready() <-chan struct{}
}

type CacheReader interface {
	Get(ns string, name string) (*corev1.Event, error)
	List() ([]*corev1.Event, error)
}

type Controller interface {
	CacheController
	Publisher
	Done() <-chan struct{}
	Close()
	Error() error
}

type Event interface {
	Type() kcache.EventType
	Resource() *corev1.Event
}

type FilterController interface {
	Controller
	Refilter(filter.Filter) error
}

type FilterSubscription interface {
	Subscription
	Refilter(filter.Filter) error
}

type Handler interface {
	BaseHandler
	OnInitialize([]*corev1.Event)
}

type HandlerBuilder interface {
	OnInitialize(func([]*corev1.Event)) HandlerBuilder
	OnCreate(func(*corev1.Event)) HandlerBuilder
	OnUpdate(func(*corev1.Event)) HandlerBuilder
	OnDelete(func(*corev1.Event)) HandlerBuilder
	Create() Handler
}

type Object interface {
	GetObjectKind() schema.ObjectKind
	GetNamespace() string
	GetName() string
}

type Publisher interface {
	Subscribe() (Subscription, error)
	SubscribeWithFilter(filter.Filter) (FilterSubscription, error)
	SubscribeForFilter() (FilterSubscription, error)
	Clone() (Controller, error)
	CloneWithFilter(filter.Filter) (FilterController, error)
	CloneForFilter() (FilterController, error)
}

type Subscription interface {
	CacheController
	Events() <-chan Event
	Close()
	Done() <-chan struct{}
}

type UnitaryHandler interface {
	BaseHandler
	OnInitialize(*corev1.Event)
}

type UnitaryHandlerBuilder interface {
	OnInitialize(func(*corev1.Event)) UnitaryHandlerBuilder
	OnCreate(func(*corev1.Event)) UnitaryHandlerBuilder
	OnUpdate(func(*corev1.Event)) UnitaryHandlerBuilder
	OnDelete(func(*corev1.Event)) UnitaryHandlerBuilder
	Create() UnitaryHandler
}