Struct QueueRuntime 

pub struct QueueRuntime { /* private fields */ }

Top-level handle for the queue subsystem.

Implementations

impl QueueRuntime

pub fn new( storage: Storage, handlers: HandlerRegistry, router: Arc<dyn Router>, ) -> Self

Build a new runtime. host_id is freshly minted from a ULID so each process boot has its own identity in the process registry.

pub fn with_queues(self, queues: impl IntoIterator<Item = String>) -> Self

Declare the queues this worker is responsible for. Required — a worker that declares none fails at start. Names are de-duplicated, preserving first-seen order. Only supervisors for these queues are spawned, and the rebalancer only hands this pod slots for them.

pub fn with_worker_prefix(self, prefix: impl Into<String>) -> Self

Set this worker’s label prefix, shown in the monitoring view. The full label is composed as {prefix}-worker-{version}-{id} (k8s-style), so two workers sharing a prefix stay distinct via the trailing host_id. Accepts a &'static str const, so a service can bake its identity in at compile time: .with_worker_prefix("rates") → rates-worker-{ver}-{id}. Unset → the view falls back to host_id. See also with_worker_version / worker_prefix_from_env.

pub fn with_worker_version(self, version: impl Into<String>) -> Self

Set the build version segment of the composed worker label — typically the git commit the binary was built at. Omitted from the label when unset. Has no effect unless a prefix is also set (the label only exists with a prefix). See with_worker_prefix / worker_version_from_env.

pub fn with_worker_id(self, id: impl Into<String>) -> Self

Override the autogenerated id segment of the composed worker label — e.g. a k8s pod id from FORGE_WORKER_ID, so the label tracks pod identity. Unset → forge autogenerates a short id (4 hex) from the per-boot host_id. Has no effect unless a prefix is also set. See worker_id_from_env.

pub async fn ensure_queue( &self, name: &str, default_max_workers: i32, ) -> Result<()>

Ensure a queue config row exists. Safe to call before or after start; the supervisor for a newly-added queue is not spawned until the next start invocation.

pub async fn enqueue(&self, req: EnqueueRequest) -> Result<EnqueueOutcome>

Insert a job and wake the destination queue.

pub async fn start(self) -> Result<QueueHandle>

Spawn one supervisor per registered queue + reaper + cleanup

• cron. Returns a QueueHandle for orchestration.

Trait Implementations

impl Clone for QueueRuntime

fn clone(&self) -> QueueRuntime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QueueRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.