Struct Pool 

pub struct Pool<DB>(/* private fields */);

The pool a handler queries through: writes through it commit on their own, whatever the delivery’s outcome.

It reads PoolContext, which every delivery of an InboxQueue subscription lends, or TxContext after Ctx<keys::Tx<..>>. On the app’s runtime it yields the service’s pool. On a dedicated thread it yields the thread’s own pool, built from the service pool’s options on the first read there. Its connections open on the thread and close with it, so none outlives the thread’s runtime in the service’s pool. It opens one connection at most, or the number InboxThreads::connections sets. A read costs one thread-local access and one clone of a pool handle. A pool’s type names its database, and so does the key: keys::Pool<Postgres>.

Examples

use ruststream_sqlx::prelude::*;
use sqlx::Postgres;

#[subscriber(InboxQueue::<Job>::new("visits"))]
async fn count(visit: &Visit, Ctx(pool): Ctx<keys::Pool<Postgres>>) -> HandlerOutcome {
    let counted = sqlx::query("UPDATE pages SET visits = visits + 1 WHERE path = $1")
        .bind(&visit.page)
        .execute(&pool)
        .await;
    if counted.is_ok() { HandlerOutcome::ack() } else { HandlerOutcome::retry() }
}

Trait Implementations

impl<DB> Clone for Pool<DB>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<DB: QueueDatabase> ContextField for Pool<DB>

type Context = PoolContext<DB>

The per-delivery context type this key reads from.

type Value = Pool<DB>

The owned value the key yields.

fn read(self, src: &PoolContext<DB>) -> DbPool<DB>

Reads this key’s field out of src. Named apart from Field::get so a key implementing both traits stays unambiguous to call.

impl<DB> Copy for Pool<DB>

impl<DB> Debug for Pool<DB>

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

Formats the value using the given formatter.

impl<DB> Default for Pool<DB>

fn default() -> Self

Returns the “default value” for a type.