boson-backend-sql-common

Shared SQL QueueBackend implementation for SQLite and PostgreSQL.

Role

• SqlQueueBackend — connect, schema bootstrap, and trait implementation
• SqlDialect / SqlPool — engine selection
• Row mapping helpers in row.rs
• Used by boson-backend-sqlite and boson-backend-postgres

Compose

use std::sync::Arc;

use boson::{Boson, SqliteQueueBackend};

let backend = Arc::new(SqliteQueueBackend::new("boson.db").await?);
let boson = Boson::builder()
    .queue_backend(backend)
    .execution_context_factory(your_factory)
    .build()?;

Related crates

• boson-backend-sqlite — thin SQLite wrapper
• boson-backend-postgres — thin PostgreSQL wrapper
• boson-core — QueueBackend trait definition