Documentation
¶
Index ¶
- type ConfigUpdateJob
- type ConfigUpdateJobTask
- func (task *ConfigUpdateJobTask) Action() (*actionflow.Action, error)
- func (task *ConfigUpdateJobTask) CanExecute() bool
- func (task *ConfigUpdateJobTask) GetObject() any
- func (task *ConfigUpdateJobTask) NodeName() string
- func (task *ConfigUpdateJobTask) Phase() operationsv1alpha2.NodeTaskPhase
- func (task *ConfigUpdateJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)
- type ImagePrePullJob
- type ImagePrePullJobTask
- func (task ImagePrePullJobTask) Action() (*actionflow.Action, error)
- func (task ImagePrePullJobTask) CanExecute() bool
- func (task ImagePrePullJobTask) GetObject() any
- func (task ImagePrePullJobTask) NodeName() string
- func (task ImagePrePullJobTask) Phase() operationsv1alpha2.NodeTaskPhase
- func (task *ImagePrePullJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)
- type NodeJob
- type NodeJobTask
- type NodeUpgradeJob
- type NodeUpgradeJobTask
- func (task NodeUpgradeJobTask) Action() (*actionflow.Action, error)
- func (task NodeUpgradeJobTask) CanExecute() bool
- func (task NodeUpgradeJobTask) GetObject() any
- func (task NodeUpgradeJobTask) NodeName() string
- func (task NodeUpgradeJobTask) Phase() operationsv1alpha2.NodeTaskPhase
- func (task *NodeUpgradeJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigUpdateJob ¶
type ConfigUpdateJob struct {
Obj *operationsv1alpha2.ConfigUpdateJob
}
func NewConfigUpdateJob ¶
func NewConfigUpdateJob(obj *operationsv1alpha2.ConfigUpdateJob) *ConfigUpdateJob
func (ConfigUpdateJob) Concurrency ¶
func (job ConfigUpdateJob) Concurrency() int
func (ConfigUpdateJob) GetObject ¶
func (job ConfigUpdateJob) GetObject() any
func (ConfigUpdateJob) Name ¶
func (job ConfigUpdateJob) Name() string
func (ConfigUpdateJob) ResourceType ¶
func (job ConfigUpdateJob) ResourceType() string
func (ConfigUpdateJob) Spec ¶
func (job ConfigUpdateJob) Spec() any
func (ConfigUpdateJob) Tasks ¶
func (job ConfigUpdateJob) Tasks() []NodeJobTask
type ConfigUpdateJobTask ¶
type ConfigUpdateJobTask struct {
Obj *operationsv1alpha2.ConfigUpdateJobNodeTaskStatus
}
func (*ConfigUpdateJobTask) Action ¶
func (task *ConfigUpdateJobTask) Action() (*actionflow.Action, error)
func (*ConfigUpdateJobTask) CanExecute ¶
func (task *ConfigUpdateJobTask) CanExecute() bool
func (*ConfigUpdateJobTask) GetObject ¶
func (task *ConfigUpdateJobTask) GetObject() any
func (*ConfigUpdateJobTask) NodeName ¶
func (task *ConfigUpdateJobTask) NodeName() string
func (*ConfigUpdateJobTask) Phase ¶
func (task *ConfigUpdateJobTask) Phase() operationsv1alpha2.NodeTaskPhase
func (*ConfigUpdateJobTask) SetPhase ¶
func (task *ConfigUpdateJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)
type ImagePrePullJob ¶
type ImagePrePullJob struct {
Obj *operationsv1alpha2.ImagePrePullJob
}
func NewImagePrepullJob ¶
func NewImagePrepullJob(obj *operationsv1alpha2.ImagePrePullJob) *ImagePrePullJob
func (ImagePrePullJob) Concurrency ¶
func (job ImagePrePullJob) Concurrency() int
func (ImagePrePullJob) GetObject ¶
func (job ImagePrePullJob) GetObject() any
func (ImagePrePullJob) Name ¶
func (job ImagePrePullJob) Name() string
func (ImagePrePullJob) ResourceType ¶
func (job ImagePrePullJob) ResourceType() string
func (ImagePrePullJob) Spec ¶
func (job ImagePrePullJob) Spec() any
func (ImagePrePullJob) Tasks ¶
func (job ImagePrePullJob) Tasks() []NodeJobTask
type ImagePrePullJobTask ¶
type ImagePrePullJobTask struct {
Obj *operationsv1alpha2.ImagePrePullNodeTaskStatus
}
func (ImagePrePullJobTask) Action ¶
func (task ImagePrePullJobTask) Action() (*actionflow.Action, error)
func (ImagePrePullJobTask) CanExecute ¶
func (task ImagePrePullJobTask) CanExecute() bool
func (ImagePrePullJobTask) GetObject ¶
func (task ImagePrePullJobTask) GetObject() any
func (ImagePrePullJobTask) NodeName ¶
func (task ImagePrePullJobTask) NodeName() string
func (ImagePrePullJobTask) Phase ¶
func (task ImagePrePullJobTask) Phase() operationsv1alpha2.NodeTaskPhase
func (*ImagePrePullJobTask) SetPhase ¶
func (task *ImagePrePullJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)
type NodeJob ¶
type NodeJob interface {
// Name returns the name of the node job.
Name() string
// ResourceType returns the resource type of the node job.
ResourceType() string
// Concurrency returns the concurrency in the node job spec.
Concurrency() int
// Spec returns the spec of the node job.
Spec() any
// Tasks returns the node tasks of the node job.
Tasks() []NodeJobTask
// GetObject returns the node job object.
GetObject() any
}
func WithEventObj ¶
WithEventObj returns the node job wrap based on the event object.
type NodeJobTask ¶
type NodeJobTask interface {
// NodeName returns the node name of the node task.
NodeName() string
// CanExecute returns whether the node job status can be executed.
CanExecute() bool
// Phase returns the phase of the node task.
Phase() operationsv1alpha2.NodeTaskPhase
// SetPhase sets the phase of the node task.
SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)
// Action returns the first action from the action flow.
// Continuing execution is not supported now.
Action() (*actionflow.Action, error)
// GetObject returns the node task object.
GetObject() any
}
type NodeUpgradeJob ¶
type NodeUpgradeJob struct {
Obj *operationsv1alpha2.NodeUpgradeJob
}
func NewNodeUpgradeJob ¶
func NewNodeUpgradeJob(obj *operationsv1alpha2.NodeUpgradeJob) *NodeUpgradeJob
func (NodeUpgradeJob) Concurrency ¶
func (job NodeUpgradeJob) Concurrency() int
func (NodeUpgradeJob) GetObject ¶
func (job NodeUpgradeJob) GetObject() any
func (NodeUpgradeJob) Name ¶
func (job NodeUpgradeJob) Name() string
func (NodeUpgradeJob) ResourceType ¶
func (job NodeUpgradeJob) ResourceType() string
func (NodeUpgradeJob) Spec ¶
func (job NodeUpgradeJob) Spec() any
func (NodeUpgradeJob) Tasks ¶
func (job NodeUpgradeJob) Tasks() []NodeJobTask
type NodeUpgradeJobTask ¶
type NodeUpgradeJobTask struct {
Obj *operationsv1alpha2.NodeUpgradeJobNodeTaskStatus
}
func (NodeUpgradeJobTask) Action ¶
func (task NodeUpgradeJobTask) Action() (*actionflow.Action, error)
func (NodeUpgradeJobTask) CanExecute ¶
func (task NodeUpgradeJobTask) CanExecute() bool
func (NodeUpgradeJobTask) GetObject ¶
func (task NodeUpgradeJobTask) GetObject() any
func (NodeUpgradeJobTask) NodeName ¶
func (task NodeUpgradeJobTask) NodeName() string
func (NodeUpgradeJobTask) Phase ¶
func (task NodeUpgradeJobTask) Phase() operationsv1alpha2.NodeTaskPhase
func (*NodeUpgradeJobTask) SetPhase ¶
func (task *NodeUpgradeJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)
Click to show internal directories.
Click to hide internal directories.