driver

package

Go to main page

Versions in this module

v0

v0.0.13

Oct 12, 2026

v0.0.12

Oct 11, 2026

v0.0.11

Sep 24, 2026

v0.0.10

Sep 24, 2026

Changes in this version

+ var ErrAlreadyExists = errors.New("azync: id already exists")

type EnqueueParams

+ CoalesceKey string

v0.0.9

Sep 24, 2026

v0.0.8

Jul 31, 2026

Changes in this version

+ type Change struct

+ At time.Time

+ Bulk bool

+ Count int

+ DAGID uuid.UUID

+ Entity ChangeEntity

+ ID uuid.UUID

+ Kind string

+ Source Source

+ State string

+ TaskKey string

+ type ChangeEntity string

+ const ChangeDAG

+ const ChangeEvent

+ const ChangeJob

+ const ChangeReset

+ type ChangeNotifier interface

+ Changes func(ctx context.Context) (<-chan Change, error)

v0.0.7

Jul 28, 2026

Changes in this version

type DAGStore

+ DAGDeps func(ctx context.Context, id uuid.UUID) ([]DAGDep, error)

+ DAGNameStateCounts func(ctx context.Context) (map[string]map[DAGState]int64, error)

+ DAGTaskCounts func(ctx context.Context, ids []uuid.UUID) (map[uuid.UUID]map[JobState]int64, error)

type Job

+ StartedAt time.Time

v0.0.6

Jul 27, 2026

Changes in this version

+ type DAGSignalParams struct

+ DAGID uuid.UUID

+ MessageID string

+ Name string

+ Payload json.RawMessage

type DAGState

+ const DAGPaused

type DAGStore

+ DeliverBufferedSignals func(ctx context.Context) (int64, error)

+ FindDAGByKey func(ctx context.Context, name, idempotencyKey string) (uuid.UUID, error)

+ PauseDAG func(ctx context.Context, id uuid.UUID, reason string) error

type DAGTask

+ Deadline time.Duration

type Job

+ DeadlineAt time.Time

+ SnoozeBudget time.Duration

type JobState

+ const StateSkipped

type Store

+ RunNow func(ctx context.Context, source Source, id uuid.UUID) error

+ Skip func(ctx context.Context, id, leaseToken uuid.UUID, reason string) error

+ type TaskResult struct

+ Result json.RawMessage

+ Skipped bool

type UnimplementedStore

+ func (UnimplementedStore) RunNow(context.Context, Source, uuid.UUID) error

+ func (UnimplementedStore) Skip(context.Context, uuid.UUID, uuid.UUID, string) error

v0.0.5

Jul 26, 2026

v0.0.4

Jul 26, 2026

Changes in this version

type Depths

+ OldestPendingAge time.Duration

+ type LeadershipLease interface

+ Release func()

+ Valid func(ctx context.Context) bool

+ type LeaseElector interface

+ AcquireLeadershipLease func(ctx context.Context, name string) (lease LeadershipLease, acquired bool, err error)

+ type StalledWorkflow struct

+ ID uuid.UUID

+ Name string

type Store

+ DeleteSubscriber func(ctx context.Context, name, eventType string) (int64, error)

type UnimplementedStore

+ func (UnimplementedStore) DeleteSubscriber(context.Context, string, string) (int64, error)

type WorkflowStore

+ ListStalledWorkflows func(ctx context.Context, olderThan time.Duration, limit int) ([]StalledWorkflow, error)

v0.0.3

Jul 26, 2026

v0.0.2

Jul 25, 2026

v0.0.1

Jul 25, 2026

Changes in this version

+ const KindSignal

+ const KindSleep

+ const TaskKeyCompensationPrefix

+ var ErrNotSupported = errors.New("azync: capability not supported by driver")

+ func IsNotFound(err error) bool

+ func NewNotFound(op string) error

+ type AttemptError struct

+ At time.Time

+ Attempt int

+ Error string

+ Trace string

+ type Config struct

+ Logger *slog.Logger

+ MigrationsTable string

+ NotifyChannel string

+ PollOnly bool

+ Schema string

+ type DAGDep struct

+ DependsOnKey string

+ TaskKey string

+ type DAGFailure struct

+ DAGID uuid.UUID

+ DeadTasks []string

+ Policy OnFailurePolicy

+ type DAGFilter struct

+ Name string

+ State DAGState

+ type DAGParams struct

+ Deps []DAGDep

+ ID uuid.UUID

+ IdempotencyKey string

+ Meta map[string]string

+ Name string

+ OnFailure OnFailurePolicy

+ SpanID string

+ Tasks []DAGTask

+ TraceFlags int16

+ TraceID string

+ type DAGState string

+ const DAGCancelled

+ const DAGCompensating

+ const DAGFailed

+ const DAGRunning

+ const DAGSucceeded

+ const DAGSuspended

+ type DAGStore interface

+ AckTaskResult func(ctx context.Context, id, leaseToken uuid.UUID, result json.RawMessage) error

+ ApplyFailurePolicy func(ctx context.Context) ([]DAGFailure, error)

+ CancelDAG func(ctx context.Context, id uuid.UUID) error

+ CompensateDAG func(ctx context.Context, id uuid.UUID) error

+ CompleteDAGs func(ctx context.Context) (int64, error)

+ CompleteDueSleeps func(ctx context.Context) (int64, error)

+ CreateDAG func(ctx context.Context, p DAGParams) (inserted bool, existingID uuid.UUID, err error)

+ DAGTasks func(ctx context.Context, id uuid.UUID) ([]Job, error)

+ GetDAG func(ctx context.Context, id uuid.UUID) (*DAGView, error)

+ ListDAGs func(ctx context.Context, filter DAGFilter, offset, limit int) ([]DAGView, int64, error)

+ PromoteUnblocked func(ctx context.Context) (int64, error)

+ RetryDAG func(ctx context.Context, id uuid.UUID) error

+ Signal func(ctx context.Context, dagID uuid.UUID, name string, payload json.RawMessage) (matched int64, err error)

+ TaskResults func(ctx context.Context, dagID uuid.UUID, keys []string) (map[string]json.RawMessage, error)

+ VacuumDAGs func(ctx context.Context, retention time.Duration) (int64, error)

+ type DAGTask struct

+ CompensationKind string

+ CompensationPayload json.RawMessage

+ IgnoreDeadDeps bool

+ Key string

+ Kind string

+ MaxAttempts int

+ Payload json.RawMessage

+ SignalName string

+ SleepFor time.Duration

+ type DAGView struct

+ CompletedAt time.Time

+ CreatedAt time.Time

+ FailureReason string

+ ID uuid.UUID

+ IdempotencyKey string

+ Meta map[string]string

+ Name string

+ OnFailure OnFailurePolicy

+ State DAGState

+ TraceID string

+ UpdatedAt time.Time

+ type DailyCount struct

+ Date time.Time

+ Enqueued int64

+ Failed int64

+ Processed int64

+ Reaped int64

+ type Depths struct

+ Active int64

+ Dead int64

+ Paused int64

+ Pending int64

+ Scheduled int64

+ Succeeded int64

+ type DequeueParams struct

+ DefaultMaxAttempts int

+ Kind string

+ Lease time.Duration

+ Limit int

+ OverrideDefault bool

+ type EnqueueParams struct

+ Delay time.Duration

+ ID uuid.UUID

+ IdempotencyKey string

+ IdempotencyTTL time.Duration

+ Kind string

+ MaxAttempts int

+ MaxAttemptsExplicit bool

+ Meta map[string]string

+ Payload json.RawMessage

+ RunAt time.Time

+ SpanID string

+ TraceFlags int16

+ TraceID string

+ type EventAdminRow struct

+ AggregateID string

+ AggregateType string

+ Deliveries int64

+ DispatchedAt time.Time

+ ID uuid.UUID

+ Meta map[string]string

+ OccurredAt time.Time

+ Payload json.RawMessage

+ SpanID string

+ TenantID uuid.UUID

+ TraceFlags int16

+ TraceID string

+ Type string

+ Version int64

+ type EventFilter struct

+ Since time.Time

+ TenantID uuid.UUID

+ Type string

+ Undispatched *bool

+ Until time.Time

+ type EventRecord struct

+ AggregateID string

+ AggregateType string

+ ID uuid.UUID

+ Meta map[string]string

+ OccurredAt time.Time

+ Payload json.RawMessage

+ SpanID string

+ TenantID uuid.UUID

+ TraceFlags int16

+ TraceID string

+ Type string

+ Version int64

+ type HistoryEvent struct

+ CreatedAt time.Time

+ Payload json.RawMessage

+ Seq int64

+ Type string

+ WorkflowID uuid.UUID

+ type Job struct

+ Attempt int

+ CompensationKind string

+ CompletedAt time.Time

+ DAGID uuid.UUID

+ EnqueuedAt time.Time

+ Event *EventRecord

+ EventID uuid.UUID

+ FailedAt time.Time

+ ID uuid.UUID

+ IgnoreDeadDeps bool

+ Kind string

+ LastError string

+ LeaseToken uuid.UUID

+ LeaseUntil time.Time

+ MaxAttempts int

+ Meta map[string]string

+ Payload json.RawMessage

+ ReapCount int

+ Replay bool

+ Result json.RawMessage

+ RunAt time.Time

+ RunID uuid.UUID

+ SignalName string

+ Source Source

+ SpanID string

+ State JobState

+ TaskKey string

+ TraceFlags int16

+ TraceID string

+ type JobFilter struct

+ Kind string

+ State JobState

+ type JobState string

+ const StateActive

+ const StateBlocked

+ const StateCancelled

+ const StateDead

+ const StatePaused

+ const StatePending

+ const StateScheduled

+ const StateSucceeded

+ const StateUncertain

+ const StateWaiting

+ type LeaderElector interface

+ AcquireLeadership func(ctx context.Context, name string) (release func(), acquired bool, err error)

+ type Migrator interface

+ Migrate func(ctx context.Context) error

+ type Notifier interface

+ Wake func(ctx context.Context) (<-chan Wake, error)

+ type NukeReport struct

+ Jobs int64

+ Keys int64

+ Stats int64

+ type OnFailurePolicy string

+ const OnFailureCancel

+ const OnFailureSuspend

+ type Opener func(dsn string, cfg Config) (Store, error)

+ type OperationState string

+ const OperationActive

+ const OperationCancelled

+ const OperationCompleted

+ const OperationFailed

+ const OperationRetryWait

+ const OperationScheduled

+ const OperationUncertain

+ type OpsStats struct

+ Subscribers int64

+ Total24h int64

+ Types24h int64

+ Undispatched int64

+ type PublishParams struct

+ AggregateID string

+ AggregateType string

+ ID uuid.UUID

+ Meta map[string]string

+ OccurredAt time.Time

+ Payload json.RawMessage

+ SpanID string

+ TenantID uuid.UUID

+ TraceFlags int16

+ TraceID string

+ Type string

+ Version int64

+ type ReplayFilter struct

+ EventID uuid.UUID

+ EventType string

+ Limit int

+ Since time.Time

+ Subscriber string

+ Until time.Time

+ type ScheduleOperationParams struct

+ ExecutionKey string

+ Kind string

+ MaxAttempts int

+ Meta map[string]string

+ Payload json.RawMessage

+ RunAt time.Time

+ WorkflowID uuid.UUID

+ type SignalParams struct

+ MessageID string

+ Name string

+ Payload json.RawMessage

+ WorkflowID uuid.UUID

+ type Source string

+ const SourceDAG

+ const SourceEvent

+ const SourceQueue

+ const SourceWorkflow

+ type Store interface

+ Ack func(ctx context.Context, id, leaseToken uuid.UUID) error

+ AllDaily func(ctx context.Context, source Source) ([]DailyCount, error)

+ ArchiveJob func(ctx context.Context, source Source, id uuid.UUID) error

+ Close func(ctx context.Context) error

+ Dead func(ctx context.Context, id, leaseToken uuid.UUID, lastError string) error

+ DeleteAll func(ctx context.Context, source Source, kind string, state JobState) (int64, error)

+ DeleteJob func(ctx context.Context, source Source, id uuid.UUID, state JobState) error

+ DequeueBatch func(ctx context.Context, source Source, p DequeueParams) ([]Job, error)

+ Enqueue func(ctx context.Context, p EnqueueParams) (inserted bool, err error)

+ ExtendLease func(ctx context.Context, id, leaseToken uuid.UUID, lease time.Duration) error

+ GetEvent func(ctx context.Context, id uuid.UUID) (*EventAdminRow, error)

+ GetJob func(ctx context.Context, source Source, id uuid.UUID) (*Job, error)

+ JobAttempts func(ctx context.Context, source Source, id uuid.UUID) ([]AttemptError, error)

+ KindDepths func(ctx context.Context, source Source) (map[string]Depths, error)

+ ListEvents func(ctx context.Context, filter EventFilter, offset, limit int) ([]EventAdminRow, int64, error)

+ ListJobs func(ctx context.Context, source Source, filter JobFilter, offset, limit int) ([]Job, int64, error)

+ ListKinds func(ctx context.Context, source Source) ([]string, error)

+ ListSubscriberViews func(ctx context.Context, eventType string) ([]SubscriberView, error)

+ NukeAll func(ctx context.Context, source Source) (NukeReport, error)

+ OpsStats func(ctx context.Context) (OpsStats, error)

+ PauseJob func(ctx context.Context, source Source, id uuid.UUID) error

+ PromoteDue func(ctx context.Context, source Source, kinds []string) (int64, error)

+ Publish func(ctx context.Context, p PublishParams) (delivered int, err error)

+ ReapExpired func(ctx context.Context, source Source, kinds []string, maxReaps int) (reaped, killed int64, err error)

+ RegisterSubscriber func(ctx context.Context, sub Subscriber) error

+ Release func(ctx context.Context, id, leaseToken uuid.UUID) error

+ Replay func(ctx context.Context, filter ReplayFilter) (int64, error)

+ Reschedule func(ctx context.Context, id, leaseToken uuid.UUID, delay time.Duration, ...) error

+ ResumeJob func(ctx context.Context, source Source, id uuid.UUID) error

+ Retain func(ctx context.Context, before time.Time, limit int) (int64, error)

+ RetryAllDead func(ctx context.Context, source Source, kind string) (int64, error)

+ RetryJob func(ctx context.Context, source Source, id uuid.UUID) error

+ Snooze func(ctx context.Context, id, leaseToken uuid.UUID, delay time.Duration) error

+ Stats func(ctx context.Context, source Source, kind string) (Depths, []DailyCount, error)

+ Subscribers func(ctx context.Context, eventType string) ([]Subscriber, error)

+ VacuumCompleted func(ctx context.Context, source Source, retention time.Duration) (int64, error)

+ VacuumDead func(ctx context.Context, source Source, kind string, olderThan time.Duration) (int64, error)

+ VacuumIdempotency func(ctx context.Context, source Source) (int64, error)

+ VacuumStats func(ctx context.Context, source Source, retention time.Duration) (int64, error)

+ type Subscriber struct

+ EventType string

+ MaxAttempts int

+ Name string

+ type SubscriberView struct

+ CreatedAt time.Time

+ EventType string

+ MaxAttempts int

+ Subscriber string

+ UpdatedAt time.Time

+ type TxDAGStore interface

+ CreateDAGTx func(ctx context.Context, tx TTx, p DAGParams) (inserted bool, existingID uuid.UUID, err error)

+ type TxStore interface

+ EnqueueTx func(ctx context.Context, tx TTx, p EnqueueParams) (inserted bool, err error)

+ PublishTx func(ctx context.Context, tx TTx, p PublishParams) (delivered int, err error)

+ type UncertainDecision string

+ const UncertainComplete

+ const UncertainFail

+ const UncertainRetry

+ type UnimplementedStore struct

+ func (UnimplementedStore) Ack(context.Context, uuid.UUID, uuid.UUID) error

+ func (UnimplementedStore) AllDaily(context.Context, Source) ([]DailyCount, error)

+ func (UnimplementedStore) ArchiveJob(context.Context, Source, uuid.UUID) error

+ func (UnimplementedStore) Close(context.Context) error

+ func (UnimplementedStore) Dead(context.Context, uuid.UUID, uuid.UUID, string) error

+ func (UnimplementedStore) DeleteAll(context.Context, Source, string, JobState) (int64, error)

+ func (UnimplementedStore) DeleteJob(context.Context, Source, uuid.UUID, JobState) error

+ func (UnimplementedStore) DequeueBatch(context.Context, Source, DequeueParams) ([]Job, error)

+ func (UnimplementedStore) Enqueue(context.Context, EnqueueParams) (bool, error)

+ func (UnimplementedStore) ExtendLease(context.Context, uuid.UUID, uuid.UUID, time.Duration) error

+ func (UnimplementedStore) GetEvent(context.Context, uuid.UUID) (*EventAdminRow, error)

+ func (UnimplementedStore) GetJob(context.Context, Source, uuid.UUID) (*Job, error)

+ func (UnimplementedStore) JobAttempts(context.Context, Source, uuid.UUID) ([]AttemptError, error)

+ func (UnimplementedStore) KindDepths(context.Context, Source) (map[string]Depths, error)

+ func (UnimplementedStore) ListEvents(context.Context, EventFilter, int, int) ([]EventAdminRow, int64, error)

+ func (UnimplementedStore) ListJobs(context.Context, Source, JobFilter, int, int) ([]Job, int64, error)

+ func (UnimplementedStore) ListKinds(context.Context, Source) ([]string, error)

+ func (UnimplementedStore) ListSubscriberViews(context.Context, string) ([]SubscriberView, error)

+ func (UnimplementedStore) NukeAll(context.Context, Source) (NukeReport, error)

+ func (UnimplementedStore) OpsStats(context.Context) (OpsStats, error)

+ func (UnimplementedStore) PauseJob(context.Context, Source, uuid.UUID) error

+ func (UnimplementedStore) PromoteDue(context.Context, Source, []string) (int64, error)

+ func (UnimplementedStore) Publish(context.Context, PublishParams) (int, error)

+ func (UnimplementedStore) ReapExpired(context.Context, Source, []string, int) (int64, int64, error)

+ func (UnimplementedStore) RegisterSubscriber(context.Context, Subscriber) error

+ func (UnimplementedStore) Release(context.Context, uuid.UUID, uuid.UUID) error

+ func (UnimplementedStore) Replay(context.Context, ReplayFilter) (int64, error)

+ func (UnimplementedStore) Reschedule(context.Context, uuid.UUID, uuid.UUID, time.Duration, string) error

+ func (UnimplementedStore) ResumeJob(context.Context, Source, uuid.UUID) error

+ func (UnimplementedStore) Retain(context.Context, time.Time, int) (int64, error)

+ func (UnimplementedStore) RetryAllDead(context.Context, Source, string) (int64, error)

+ func (UnimplementedStore) RetryJob(context.Context, Source, uuid.UUID) error

+ func (UnimplementedStore) Snooze(context.Context, uuid.UUID, uuid.UUID, time.Duration) error

+ func (UnimplementedStore) Stats(context.Context, Source, string) (Depths, []DailyCount, error)

+ func (UnimplementedStore) Subscribers(context.Context, string) ([]Subscriber, error)

+ func (UnimplementedStore) VacuumCompleted(context.Context, Source, time.Duration) (int64, error)

+ func (UnimplementedStore) VacuumDead(context.Context, Source, string, time.Duration) (int64, error)

+ func (UnimplementedStore) VacuumIdempotency(context.Context, Source) (int64, error)

+ func (UnimplementedStore) VacuumStats(context.Context, Source, time.Duration) (int64, error)

+ type Wake struct

+ Kind string

+ Source Source

+ type WorkflowExecutionView struct

+ BusinessIdempotencyKey string

+ CompletedAt time.Time

+ CreatedAt time.Time

+ FailureReason string

+ ID uuid.UUID

+ Input json.RawMessage

+ Meta map[string]string

+ Name string

+ Result json.RawMessage

+ State WorkflowState

+ TaskQueue string

+ UpdatedAt time.Time

+ Version string

+ type WorkflowStartParams struct

+ BusinessIdempotencyKey string

+ ID uuid.UUID

+ Input json.RawMessage

+ Meta map[string]string

+ Name string

+ TaskQueue string

+ Version string

+ type WorkflowState string

+ const WorkflowCancelled

+ const WorkflowFailed

+ const WorkflowRunning

+ const WorkflowSucceeded

+ const WorkflowSuspended

+ type WorkflowStore interface

+ AppendHistory func(ctx context.Context, workflowID uuid.UUID, typ string, payload json.RawMessage) (seq int64, err error)

+ CancelWorkflowExecution func(ctx context.Context, id uuid.UUID) error

+ CompleteWorkflow func(ctx context.Context, id uuid.UUID, result json.RawMessage) error

+ FailWorkflow func(ctx context.Context, id uuid.UUID, reason string) error

+ GetWorkflowExecution func(ctx context.Context, id uuid.UUID) (WorkflowExecutionView, error)

+ ListHistory func(ctx context.Context, workflowID uuid.UUID) ([]HistoryEvent, error)

+ MarkUncertain func(ctx context.Context, operationJobID, leaseToken uuid.UUID, reason string) error

+ ResolveUncertain func(ctx context.Context, operationJobID uuid.UUID, decision string, ...) (workflowID uuid.UUID, workflowName string, err error)

+ ResumeWorkflow func(ctx context.Context, id uuid.UUID) error

+ ScheduleOperation func(ctx context.Context, p ScheduleOperationParams) (jobID uuid.UUID, err error)

+ ScheduleTask func(ctx context.Context, workflowID uuid.UUID, kind string, runAt time.Time) error

+ SignalWorkflow func(ctx context.Context, p SignalParams) (inserted bool, err error)

+ StartWorkflow func(ctx context.Context, p WorkflowStartParams) (inserted bool, existingID uuid.UUID, err error)

+ SuspendWorkflow func(ctx context.Context, id uuid.UUID, reason string) error

+ VacuumWorkflows func(ctx context.Context, retention time.Duration) (int64, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL