uf-boson 0.1.1

Public Boson facade — async work engine
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

//! Manual task registration without the `#[task]` macro.
//!
//! Run: `cargo run -p uf-boson --example minimal_enqueue --features mem`

use std::future::Future;
use std::pin::Pin;
use std::sync::Arc;

use boson::{
    Boson, ExecutionContext, JsonExecutionContextFactory, MemQueueBackend, TaskDescriptor,
    TaskRegistry,
};
use boson::prelude::Result as BosonResult;

fn echo_task(
    ctx: Box<dyn ExecutionContext>,
    _params: serde_json::Value,
) -> Pin<Box<dyn Future<Output = BosonResult<()>> + Send + 'static>> {
    Box::pin(async move {
        println!("task ran (actor={})", ctx.label());
        Ok(())
    })
}

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let mut registry = TaskRegistry::new();
    let desc: &'static TaskDescriptor =
        Box::leak(Box::new(TaskDescriptor::new("echo", echo_task)));
    registry.register(desc);

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

    let job_id = boson
        .enqueue(
            "echo",
            serde_json::json!({"System": {"operation": "demo"}}),
            serde_json::json!({}),
            None,
        )
        .await?;
    println!("enqueued job {job_id}");
    Ok(())
}