Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActivityTimeoutMetadata ¶
type ChildWfTimeoutMetadata ¶
type Invariant ¶
type Invariant interface { Check(context.Context) ([]InvariantCheckResult, error) RootCause(context.Context, []InvariantCheckResult) ([]InvariantRootCauseResult, error) }
Invariant represents a condition of a workflow execution.
func NewTimeout ¶
func NewTimeout(p NewTimeoutParams) Invariant
type InvariantCheckResult ¶
InvariantCheckResult is the result from the invariant check
type InvariantRootCauseResult ¶
InvariantRootCauseResult is the root cause for the issues identified in the invariant check
type NewTimeoutParams ¶
type NewTimeoutParams struct { WorkflowExecutionHistory *types.GetWorkflowExecutionHistoryResponse Domain string ClientBean client.Bean }
type RootCause ¶
type RootCause string
const ( RootCauseTypeMissingPollers RootCause = "There are no pollers for the tasklist" RootCauseTypePollersStatus RootCause = "There are pollers for the tasklist. Check backlog status" RootCauseTypeHeartBeatingNotEnabled RootCause = "HeartBeating not enabled for activity" RootCauseTypeHeartBeatingEnabledMissingHeartbeat RootCause = "HeartBeating enabled for activity but timed out due to missing heartbeat" )
type TimeoutType ¶
type TimeoutType string
const ( TimeoutTypeExecution TimeoutType = "The Workflow Execution has timed out" TimeoutTypeActivity TimeoutType = "Activity task has timed out" TimeoutTypeDecision TimeoutType = "Decision task has timed out" TimeoutTypeChildWorkflow TimeoutType = "Child Workflow Execution has timed out" )
func (TimeoutType) String ¶
func (tt TimeoutType) String() string
Click to show internal directories.
Click to hide internal directories.