Versions in this module Expand all Collapse all v0 v0.1.1 Jul 15, 2026 v0.1.0 Jul 15, 2026 Changes in this version + func Emit(ctx context.Context, payload any) error + func Event[O any](ctx context.Context, name string) (O, error) + func Exec[I, O any](ctx context.Context, c *Client, a *ActivityFn[I, O], in I, opts ...StartOption) (O, error) + func IdempotencyKey(ctx context.Context) string + func InRun(ctx context.Context) bool + func NonRetryable(err error) error + func PriorDeltas(ctx context.Context) ([][]byte, error) + func Step[O any](ctx context.Context, name string, fn func(context.Context) (O, error)) (O, error) + type ActivityFn struct + func ActivityIn[I, O any](reg *run.Registry, name string, fn func(context.Context, I) (O, error)) *ActivityFn[I, O] + func Activity[I, O any](name string, fn func(context.Context, I) (O, error)) *ActivityFn[I, O] + func (a *ActivityFn[I, O]) Call(ctx context.Context, in I) (O, error) + func (a *ActivityFn[I, O]) CallKeyed(ctx context.Context, key string, in I) (O, error) + func (a *ActivityFn[I, O]) Name() string + type Client struct + func New(lgr ledger.Ledger, q queue.Queue, opts ...ClientOption) *Client + func (c *Client) Signal(ctx context.Context, runID, name string, payload any) error + func (c *Client) Watch(ctx context.Context, runID string, from queue.Cursor) (queue.Stream, error) + type ClientOption func(*Client) + func WithCodec(c run.Codec) ClientOption + func WithDefaultMaxAttempts(n int) ClientOption + type DecodeError struct + Err error + Name string + func (e *DecodeError) Error() string + func (e *DecodeError) Unwrap() error + type Handle struct + func HandleFor[O any](c *Client, runID string) *Handle[O] + func Start[I, O any](ctx context.Context, c *Client, a *ActivityFn[I, O], in I, opts ...StartOption) (*Handle[O], error) + func (h *Handle[O]) Result(ctx context.Context) (O, error) + func (h *Handle[O]) RunID() string + type RunFailedError struct + Message string + RunID string + func (e *RunFailedError) Error() string + type RunInfo struct + Attempt int + RunID string + func FromContext(ctx context.Context) (RunInfo, bool) + type StartOption func(*startCfg) + func WithMaxAttempts(n int) StartOption + func WithParent(runID string) StartOption + func WithRunID(id string) StartOption + type Void = struct
Go to main page