Versions in this module Expand all Collapse all v0 v0.19.978 May 29, 2026 v0.19.976 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
Go to main page