cord

Aug 26, 2026

Changes in this version

type Cord

+ func (c *Cord) InspectRun(ctx context.Context, runID RunID) (RunReport, error)

+ func (c *Cord) ListRunNodes(ctx context.Context, runID RunID, query NodeQuery) (NodePage, error)

+ func (c *Cord) RunnerID() RunnerID

+ type CurrentLease struct

+ ExpiresAt time.Time

+ Generation int64

+ RunnerID RunnerID

+ type NodeID string

+ type NodePage struct

+ ContinuationToken string

+ Nodes []NodeReport

+ type NodeQuery struct

+ ContinuationToken string

+ PageSize int

+ Reason *TerminalReason

+ State *NodeState

+ type NodeReport struct

+ Attempt int

+ CurrentLease *CurrentLease

+ EligibleAt time.Time

+ FinishedAt *time.Time

+ FirstStartedAt *time.Time

+ FunctionKey string

+ LastStartedAt *time.Time

+ MaxAttempts int

+ NodeID NodeID

+ Reason TerminalReason

+ RunID RunID

+ RunnerID *RunnerID

+ State NodeState

+ StateChangedAt *time.Time

+ type NodeState string

+ const NodeStateCanceled

+ const NodeStateCompleted

+ const NodeStateFailed

+ const NodeStatePending

+ const NodeStateReady

+ const NodeStateRetryWait

+ const NodeStateRunning

+ func (state NodeState) AllowsReason(reason TerminalReason) bool

+ func (state NodeState) IsKnown() bool

+ func (state NodeState) Terminal() (terminal, known bool)

+ type NodeStateCounts struct

+ Canceled int

+ Completed int

+ Failed int

+ Pending int

+ Ready int

+ RetryWait int

+ Running int

+ type RunReport struct

+ FinishedAt *time.Time

+ FirstStartedAt *time.Time

+ ID RunID

+ NodeCounts NodeStateCounts

+ Reason TerminalReason

+ State RunState

+ StateChangedAt time.Time

+ SubmittedAt time.Time

+ TerminalRunnerID *RunnerID

+ WorkflowName string

+ type RunState string

+ const RunStateCanceled

+ const RunStateCanceling

+ const RunStateCompleted

+ const RunStateFailed

+ const RunStateRunning

+ func (state RunState) AllowsReason(reason TerminalReason) bool

+ func (state RunState) IsKnown() bool

+ func (state RunState) Terminal() (terminal, known bool)

+ type RunnerID string

+ type TerminalReason string

+ const ReasonCanceledByRequest

+ const ReasonCanceledByRunFailure

+ const ReasonFailureAttemptsExhausted

+ const ReasonFailureLeaseExpired

+ const ReasonFailureNonRetryable

+ const ReasonSucceeded

+ func (reason TerminalReason) IsKnown() bool

Aug 24, 2026

Changes in this version

+ var ErrRunCanceled = errors.New("cord: workflow run was canceled")

+ var ErrRunConflict = errors.New("cord: workflow submission conflicts with an existing run")

+ var ErrRunFinished = errors.New("cord: workflow run already finished")

+ var ErrRunIncompatible = errors.New("cord: workflow is incompatible with the durable run")

+ var ErrRunNotFound = errors.New("cord: workflow run not found")

+ type RunID string

type Workflow

+ func (w Workflow[I, O]) Cancel(ctx context.Context, runID RunID) error

+ func (w Workflow[I, O]) Get(ctx context.Context, runID RunID) (O, error)

+ func (w Workflow[I, O]) Submit(ctx context.Context, input I, idempotencyKey ...string) (RunID, error)

Aug 21, 2026

Changes in this version

type Cord

+ func (c *Cord) Shutdown(ctx context.Context) error

Aug 15, 2026

Changes in this version

type Options

+ MaxAttempts int

+ RetryBaseDelay time.Duration

+ RetryMaxDelay time.Duration

Aug 15, 2026

Changes in this version

+ type Options struct

+ Concurrency int

+ HeartbeatInterval time.Duration

+ LeaseTTL time.Duration

+ OnSchedulerError func(error)

+ PollInterval time.Duration

Aug 14, 2026

Changes in this version

+ var ErrMigrationFailed = errors.New("cord: migration failed")

+ var ErrSchemaNewer = errors.New("cord: schema is newer than runtime")

+ var ErrSchemaOutdated = errors.New("cord: schema is absent or outdated")

+ func Permanent(err error) error

+ type Cord struct

+ func New(database *sql.DB) (*Cord, error)

+ func NewWithOptions(database *sql.DB, options RuntimeOptions) (*Cord, error)

+ func NewWithOptionsContext(ctx context.Context, database *sql.DB, options RuntimeOptions) (*Cord, error)

+ func (c *Cord) Close() error

+ func (c *Cord) From[I, O any](name string, step func(context.Context, I) (O, error)) Workflow[I, O]

+ func (c *Cord) SetRetryPolicy(policy RetryPolicy) error

+ type JoinResult struct

+ func Join[I, A, B any](left Workflow[I, A], right Workflow[I, B]) JoinResult[I, A, B]

+ func (j JoinResult[I, A, B]) Then[O any](step func(context.Context, A, B) (O, error)) Workflow[I, O]

+ type RetryPolicy struct

+ BaseDelay time.Duration

+ MaxAttempts int

+ MaxDelay time.Duration

+ type RuntimeOptions struct

+ Concurrency int

+ HeartbeatInterval time.Duration

+ LeaseTTL time.Duration

+ OnSchedulerError func(error)

+ PollInterval time.Duration

+ type Workflow struct

+ func (w Workflow[I, O]) Run(ctx context.Context, input I) (O, error)

+ func (w Workflow[I, O]) Then[N any](step func(context.Context, O) (N, error)) Workflow[I, N]