invariant

Documentation

Index

• func MarshalData(rc any) []byte
• type Invariant
• type InvariantCheckResult
• type InvariantRootCauseResult
• type RootCause
  • func (r RootCause) String() string

Functions

func MarshalData

func MarshalData(rc any) []byte

Types

type Invariant

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

Invariant represents a condition of a workflow execution.

type InvariantCheckResult

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

InvariantCheckResult is the result from the invariant check

type InvariantRootCauseResult

type InvariantRootCauseResult struct {
	RootCause RootCause
	Metadata  []byte
}

InvariantRootCauseResult is the root cause for the issues identified in the invariant check

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"
	RootCauseTypeServiceSideIssue                    RootCause = "There is an issue in the worker service code that is causing this failure. Check identity for service logs"
)

func (RootCause) String

func (r RootCause) String() string