ingress

type BaseHandler interface {
	OnCreate(*networkingv1beta1.Ingress)
	OnUpdate(*networkingv1beta1.Ingress)
	OnDelete(*networkingv1beta1.Ingress)
}

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

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

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

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

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

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

type Handler interface {
	BaseHandler
	OnInitialize([]*networkingv1beta1.Ingress)
}

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

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(*networkingv1beta1.Ingress)
}

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