Versions in this module Expand all Collapse all v0 v0.1.2 Jun 3, 2020 Changes in this version + var ErrDeadlineExceeded = errors.New(errors.CodeTimeout, "Deadline exceeded") + var ErrParallelismReached = errors.New(errors.CodeForbidden, "Max parallelism reached") + func ReadConfigMapValue(clientset kubernetes.Interface, namespace string, name string, key string) (string, error) + type Throttler interface + Add func(key interface{}, priority int32, creationTime time.Time) + Next func(key interface{}) (interface{}, bool) + Remove func(key interface{}) + SetParallelism func(parallelism int) + func NewThrottler(parallelism int, queue workqueue.RateLimitingInterface) Throttler + type WorkflowController struct + Config config.WorkflowControllerConfig + func NewWorkflowController(restConfig *rest.Config, kubeclientset kubernetes.Interface, ...) *WorkflowController + func (wfc *WorkflowController) GetContainerRuntimeExecutor() string + func (wfc *WorkflowController) GetManagedNamespace() string + func (wfc *WorkflowController) MetricsServer(ctx context.Context) + func (wfc *WorkflowController) ResyncConfig() error + func (wfc *WorkflowController) Run(ctx context.Context, wfWorkers, podWorkers int) + func (wfc *WorkflowController) RunCronController(ctx context.Context) + func (wfc *WorkflowController) RunTTLController(ctx context.Context) + func (wfc *WorkflowController) TelemetryServer(ctx context.Context)
Go to main page