Struct ConsumerGroup 

pub struct ConsumerGroup;

Reads the consumer group off a stream context, per delivery or per batch.

Examples

use ruststream_fred::stream::prelude::*;
use serde::Deserialize;

#[derive(Deserialize)]
struct Order {
    id: u64,
}

#[subscriber(RedisStream::new("orders").group("workers"))]
async fn handle(order: &Order, ctx: &mut Context<'_, StreamContext>) -> HandlerOutcome {
    // The entry id reads like `1700000000000-0`.
    tracing::info!(
        order.id,
        entry = %ctx.context(keys::EntryId),
        group = %ctx.context(keys::ConsumerGroup),
        "read"
    );
    HandlerOutcome::ack()
}

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        RedisBroker::standalone("redis://localhost:6379"),
        |b| {
            b.include(handle);
        },
    )
}

Trait Implementations

impl Clone for ConsumerGroup

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ContextField for ConsumerGroup

type Context = StreamContext

The per-delivery context type this key reads from.

type Value = String

The owned value the key yields.

fn read(self, src: &StreamContext) -> String

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

impl Copy for ConsumerGroup

impl Debug for ConsumerGroup

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

Formats the value using the given formatter.

impl Default for ConsumerGroup

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ConsumerGroup

impl Field<StreamBatchContext> for ConsumerGroup

type Value<'a> = &'a str

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

fn get(self, src: &StreamBatchContext) -> &str

Reads this key’s field out of src.

impl Field<StreamContext> for ConsumerGroup

type Value<'a> = &'a str

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

fn get(self, src: &StreamContext) -> &str

Reads this key’s field out of src.

impl Hash for ConsumerGroup

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ConsumerGroup

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ConsumerGroup