workflow

Sep 24, 2026

Changes in this version

type Worker

+ func (w *Worker) RegisterOperation[TIn, TOut any](name, version string, fn func(ctx context.Context, in TIn) (TOut, error))

+ func (w *Worker) RegisterWorkflow[TIn, TOut any](name, version string, fn func(ctx Context, in TIn) (TOut, error))

Jul 27, 2026

Changes in this version

type Manager

+ func (m *Manager) Resume(ctx context.Context, id uuid.UUID) error

+ func (m *Manager) Suspend(ctx context.Context, id uuid.UUID, reason string) error

Jul 26, 2026

Changes in this version

type Option

+ func WithConcurrency(n int) Option

+ func WithShutdownDrain(d time.Duration) Option

type Worker

+ func (w *Worker) Wait(ctx context.Context) error

Jul 25, 2026

Changes in this version

+ var ErrSelectNoFutures = errors.New("workflow: Select requires at least one future")

+ var ErrUncertain = errors.New("workflow: operation uncertain")

+ var ErrUnknownOperation = errors.New("workflow: unknown operation (name, version)")

+ var ErrUnknownWorkflow = errors.New("workflow: unknown workflow (name, version)")

+ func ExecutionKey(ctx context.Context) string

+ func IsNotFound(err error) bool

+ func IsUncertain(err error) bool

+ func RegisterOperation[TIn, TOut any](w *Worker, name, version string, ...)

+ func RegisterWorkflow[TIn, TOut any](w *Worker, name, version string, fn func(ctx Context, in TIn) (TOut, error))

+ func Select(ctx Context, futures ...Future) (int, error)

+ type Client struct

+ func (c *Client) Signal(ctx context.Context, workflowID uuid.UUID, name string, payload any, ...) (bool, error)

+ func (c *Client) Start(ctx context.Context, name, version string, input any, opts ...StartOption) (StartResult, error)

+ type Context interface

+ Now func() time.Time

+ RunID func() uuid.UUID

+ WorkflowID func() uuid.UUID

+ type Future struct

+ func ExecuteOperation(ctx Context, name, version string, input any) Future

+ func Sleep(ctx Context, d time.Duration) Future

+ func WaitSignal(ctx Context, name string) Future

+ func (f Future) Err() error

+ func (f Future) Get(out any) error

+ func (f Future) Ready() bool

+ type Manager struct

+ func (m *Manager) Cancel(ctx context.Context, id uuid.UUID) error

+ func (m *Manager) Get(ctx context.Context, id uuid.UUID) (View, error)

+ func (m *Manager) ResolveUncertain(ctx context.Context, operationJobID uuid.UUID, decision string, ...) error

+ type Option func(*config) error

+ func WithCoreOptions(opts ...azync.Option) Option

+ func WithDefaultMaxRetries(n int) Option

+ func WithFetchPollInterval(d time.Duration) Option

+ func WithLeaseTTL(d time.Duration) Option

+ func WithOperationRetryDelay(d time.Duration) Option

+ func WithOperationTimeout(d time.Duration) Option

+ func WithRetention(d time.Duration) Option

+ func WithWorkerMode(mode WorkerMode) Option

+ type Runtime struct

+ func New(core *azync.Core, opts ...Option) (*Runtime, error)

+ func Open(dsn string, opts ...Option) (*Runtime, error)

+ func (r *Runtime) Client() *Client

+ func (r *Runtime) Close(ctx context.Context) error

+ func (r *Runtime) Manager() *Manager

+ func (r *Runtime) Migrate(ctx context.Context) error

+ func (r *Runtime) Worker() *Worker

+ type SignalOption func(*signalOptions)

+ func WithMessageID(id string) SignalOption

+ type StartOption func(*startOptions)

+ func WithBusinessIdempotencyKey(key string) StartOption

+ func WithStartMeta(key, value string) StartOption

+ func WithTaskQueue(name string) StartOption

+ func WithWorkflowID(id uuid.UUID) StartOption

+ type StartResult struct

+ Deduplicated bool

+ WorkflowID uuid.UUID

+ type View = driver.WorkflowExecutionView

+ type Worker struct

+ func (w *Worker) ProcessNext(ctx context.Context) (bool, error)

+ func (w *Worker) Start(ctx context.Context) error

+ type WorkerMode string

+ const WorkerModeCombined

+ const WorkerModeOperationOnly

+ const WorkerModeWorkflowOnly