invariants

Sep 4, 2024

Changes in this version

+ type ActivityTimeoutMetadata struct

+ ConfiguredTimeout time.Duration

+ HeartBeatTimeout time.Duration

+ RetryPolicy *types.RetryPolicy

+ Tasklist *types.TaskList

+ TimeElapsed time.Duration

+ TimeoutType *types.TimeoutType

+ type ChildWfTimeoutMetadata struct

+ ConfiguredTimeout time.Duration

+ Execution *types.WorkflowExecution

+ ExecutionTime time.Duration

+ type ExecutionTimeoutMetadata struct

+ ConfiguredTimeout time.Duration

+ ExecutionTime time.Duration

+ LastOngoingEvent *types.HistoryEvent

+ Tasklist *types.TaskList

+ type Invariant interface

+ Check func(context.Context) ([]InvariantCheckResult, error)

+ RootCause func(context.Context, []InvariantCheckResult) ([]InvariantRootCauseResult, error)

+ func NewTimeout(p NewTimeoutParams) Invariant

+ type InvariantCheckResult struct

+ InvariantType string

+ Metadata []byte

+ Reason string

+ type InvariantRootCauseResult struct

+ Metadata []byte

+ RootCause RootCause

+ type NewTimeoutParams struct

+ ClientBean client.Bean

+ Domain string

+ WorkflowExecutionHistory *types.GetWorkflowExecutionHistoryResponse

+ type RootCause string

+ const RootCauseTypeHeartBeatingEnabledMissingHeartbeat

+ const RootCauseTypeHeartBeatingNotEnabled

+ const RootCauseTypeMissingPollers

+ const RootCauseTypePollersStatus

+ func (r RootCause) String() string

+ type Timeout Invariant

+ type TimeoutType string

+ const TimeoutTypeActivity

+ const TimeoutTypeChildWorkflow

+ const TimeoutTypeDecision

+ const TimeoutTypeExecution

+ func (tt TimeoutType) String() string