Versions in this module Expand all Collapse all v0 v0.5.0 Nov 14, 2022 Changes in this version + var ErrInvalidType = fmt.Errorf("invalid type") + func NewClient(cs kubernetes.Interface, ns string) client.Client + func NewMonitor(publisher Publisher, handler Handler) (kcache.Monitor, error) + func PodsFilter(sources ...*appsv1.StatefulSet) filter.ComparableFilter + type BaseHandler interface + OnCreate func(*appsv1.StatefulSet) + OnDelete func(*appsv1.StatefulSet) + OnUpdate func(*appsv1.StatefulSet) + type CacheController interface + Cache func() CacheReader + Ready func() <-chan struct{} + type CacheReader interface + Get func(ns string, name string) (*appsv1.StatefulSet, error) + List func() ([]*appsv1.StatefulSet, error) + type Controller interface + Close func() + Done func() <-chan struct{} + Error func() error + func BuildController(ctx context.Context, log logutil.Log, client client.Client) (Controller, error) + func NewController(ctx context.Context, log logutil.Log, cs kubernetes.Interface, ns string) (Controller, error) + type Event interface + Resource func() *appsv1.StatefulSet + Type func() kcache.EventType + type FilterController interface + Refilter func(filter.Filter) error + type FilterSubscription interface + Refilter func(filter.Filter) error + type Handler interface + OnInitialize func([]*appsv1.StatefulSet) + func ToUnitary(log logutil.Log, delegate UnitaryHandler) Handler + type HandlerBuilder interface + Create func() Handler + OnCreate func(func(*appsv1.StatefulSet)) HandlerBuilder + OnDelete func(func(*appsv1.StatefulSet)) HandlerBuilder + OnInitialize func(func([]*appsv1.StatefulSet)) HandlerBuilder + OnUpdate func(func(*appsv1.StatefulSet)) HandlerBuilder + func BuildHandler() HandlerBuilder + type Publisher interface + Clone func() (Controller, error) + CloneForFilter func() (FilterController, error) + CloneWithFilter func(filter.Filter) (FilterController, error) + Subscribe func() (Subscription, error) + SubscribeForFilter func() (FilterSubscription, error) + SubscribeWithFilter func(filter.Filter) (FilterSubscription, error) + type Subscription interface + Close func() + Done func() <-chan struct{} + Events func() <-chan Event + type UnitaryHandler interface + OnInitialize func(*appsv1.StatefulSet) + type UnitaryHandlerBuilder interface + Create func() UnitaryHandler + OnCreate func(func(*appsv1.StatefulSet)) UnitaryHandlerBuilder + OnDelete func(func(*appsv1.StatefulSet)) UnitaryHandlerBuilder + OnInitialize func(func(*appsv1.StatefulSet)) UnitaryHandlerBuilder + OnUpdate func(func(*appsv1.StatefulSet)) UnitaryHandlerBuilder + func BuildUnitaryHandler() UnitaryHandlerBuilder
Go to main page