nodeupgradecontroller

Documentation

Index

• Constants
• func NewUpgradeNodeFSM(taskName, nodeName string) *fsm.FSM
• func NewUpgradeTaskFSM(taskName string) *fsm.FSM
• type NodeUpgradeController
  • func NewNodeUpgradeController(messageChan chan util.TaskMessage) (*NodeUpgradeController, error)
  • func (ndc *NodeUpgradeController) GetNodeStatus(name string) ([]v1alpha1.TaskStatus, error)
  • func (ndc *NodeUpgradeController) GetNodeVersion(name string) (string, error)
  • func (ndc *NodeUpgradeController) ReportNodeStatus(taskID, nodeID string, event fsm.Event) (api.State, error)
  • func (ndc *NodeUpgradeController) ReportTaskStatus(taskID string, event fsm.Event) (api.State, error)
  • func (ndc *NodeUpgradeController) StageCompleted(taskID string, state api.State) bool
  • func (ndc *NodeUpgradeController) Start() error
  • func (ndc *NodeUpgradeController) UpdateNodeStatus(name string, nodeStatus []v1alpha1.TaskStatus) error
  • func (ndc *NodeUpgradeController) ValidateNode(taskMessage util.TaskMessage) []v1.Node

Constants

const NodeUpgrade = "NodeUpgradeController"

Functions

func NewUpgradeNodeFSM

func NewUpgradeNodeFSM(taskName, nodeName string) *fsm.FSM

func NewUpgradeTaskFSM

func NewUpgradeTaskFSM(taskName string) *fsm.FSM

Types

type NodeUpgradeController

type NodeUpgradeController struct {
	sync.Mutex
	*controller.BaseController
}

func NewNodeUpgradeController

func NewNodeUpgradeController(messageChan chan util.TaskMessage) (*NodeUpgradeController, error)

func (*NodeUpgradeController) GetNodeStatus

func (ndc *NodeUpgradeController) GetNodeStatus(name string) ([]v1alpha1.TaskStatus, error)

func (*NodeUpgradeController) GetNodeVersion

func (ndc *NodeUpgradeController) GetNodeVersion(name string) (string, error)

func (*NodeUpgradeController) ReportNodeStatus

func (ndc *NodeUpgradeController) ReportNodeStatus(taskID, nodeID string, event fsm.Event) (api.State, error)

func (*NodeUpgradeController) ReportTaskStatus

func (ndc *NodeUpgradeController) ReportTaskStatus(taskID string, event fsm.Event) (api.State, error)

func (*NodeUpgradeController) StageCompleted

func (ndc *NodeUpgradeController) StageCompleted(taskID string, state api.State) bool

func (*NodeUpgradeController) Start

func (ndc *NodeUpgradeController) Start() error

func (*NodeUpgradeController) UpdateNodeStatus

func (ndc *NodeUpgradeController) UpdateNodeStatus(name string, nodeStatus []v1alpha1.TaskStatus) error

func (*NodeUpgradeController) ValidateNode

func (ndc *NodeUpgradeController) ValidateNode(taskMessage util.TaskMessage) []v1.Node