invariants

Documentation

Index

• type Invariant
  • func NewTimeout(wfHistory *types.GetWorkflowExecutionHistoryResponse) Invariant
• type InvariantCheckResult
• type Timeout
• type TimeoutType
  • func (tt TimeoutType) String() string

Types

type Invariant

type Invariant interface {
	Check(context.Context) ([]InvariantCheckResult, error)
}

Invariant represents a condition of a workflow execution.

func NewTimeout

func NewTimeout(wfHistory *types.GetWorkflowExecutionHistoryResponse) Invariant

type InvariantCheckResult

type InvariantCheckResult struct {
	InvariantType string
	Reason        string
	Metadata      []byte
}

InvariantCheckResult is the result from the invariant check

type Timeout

type Timeout Invariant

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