workflow

Documentation

Index

• Constants
• Variables
• func ComputeWorkflowRevisionHash(rev string, app *oamcore.Application) (string, error)
• func ConvertWorkflowStatus(status workflowv1alpha1.WorkflowRunStatus, revision string) *common.WorkflowStatus
• func IsFailedAfterRetry(app *oamcore.Application) bool

Constants

const (
	// MessageTerminatedFailedAfterRetries is the message of failed after retries
	MessageTerminatedFailedAfterRetries = "The workflow terminates automatically because the failed times of steps have reached the limit"
	// MessageSuspendFailedAfterRetries is the message of failed after retries
	MessageSuspendFailedAfterRetries = "The workflow suspends automatically because the failed times of steps have reached the limit"
)

Variables

var (
	// DisableRecorder optimize workflow by disable recorder
	DisableRecorder = false
)

Functions

func ComputeWorkflowRevisionHash

func ComputeWorkflowRevisionHash(rev string, app *oamcore.Application) (string, error)

ComputeWorkflowRevisionHash compute workflow revision.

func ConvertWorkflowStatus

func ConvertWorkflowStatus(status workflowv1alpha1.WorkflowRunStatus, revision string) *common.WorkflowStatus

ConvertWorkflowStatus convert workflow run status to workflow status

func IsFailedAfterRetry

func IsFailedAfterRetry(app *oamcore.Application) bool

IsFailedAfterRetry check if application is hang due to FailedAfterRetry