invariants

Documentation

Index

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

Types

type ActivityTimeoutMetadata

type ActivityTimeoutMetadata struct {
	TimeoutType       *types.TimeoutType
	ConfiguredTimeout time.Duration
	TimeElapsed       time.Duration
	RetryPolicy       *types.RetryPolicy
	HeartBeatTimeout  time.Duration
	Tasklist          *types.TaskList
}

type ChildWfTimeoutMetadata

type ChildWfTimeoutMetadata struct {
	ExecutionTime     time.Duration
	ConfiguredTimeout time.Duration
	Execution         *types.WorkflowExecution
}

type ExecutionTimeoutMetadata

type ExecutionTimeoutMetadata struct {
	ExecutionTime     time.Duration
	ConfiguredTimeout time.Duration
	LastOngoingEvent  *types.HistoryEvent
}

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