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

use ruststream_sqlx::dialect::{Column, KeyPart};
use ruststream_sqlx::spec::{Advisory, own};
use ruststream_sqlx::{InboxSpec, InboxTable};

const KEY: &[KeyPart<'static>] = &[KeyPart::Literal("orders-"), KeyPart::Column("id")];

/// A lock of the service's own without its unlock.
struct LockedOnly {
    id: i64,
}

impl InboxTable for LockedOnly {
    type Id = i64;
    type Table = InboxSpec<(Advisory, own::Lock)>;
    const TABLE: Self::Table = InboxSpec::new("orders", Column::new("id"))
        .advisory(KEY)
        .own::<own::Lock>();

    fn id(&self) -> &i64 {
        &self.id
    }
}

/// A lock and an unlock of the service's own in the row lock form.
struct LockedRows {
    id: i64,
}

impl InboxTable for LockedRows {
    type Id = i64;
    type Table = InboxSpec<(own::Lock, own::Unlock)>;
    const TABLE: Self::Table = InboxSpec::new("orders", Column::new("id"))
        .own::<own::Lock>()
        .own::<own::Unlock>();

    fn id(&self) -> &i64 {
        &self.id
    }
}

fn main() {}