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

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")];

/// An extend of the service's own in the row lock form.
struct ExtendedRowLock {
    id: i64,
}

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

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

/// An extend of the service's own in the advisory lock form.
struct ExtendedLock {
    id: i64,
}

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

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

fn main() {}