workflowmanager

Jun 25, 2026

Changes in this version

type Manager

+ Terminated bool

type Option

+ func WithOnTerminated(fn func(ctx workflow.Context, historyLen int)) Option

+ func WithTerminateThreshold(n int) Option

Jun 2, 2026

Changes in this version

type Option

+ func WithDeferRestart(fn func() bool) Option

May 29, 2026

Changes in this version

+ type CANHintChecker interface

+ CheckCANHint func(ctx workflow.Context) (bool, error)

+ ClearCANHint func(ctx workflow.Context) error

+ type CANHintCheckerFunc struct

+ CheckFn func(ctx workflow.Context) (bool, error)

+ ClearFn func(ctx workflow.Context) error

+ func (f CANHintCheckerFunc) CheckCANHint(ctx workflow.Context) (bool, error)

+ func (f CANHintCheckerFunc) ClearCANHint(ctx workflow.Context) error

+ type CANResponse struct

+ HintRequested bool

+ HistoryLength int

+ HistoryMax int

+ Namespace string

+ Restarting bool

+ WorkflowType string

+ type Manager struct

+ Restarted bool

+ Stopped bool

+ func New(opts ...Option) *Manager

+ func (m *Manager) RunCANCheck(ctx workflow.Context) (bool, *CANResponse)

+ func (m *Manager) Start(ctx workflow.Context)

+ type Option func(*options)

+ func WithAliveChecker(fn func(ctx workflow.Context) (bool, error)) Option

+ func WithCANHintChecker(c CANHintChecker) Option

+ func WithCheckInterval(d time.Duration) Option

+ func WithExpiryChecker(fn func(ctx workflow.Context) (*time.Time, error)) Option

+ func WithHistoryMax(n int) Option

+ func WithMetricsWriter(mw tmetrics.Writer) Option

+ func WithOnStopped(fn func(ctx workflow.Context)) Option