state

Documentation

Index

• type JobFlowActionFn
• type State
  • func NewState(jobFlow *v1alpha1.JobFlow) State
• type UpdateJobFlowStatusFn

Types

type JobFlowActionFn

type JobFlowActionFn func(jobflow *v1alpha1.JobFlow, fn UpdateJobFlowStatusFn) error

var (
	// SyncJobFlow will sync queue status.
	SyncJobFlow JobFlowActionFn
)

type State

type State interface {
	// Execute executes the actions based on current state.
	Execute(action v1alpha1.Action) error
}

func NewState

func NewState(jobFlow *v1alpha1.JobFlow) State

NewState gets the state from queue status.

type UpdateJobFlowStatusFn

type UpdateJobFlowStatusFn func(status *v1alpha1.JobFlowStatus, allJobList int)

UpdateJobFlowStatusFn updates the jobFlow status.