Documentation ¶
Index ¶
- func NewImagePrePullNodeFSM(taskName, nodeName string) *fsm.FSM
- func NewImagePrePullTaskFSM(taskName string) *fsm.FSM
- type ImagePrePullController
- func (ndc *ImagePrePullController) GetNodeStatus(name string) ([]v1alpha1.TaskStatus, error)
- func (ndc *ImagePrePullController) ReportNodeStatus(taskID, nodeID string, event fsm.Event) (api.State, error)
- func (ndc *ImagePrePullController) ReportTaskStatus(taskID string, event fsm.Event) (api.State, error)
- func (ndc *ImagePrePullController) StageCompleted(taskID string, state api.State) bool
- func (ndc *ImagePrePullController) Start() error
- func (ndc *ImagePrePullController) UpdateNodeStatus(name string, nodeStatus []v1alpha1.TaskStatus) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewImagePrePullNodeFSM ¶
func NewImagePrePullTaskFSM ¶
Types ¶
type ImagePrePullController ¶
type ImagePrePullController struct { sync.Mutex *controller.BaseController }
func NewImagePrePullController ¶
func NewImagePrePullController(messageChan chan util.TaskMessage) (*ImagePrePullController, error)
func (*ImagePrePullController) GetNodeStatus ¶
func (ndc *ImagePrePullController) GetNodeStatus(name string) ([]v1alpha1.TaskStatus, error)
func (*ImagePrePullController) ReportNodeStatus ¶
func (*ImagePrePullController) ReportTaskStatus ¶
func (*ImagePrePullController) StageCompleted ¶
func (ndc *ImagePrePullController) StageCompleted(taskID string, state api.State) bool
func (*ImagePrePullController) Start ¶
func (ndc *ImagePrePullController) Start() error
func (*ImagePrePullController) UpdateNodeStatus ¶
func (ndc *ImagePrePullController) UpdateNodeStatus(name string, nodeStatus []v1alpha1.TaskStatus) error
Click to show internal directories.
Click to hide internal directories.