boson-runtime 0.1.1

Boson worker engine, builder, and enqueue orchestration
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

# boson-runtime

Worker runtime, builder, and enqueue orchestration.

Wire the worker (or enqueue-only host) process here once; task authors add handlers via
[`boson-macros`](https://docs.rs/boson-macros) without repeating boot steps.

Topology (embedded vs remote): see [`boson`](https://docs.rs/uf-boson)
[Getting started](https://docs.rs/uf-boson/latest/boson/index.html#getting-started).

## Role

- [`Boson`](src/boson.rs) / [`BosonBuilder`](src/builder.rs) — inject `QueueBackend`, identity factory, and `OpsLog`
- Background worker loop with lease-based claim and dispatch
- [`configure`](src/global.rs) / [`default`](src/global.rs) — process-wide default required for macro `send_with` (once at boot)
- [`TaskRegistry`](src/registry/mod.rs) — auto-discovery via `auto_registry` or manual registration in tests

## Boot with `#[task]` (Mode 1 — once per process)

```rust
use std::sync::Arc;

use boson_core::JsonExecutionContextFactory;
use boson_backend_mem::MemQueueBackend;
use boson_runtime::{configure, Boson};

let boson = Boson::builder()
    .queue_backend(Arc::new(MemQueueBackend::new()))
    .execution_context_factory(JsonExecutionContextFactory)
    .auto_registry()
    .build()?;
configure(boson);
```

Link every crate that defines `#[boson::task]` handlers into the **worker** binary. See
[`boson`](https://docs.rs/uf-boson) [Mode 1](https://docs.rs/uf-boson/latest/boson/index.html#mode-1--embedded-one-binary) /
[Mode 2](https://docs.rs/uf-boson/latest/boson/index.html#mode-2--remote-worker-two-binaries) and
[`task_macro`](https://github.com/unified-field-dev/boson/blob/main/boson/examples/task_macro.rs).

## Manual task registration (tests)

```rust
use boson_runtime::{TaskDescriptor, TaskRegistry};

let mut registry = TaskRegistry::new();
let desc: &'static TaskDescriptor = Box::leak(Box::new(TaskDescriptor::new("my_task", invoke_fn)));
registry.register(desc);
```

## Related crates

- [`boson`](https://docs.rs/uf-boson) — main crate and guided get-started
- [`boson-macros`](https://docs.rs/boson-macros) — task attribute macro
- [`boson-core`](https://docs.rs/boson-core) — `QueueBackend` trait, identity traits
- [`boson-telemetry`](https://docs.rs/boson-telemetry) — `OpsLog` adapters