controller

type BaseController struct {
	Informer    k8sinformer.SharedInformerFactory
	TaskManager *manager.TaskCache
	MessageChan chan util.TaskMessage
	KubeClient  kubernetes.Interface
	CrdClient   crdClientset.Interface
	// contains filtered or unexported fields
}

type Controller interface {
	Name() string
	Start() error
	ReportNodeStatus(string, string, fsm.Event) (api.State, error)
	ReportTaskStatus(string, fsm.Event) (api.State, error)
	ValidateNode(util.TaskMessage) []v1.Node
	GetNodeStatus(string) ([]v1alpha1.TaskStatus, error)
	UpdateNodeStatus(string, []v1alpha1.TaskStatus) error
	StageCompleted(taskID string, state api.State) bool
}