timeout

Documentation

Index

• func NewInvariant(p NewTimeoutParams) invariant.Invariant
• type ActivityTimeoutMetadata
• type ChildWfTimeoutMetadata
• type DecisionTimeoutMetadata
• type ExecutionTimeoutMetadata
• type HeartbeatingMetadata
• type NewTimeoutParams
• type PollersMetadata
• type Timeout
• type TimeoutType
  • func (tt TimeoutType) String() string

Functions

func NewInvariant

func NewInvariant(p NewTimeoutParams) invariant.Invariant

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 DecisionTimeoutMetadata

type DecisionTimeoutMetadata struct {
	ConfiguredTimeout time.Duration
}

type ExecutionTimeoutMetadata

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

type HeartbeatingMetadata

type HeartbeatingMetadata struct {
	TimeElapsed time.Duration
}

type NewTimeoutParams

type NewTimeoutParams struct {
	WorkflowExecutionHistory *types.GetWorkflowExecutionHistoryResponse
	Domain                   string
	ClientBean               client.Bean
}

type PollersMetadata

type PollersMetadata struct {
	TaskListBacklog int64
}

type Timeout

type Timeout invariant.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