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

use ruststream_sqlx::dialect::Column;
use ruststream_sqlx::spec::{HeaderFields, Payload};
use ruststream_sqlx::{InboxSpec, InboxTable};

/// A message assembled from header fields, with a payload.
struct AssembledWithPayload {
    id: i64,
}

impl InboxTable for AssembledWithPayload {
    type Id = i64;
    type Table = InboxSpec<(HeaderFields, Payload)>;
    const TABLE: Self::Table = InboxSpec::new("orders", Column::new("id"))
        .header_fields()
        .payload(Column::new("body"));

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

fn main() {}