Skip to main content

Module model

Module model 

Source

Structs§

BackendCapabilities
Storage backend feature and guarantee declaration.
BackendSemanticCapabilities
Detailed semantic strength behind the compatibility-preserving feature flags.
ConsumerGroupStatus
Status and offset information for a consumer group registered on a stream log.
Event
Represents an immutable event stored within a durable stream log.
Job
Primary job entity representing a unit of work stored in a storage backend.
JobExecution
Runtime execution claim tying a job, durable attempt, worker, and lease together.
JobListItem
Lightweight job summary model returned when listing jobs in Admin UI or APIs.
NewEvent
Input model for publishing a new event into a stream log.
NewJob
Specification for enqueueing a new job into a storage backend.
Queue
Named queue definition plus its execution policy.
QueueConfig
Configuration options for a job queue.
Worker
Worker identity used for leases, attempts, and execution ownership.

Enums§

BackpressureCapability
Backpressure behavior exposed by a storage backend.
ConsumerGroupCapability
Coordination provided for consumers sharing one consumer-group name.
DurabilityCapability
Persistence strength provided by a backend.
JobLifecycleState
Canonical logical job lifecycle state.
JobStatus
Stored job status values.
NotificationCapability
Delivery behavior of backend wake-up notifications.
OrderingCapability
Ordering strength exposed by a storage backend.
QueueOrdering
Per-queue job execution ordering policy.
RetentionCapability
Retention behavior exposed by a backend.
TransactionalEnqueueCapability
Transaction boundary in which enqueue can be atomic with application state.

Traits§

JobProcessor
Trait-based job processor interface for structured background workers.

Type Aliases§

JobHandler
Asynchronous job handler closure type alias.