controllers

type Action interface {
	Name() string
	// Execute should attempt to execute the action. If it is not possible to
	// apply the specified changes (e.g. due to the cluster not being in a
	// 'ready state', or some transient error) then an error will be returned
	// so the action can be requeued. This allows for non-blocking blocking of
	// actions, with retries. The workqueues default scheduling and rate limit
	// will thus handle fairness within Navigator, and handle backing off on
	// retries.
	Execute(state *State) error
}

type BlockingEventHandler struct {
	WorkFunc func(obj interface{})
}

type Constructor func(ctx *Context) Interface

type Context struct {
	Client          kubernetes.Interface
	NavigatorClient clientset.Interface

	// Recorder to record events to
	Recorder                  record.EventRecorder
	KubeSharedInformerFactory kubeinformers.SharedInformerFactory
	SharedInformerFactory     intinformers.SharedInformerFactory

	Namespace string
}

type Interface func(workers int, stopCh <-chan struct{}) error

type QueuingEventHandler struct {
	Queue workqueue.RateLimitingInterface
}

type State struct {
	// The Clientset to use when performing updates
	Clientset kubernetes.Interface
	// The NavigatorClientset to use for updates
	NavigatorClientset clientset.Interface
	Recorder           record.EventRecorder

	StatefulSetLister    appslisters.StatefulSetLister
	ConfigMapLister      corelisters.ConfigMapLister
	PilotLister          listers.PilotLister
	PodLister            corelisters.PodLister
	ServiceLister        corelisters.ServiceLister
	ServiceAccountLister corelisters.ServiceAccountLister
	RoleBindingLister    rbaclisters.RoleBindingLister
	RoleLister           rbaclisters.RoleLister
}