Versions in this module Expand all Collapse all v4 v4.0.2 Mar 11, 2026 Changes in this version + var ErrDeadlineExceeded = argoerrors.New(argoerrors.CodeTimeout, "Deadline exceeded") + var ErrMaxDepthExceeded = argoerrors.New(argoerrors.CodeTimeout, ...) + var ErrParallelismReached = argoerrors.New(argoerrors.CodeForbidden, "Max parallelism reached") + var ErrRequeue = errors.New("requeue") + var ErrResourceRateLimitReached = argoerrors.New(argoerrors.CodeForbidden, "resource creation rate-limit reached") + var ErrTimeout = argoerrors.New(argoerrors.CodeTimeout, "timeout") + func FindRetryNode(nodes wfv1.Nodes, nodeID string) *wfv1.NodeStatus + func GetRequeueTime() time.Duration + func LogMiddleware(logger logging.Logger, next http.Handler) http.Handler + type RetryTweak = func(retryStrategy wfv1.RetryStrategy, nodes wfv1.Nodes, pod *apiv1.Pod) + func RetryOnDifferentHost(retryNodeName string) RetryTweak + type TaskResults struct + AllFailed bool + AnySucceeded bool + Daemoned bool + Errored bool + Failed bool + Omitted bool + Skipped bool + Succeeded bool + type WorkflowController struct + Config config.Config + PodController *pod.Controller + func NewWorkflowController(ctx context.Context, restConfig *rest.Config, ...) (*WorkflowController, error) + func (wfc *WorkflowController) GetManagedNamespace() string + func (wfc *WorkflowController) Healthz(w http.ResponseWriter, r *http.Request) + func (wfc *WorkflowController) IsLeader() bool + func (wfc *WorkflowController) Run(ctx context.Context, ...) + func (wfc *WorkflowController) RunPrometheusServer(ctx context.Context, isDummy bool) + func (wfc *WorkflowController) UpdateConfig(ctx context.Context) Other modules containing this package github.com/argoproj/argo-workflows github.com/argoproj/argo-workflows/v3
Go to main page