controller

Documentation

Index

• func Register(name string, controller Controller)
• func StartAllController() error
• type BaseController
  • func (bc *BaseController) GetNodeStatus(string) ([]v1alpha1.TaskStatus, error)
  • func (bc *BaseController) Name() string
  • func (bc *BaseController) ReportNodeStatus(string, string, fsm.Event) (api.State, error)
  • func (bc *BaseController) ReportTaskStatus(string, fsm.Event) (api.State, error)
  • func (bc *BaseController) StageCompleted(string, api.State) bool
  • func (bc *BaseController) Start() error
  • func (bc *BaseController) UpdateNodeStatus(string, []v1alpha1.TaskStatus) error
  • func (bc *BaseController) ValidateNode(taskMessage util.TaskMessage) []v1.Node
• type Controller
  • func GetController(name string) (Controller, error)

Functions

func Register

func Register(name string, controller Controller)

func StartAllController

func StartAllController() error

Types

type BaseController

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

func (*BaseController) GetNodeStatus

func (bc *BaseController) GetNodeStatus(string) ([]v1alpha1.TaskStatus, error)

func (*BaseController) Name

func (bc *BaseController) Name() string

func (*BaseController) ReportNodeStatus

func (bc *BaseController) ReportNodeStatus(string, string, fsm.Event) (api.State, error)

func (*BaseController) ReportTaskStatus

func (bc *BaseController) ReportTaskStatus(string, fsm.Event) (api.State, error)

func (*BaseController) StageCompleted

func (bc *BaseController) StageCompleted(string, api.State) bool

func (*BaseController) Start

func (bc *BaseController) Start() error

func (*BaseController) UpdateNodeStatus

func (bc *BaseController) UpdateNodeStatus(string, []v1alpha1.TaskStatus) error

func (*BaseController) ValidateNode

func (bc *BaseController) ValidateNode(taskMessage util.TaskMessage) []v1.Node

type Controller

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
}

func GetController

func GetController(name string) (Controller, error)