Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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") )
Functions ¶
This section is empty.
Types ¶
type RetryTweak ¶
RetryTweak is a 2nd order function interface for tweaking the retry
func RetryOnDifferentHost ¶
func RetryOnDifferentHost(retryNodeName string) RetryTweak
RetryOnDifferentHost append affinity with fail host to template
type TaskResults ¶
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(ctx context.Context, 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, podCleanupWorkers int)
Run starts an Workflow resource controller
func (*WorkflowController) UpdateConfig ¶
func (wfc *WorkflowController) UpdateConfig(ctx context.Context)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.