distributed 2.3.5

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

#![cfg(feature = "postgres")]

#[path = "../persistent_repository_conformance/mod.rs"]
mod conformance;
#[path = "../support/postgres.rs"]
mod postgres;

use distributed::PostgresRepository;

async fn repository() -> Option<PostgresRepository> {
    let schema = postgres::PostgresTestSchema::create_from_env(
        "pg_conformance",
        "skipping Postgres conformance test",
    )
    .await?;
    let repo = schema.repository().await;
    repo.bootstrap_table_schema_for_dev(&conformance::read_models::conformance_table_registry())
        .await
        .expect("read-model conformance table should bootstrap");
    Some(repo)
}

conformance::repository_conformance_tests!();