Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

The Postgres implementation: the body is already in conversation_messages, so publishing is confirming what a row holds and the locator is the message id. Trivial on purpose — the point of this phase is the handling, not the storage.

Implementations

impl PostgresBackend

pub const NAME: &'static str = "postgres"

pub fn new(pool: PgPool) -> Self

pub fn with_team(self, team_id: Uuid) -> Self

A handle that may only read one team’s bodies.

pub fn with_faults(pool: PgPool, faults: Faults) -> Self

Only the tests construct this.

Trait Implementations

impl Clone for PostgresBackend

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl MessagingBackend for PostgresBackend

fn name(&self) -> &'static str

Name recorded on the conversation and the outbox row.

async fn publish(&self, envelope: Envelope) -> Published

Persist a body. Must be idempotent on publish_key: presented the same key twice, it returns the same locator rather than storing twice.

async fn fetch( &self, locator: &Locator, message_id: Uuid, ) -> BusResult<Option<String>>

Read a body back by locator, for history.

async fn retain(&self, _before: DateTime<Utc>) -> BusResult<u64>

Drop a body the retention policy no longer keeps. Returns how many were removed.

async fn reconcile(&self, envelope: &Envelope) -> BusResult<Option<Locator>>

Settle an attempt that ended without an answer.