evento-sql

SQL storage backend for the evento event sourcing toolkit: Sql<DB> wraps a sqlx pool and implements the Executor trait for SQLite, MySQL, and PostgreSQL (feature flags sqlite / mysql / postgres).

Most applications depend on the evento facade, which also re-exports the schema migrations:

[dependencies]
evento = { version = "2.0.0-alpha.27", features = ["sqlite"] }

Wire a pool into an executor (run the evento-sql-migrator migrations first):

# #[cfg(feature = "sqlite")]
# async fn run() -> anyhow::Result<()> {
let pool = sqlx::sqlite::SqlitePoolOptions::new()
    .connect("sqlite:events.db")
    .await?;
let executor: evento_sql::Sqlite = pool.into();
// via the facade: let executor: evento::Sqlite = pool.into();
# let _ = executor;
# Ok(())
# }

write stamps events with the database server clock and subscriptions gate on a stability watermark, so multi-process writers stay safe; see the crate docs for the ordering model.

Learn more

• API documentation
• Workspace README
• Runnable example: bank-axum-sqlite