reliar-store-postgres 0.9.0

PostgreSQL provider for the Reliar transactional outbox and inbox: migrations, migrate(), enqueue and the SKIP LOCKED claim.
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

//! [`InboxRow`] — the full column set `find` and `list_dead` share. Belongs to the concern layer:
//! a row struct, never rehydration policy, which stays in `inbox_store::build_record`.

/// A row's full column set, named via `query_as!` (never `FromRow`) so `find` and
/// [`super::inbox_store_dead_letters::list_dead`] share one shape — every `InboxDeadLetters`
/// listing reads the same columns `find` does.
pub(in crate::inbox) struct InboxRow {
    pub(in crate::inbox) id: uuid::Uuid,

    pub(in crate::inbox) scope: String,

    pub(in crate::inbox) message_id: uuid::Uuid,

    pub(in crate::inbox) message_type: String,

    pub(in crate::inbox) message_version: i32,

    pub(in crate::inbox) conversation_id: uuid::Uuid,

    pub(in crate::inbox) correlation_id: Option<String>,

    pub(in crate::inbox) causation_id: Option<uuid::Uuid>,

    pub(in crate::inbox) received_at: time::OffsetDateTime,

    pub(in crate::inbox) updated_at: time::OffsetDateTime,

    pub(in crate::inbox) completed_at: Option<time::OffsetDateTime>,

    pub(in crate::inbox) dead_at: Option<time::OffsetDateTime>,

    pub(in crate::inbox) attempts: i32,

    pub(in crate::inbox) last_error: Option<String>,
}