Struct PoolContext 

pub struct PoolContext { /* private fields */ }

The per-delivery context that carries the broker’s connection pool and nothing else: what a handler taking Ctx<keys::FredPool> alone reads, on every form.

Examples

use fred::interfaces::KeysInterface;
use ruststream::prelude::*;
use ruststream::subscriber;
use ruststream_fred::RedisList;
use ruststream_fred::context::keys;

/// Runs a job once: a delivery of a job seen before counts past one and is dropped.
#[subscriber(RedisList::new("jobs").reliable())]
async fn work(job: &Job, Ctx(pool): Ctx<keys::FredPool>) -> HandlerOutcome {
    match pool.incr::<i64, _>(format!("jobs.seen:{}", job.id)).await {
        Ok(1) => HandlerOutcome::ack(),
        Ok(_) => HandlerOutcome::drop(),
        Err(_) => HandlerOutcome::retry(),
    }
}

Implementations

impl PoolContext

pub const fn pool(&self) -> &Pool

The broker’s connection pool.

Trait Implementations

impl BuildContext<RedisListMessage> for PoolContext

fn build(msg: &RedisListMessage) -> Self

Builds the context value by reading fields out of msg.

impl BuildContext<RedisMessage> for PoolContext

fn build(msg: &RedisMessage) -> Self

Builds the context value by reading fields out of msg.

impl BuildContext<RedisPubSubMessage> for PoolContext

fn build(msg: &RedisPubSubMessage) -> Self

Builds the context value by reading fields out of msg.

impl<F: Form> BuildContext<RoundMessage<F>> for PoolContext

fn build(msg: &RoundMessage<F>) -> Self

Builds the context value by reading fields out of msg.

impl Clone for PoolContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PoolContext

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

Formats the value using the given formatter.

impl Field<PoolContext> for FredPool

type Value<'a> = &'a Pool

The value read through this key, borrowed from the source for 'a.

fn get(self, src: &PoolContext) -> &Pool

Reads this key’s field out of src.