Struct Boson 

pub struct Boson { /* private fields */ }

Boson work engine — enqueue, admin reads, and worker orchestration.

Implementations

impl Boson

pub fn from_parts( backend: Arc<dyn QueueBackend>, registry: Arc<TaskRegistry>, worker: WorkerSettings, ) -> Self

Construct from injected parts (used by builder and tests).

pub fn from_parts_with_idempotency( backend: Arc<dyn QueueBackend>, registry: Arc<TaskRegistry>, worker: WorkerSettings, idempotency_mode: IdempotencyMode, ) -> Self

Construct with an explicit default idempotency mode.

pub const fn idempotency_mode(&self) -> IdempotencyMode

Runtime default idempotency mode (builder / task override may change per enqueue).

pub const fn worker_settings(&self) -> &WorkerSettings

Worker settings this instance was built with.

pub fn runtime_label(&self) -> &str

Telemetry/runtime label (topology slug or embedded).

pub fn queue_backend(&self) -> Arc<dyn QueueBackend>

Queue backend handle.

pub fn registry(&self) -> &TaskRegistry

Task registry.

pub async fn resolve_task_config(&self, task_name: &str) -> Result<TaskConfig>

Resolve task config from backend or registry defaults.

Precedence: persisted backend config, else descriptor policy defaults, then runtime idempotency fallback when the mode is unset.

Errors

Returns an error if the task is unknown or the backend fails.

pub async fn resolve_priority_pool( &self, task_name: &str, ) -> Result<(i32, String)>

Resolve priority and pool for enqueue.

Errors

Returns an error if the task is unknown or the backend fails.

pub async fn enqueue( &self, task_name: &str, actor_json: Value, params_json: Value, idempotency_key: Option<String>, ) -> Result<String>

Enqueue a job.

Priority and pool come from persisted TaskConfig merged with TaskDescriptor defaults. Optional idempotency_key deduplicates non-terminal jobs. Rate limits may return BosonError::RateLimited.

Errors

Returns an error if the task is unknown, rate limits apply, or the backend fails.

pub async fn get_job(&self, job_id: &str) -> Result<Option<Job>>

Get a job by id.

Errors

Returns an error if the backend fails.

pub async fn list_jobs( &self, status_filter: Option<JobStatus>, offset: usize, limit: usize, ) -> Result<Vec<Job>>

List jobs with optional status filter.

Errors

Returns an error if the backend fails.

pub async fn cancel_job(&self, job_id: &str) -> Result<()>

Cancel a job if still active.

Errors

Returns an error if the job is not found or the backend fails.

pub async fn get_task_config(&self, task_name: &str) -> Result<TaskConfig>

Get or default task config.

Errors

Returns an error if the task is unknown or the backend fails.

pub async fn upsert_task_config(&self, config: TaskConfig) -> Result<()>

Upsert task config.

Errors

Returns an error if the backend fails.

pub async fn list_runs( &self, job_id_filter: Option<&str>, offset: usize, limit: usize, ) -> Result<Vec<Run>>

List runs.

Errors

Returns an error if the backend fails.

pub async fn get_run(&self, run_id: &str) -> Result<Option<Run>>

Get run by id.

Errors

Returns an error if the backend fails.

pub async fn count_jobs(&self, status_filter: Option<JobStatus>) -> Result<u64>

Count jobs.

Errors

Returns an error if the backend fails.

pub async fn count_runs(&self, job_id_filter: Option<&str>) -> Result<u64>

Count runs.

Errors

Returns an error if the backend fails.

pub async fn count_runs_since(&self, since: DateTime<Utc>) -> Result<u64>

Count runs since timestamp.

Errors

Returns an error if the backend fails.

pub async fn count_jobs_for_task( &self, task_name: &str, status: Option<JobStatus>, ) -> Result<u64>

Count jobs for one task.

Errors

Returns an error if the backend fails.

pub async fn task_run_stats(&self, task_name: &str) -> Result<TaskRunStats>

Aggregate run stats for one task.

Errors

Returns an error if the backend fails.

impl Boson

pub fn builder() -> BosonBuilder

Create a new builder.

Trait Implementations

impl Clone for Boson

fn clone(&self) -> Boson

Returns a duplicate of the value.

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

Performs copy-assignment from source.