wrap

package
v1.23.0-cx Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2026 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

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 (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 (*ConfigUpdateJobTask) SetPhase

func (task *ConfigUpdateJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)

type ImagePrePullJob

type ImagePrePullJob struct {
	Obj *operationsv1alpha2.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 (*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

func WithEventObj(obj any) (NodeJob, error)

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 (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 (*NodeUpgradeJobTask) SetPhase

func (task *NodeUpgradeJobTask) SetPhase(phase operationsv1alpha2.NodeTaskPhase, reason ...string)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL