Struct StreamContext 

pub struct StreamContext { /* private fields */ }

Per-delivery context for a Redis Streams delivery (RedisMessage).

Built once per delivery from the message. Read its fields by keys key off a Context.

Implementations

impl StreamContext

pub fn new(entry_id: Option<String>, consumer_group: Option<String>) -> Self

Constructs a context directly from its native fields (mainly for tests).

pub fn entry_id(&self) -> Option<&str>

The stream entry id (for example 1700000000000-0) this delivery was read at.

pub fn consumer_group(&self) -> Option<&str>

The consumer group this delivery was read through.

Trait Implementations

impl BuildContext<RedisMessage> for StreamContext

fn build(msg: &RedisMessage) -> Self

Builds the context value by reading fields out of msg.

impl Clone for StreamContext

fn clone(&self) -> StreamContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamContext

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

Formats the value using the given formatter.

impl Default for StreamContext

fn default() -> StreamContext

Returns the “default value” for a type.

impl Eq for StreamContext

impl Field<StreamContext> for EntryId

type Value<'a> = Option<&'a str>

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

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

Reads this key’s field out of src.

impl Field<StreamContext> for ConsumerGroup

type Value<'a> = Option<&'a str>

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

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

Reads this key’s field out of src.

impl PartialEq for StreamContext

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamContext