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

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

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

/// A FIFO group in the advisory lock form.
struct OrderedByLock {
    id: i64,
}

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

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

fn main() {}