ruststream-sqlx 0.7.0

SQL databases for the RustStream messaging framework through sqlx: a transactional outbox over any RustStream broker and task queues in Postgres, MySQL/MariaDB and SQLite tables.
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
56

//! The transactional outbox as a service runs it: an app on `MemoryBroker` whose publishes are
//! recorded in a real database's outbox table, whose deliveries take and settle their records, and
//! whose startup republishes what no consumer processed.
//!
//! A test of tracking runs only with `RUSTSTREAM_SQLX_OUTBOX=on`, and the test of a build that
//! leaves the outbox off runs only without it: a test build reads the switch once per process, so
//! the suite cannot turn it on or off for itself.

#![cfg(all(
    feature = "outbox",
    feature = "inbox",
    feature = "json",
    feature = "testing",
    feature = "postgres",
    feature = "mysql",
    feature = "sqlite"
))]

use std::env;

#[path = "../live/mod.rs"]
mod live;

#[path = "../threads/pool.rs"]
mod pool;
#[path = "../threads/probe.rs"]
mod probe;

mod manual;
mod records;
mod registry;
mod stand;
mod threads;
mod tracked;

/// The variable that turns the outbox on in a test build.
const SWITCH: &str = "RUSTSTREAM_SQLX_OUTBOX";

/// Whether the outbox tracks in this process, or `false` to skip a test of tracking.
///
/// # Panics
///
/// Panics when the switch is off and [`live::REQUIRE_LIVE`] is set: a job that asked for the live
/// suites would pass the outbox's without running them.
fn tracking_on() -> bool {
    if env::var(SWITCH).as_deref() == Ok("on") {
        return true;
    }
    assert!(
        env::var(live::REQUIRE_LIVE).map_or(true, |value| value.is_empty()),
        "{} is set, so the outbox suite must run, but {SWITCH} is not `on`",
        live::REQUIRE_LIVE,
    );
    eprintln!("{SWITCH} is not `on`; skipping the outbox suite");
    false
}