Struct ClosedSqlxBroker 

pub struct ClosedSqlxBroker { /* private fields */ }

The broker after shutdown: what it did to the advisory locks its deliveries held.

A broker without advisory subscriptions reports none of either.

Examples

use ruststream::{Broker, ConnectedBroker};
use ruststream_sqlx::{ClosedSqlxBroker, SqlxBroker};

let closed: ClosedSqlxBroker = SqlxBroker::new(pool).connect().await?.shutdown().await?;
tracing::info!(
    locks_released = closed.locks_released(),
    connections_closed = closed.connections_closed(),
    "inbox closed",
);

Implementations

impl ClosedSqlxBroker

pub const fn locks_released(&self) -> usize

Locks shutdown released with Unlock (or freed from the process registry), whose sessions went back to the pool.

Examples

use ruststream::{Broker, ConnectedBroker};
use ruststream_sqlx::SqlxBroker;

let closed = SqlxBroker::new(pool).connect().await?.shutdown().await?;
if closed.locks_released() > 0 {
    tracing::info!(
        released = closed.locks_released(),
        "deliveries in work went back to their queues",
    );
}

pub const fn connections_closed(&self) -> usize

Sessions that held a lock and were closed instead: where shutdown’s release failed, and where a delivery dropped unsettled, or a claim dropped midway, left its session closing when shutdown began.

Examples

use ruststream::{Broker, ConnectedBroker};
use ruststream_sqlx::SqlxBroker;

let closed = SqlxBroker::new(pool).connect().await?.shutdown().await?;
if closed.connections_closed() > 0 {
    tracing::warn!(
        closed = closed.connections_closed(),
        "sessions holding a lock were closed rather than released",
    );
}

Trait Implementations

impl Debug for ClosedSqlxBroker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.