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
57
58
59
60

use chrono::{DateTime, Utc};
use ruststream_sqlx::dialect::{Column, KeyPart};
use ruststream_sqlx::spec::{Advisory, Attempt, Lease, Payload, own};
use ruststream_sqlx::{InboxSpec, InboxTable};

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

/// Two forms: the lease and the advisory lock.
struct TwoForms {
    id: i64,
}

impl InboxTable for TwoForms {
    type Id = i64;
    type Table = InboxSpec<(Lease<DateTime<Utc>>, Advisory)>;
    const TABLE: Self::Table = InboxSpec::new("jobs", Column::new("id"))
        .lease(Column::new("locked_until"))
        .advisory(KEY);

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

/// `attempt` set twice.
struct TwoAttempts {
    id: i64,
}

impl InboxTable for TwoAttempts {
    type Id = i64;
    type Table = InboxSpec<(Attempt, Payload, Attempt)>;
    const TABLE: Self::Table = InboxSpec::new("jobs", Column::new("id"))
        .attempt(Column::new("attempt"))
        .payload(Column::new("payload"))
        .attempt(Column::new("tries"));

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

/// The service's own `Ack` set twice.
struct TwoAcks {
    id: i64,
}

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

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

fn main() {}