Struct WorkerSettings 

pub struct WorkerSettings {
    pub worker_id: String,
    pub lease_ttl_secs: i64,
    pub runtime_label: String,
    pub worker_pools: Option<Vec<String>>,
    pub worker_poll_interval_ms: u64,
    pub skip_run_persistence: bool,
}

Resolved worker settings for claim, lease, and telemetry labels.

Usually constructed by BosonBuilder via worker_id and lease_ttl_secs. Defaults: worker id from INSTANCE_ID / BOSON_WORKER_ID / boson-worker-1, lease TTL 0 (Mode 1 embedded, no distributed leases).

Getting started: Mode 2 — Remote worker.

Example — multiple worker processes (Mode 2)

Run one Boson instance per process against shared persistence (Postgres, SQLite path, Redis, or NATS — not MemQueueBackend, which is in-process only). Each process needs a unique worker_id and a positive lease_ttl_secs so QueueBackend::try_claim_run_lease prevents double execution:

use std::sync::Arc;

use boson_backend_postgres::PostgresQueueBackend;
use boson_core::JsonExecutionContextFactory;
use boson_runtime::Boson;

let url = std::env::var("DATABASE_URL")?;
let backend = PostgresQueueBackend::connect(&url).await?;
let _boson = Boson::builder()
    .queue_backend(Arc::new(backend))
    .execution_context_factory(JsonExecutionContextFactory)
    .worker_id("worker-a")
    .lease_ttl_secs(30)
    .auto_registry()
    .build()?;

Fields

worker_id: String

Worker identity for distributed lease claims.

lease_ttl_secs: i64

Run lease TTL in seconds; 0 disables lease coordination.

runtime_label: String

Telemetry/runtime label (topology slug or host-provided).

worker_pools: Option<Vec<String>>

When set, poll only these pools (shared-nothing fleet pinning).

worker_poll_interval_ms: u64

Delay between worker poll ticks in milliseconds (default 50).

skip_run_persistence: bool

Skip persisting run rows on the hot path (bench / throughput mode).

Implementations

impl WorkerSettings

pub fn embedded() -> WorkerSettings

Default embedded monolith: no leases, label embedded.

pub fn resolve( worker_id: Option<String>, lease_ttl_secs: Option<i64>, runtime_label: Option<String>, worker_pools: Option<Vec<String>>, worker_poll_interval_ms: Option<u64>, ) -> WorkerSettings

Build settings from optional builder overrides.

pub fn pools_to_poll(&self, discovered: Vec<String>) -> Vec<String>

Pools this worker should poll. When pinned, uses Self::worker_pools; otherwise backend discovery.

Trait Implementations

impl Clone for WorkerSettings

fn clone(&self) -> WorkerSettings

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerSettings

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

Formats the value using the given formatter.