controller

Documentation

Index

• Variables
• type TaskResults
• type WorkflowController
  • func NewWorkflowController(restConfig *rest.Config, kubeclientset kubernetes.Interface, ...) (*WorkflowController, error)
  • func (wfc *WorkflowController) GetContainerRuntimeExecutor() string
  • func (wfc *WorkflowController) GetManagedNamespace() string
  • func (wfc *WorkflowController) Run(ctx context.Context, wfWorkers, workflowTTLWorkers, podWorkers int)
  • func (wfc *WorkflowController) UpdateConfig()

Variables

var (
	// ErrDeadlineExceeded indicates the operation exceeded its deadline for execution
	ErrDeadlineExceeded = errors.New(errors.CodeTimeout, "Deadline exceeded")
	// ErrParallelismReached indicates this workflow reached its parallelism limit
	ErrParallelismReached = errors.New(errors.CodeForbidden, "Max parallelism reached")
	// ErrTimeout indicates a specific template timed out
	ErrTimeout = errors.New(errors.CodeTimeout, "timeout")
)

Types

type TaskResults

type TaskResults struct {
	Succeeded bool `json:"Succeeded"`
	Failed    bool `json:"Failed"`
	Errored   bool `json:"Errored"`
	Skipped   bool `json:"Skipped"`
	Daemoned  bool `json:"Daemoned"`
}

type WorkflowController

type WorkflowController struct {

	// Config is the workflow controller's configuration
	Config config.Config
	// contains filtered or unexported fields
}

WorkflowController is the controller for workflow resources

func NewWorkflowController

func NewWorkflowController(restConfig *rest.Config, kubeclientset kubernetes.Interface, wfclientset wfclientset.Interface, namespace, managedNamespace, executorImage, executorImagePullPolicy, containerRuntimeExecutor, configMap string) (*WorkflowController, error)

NewWorkflowController instantiates a new WorkflowController

func (*WorkflowController) GetContainerRuntimeExecutor

func (wfc *WorkflowController) GetContainerRuntimeExecutor() string

func (*WorkflowController) GetManagedNamespace

func (wfc *WorkflowController) GetManagedNamespace() string

func (*WorkflowController) Run

func (wfc *WorkflowController) Run(ctx context.Context, wfWorkers, workflowTTLWorkers, podWorkers int)

Run starts an Workflow resource controller

func (*WorkflowController) UpdateConfig

func (wfc *WorkflowController) UpdateConfig()