Struct RoutingContext 

pub struct RoutingContext<'a> { /* private fields */ }

Routing metadata shared by source and sink records.

Implementations

impl<'a> RoutingContext<'a>

pub fn new( topic: &'a str, key: Option<&'a str>, partition: Option<&'a str>, attributes: &'a HashMap<String, String>, ) -> Self

Create a routing context from its raw topic, key, partition, and attributes.

pub fn topic(&self) -> &'a str

Return the logical Danube topic associated with the record.

pub fn key(&self) -> Option<&'a str>

Return the routing key used for partitioned publishing, if present.

pub fn partition(&self) -> Option<&'a str>

Return the partition identifier for consumed records, if known.

pub fn attributes(&self) -> &'a HashMap<String, String>

Return the user-defined record attributes.

Trait Implementations

impl<'a> Clone for RoutingContext<'a>

fn clone(&self) -> RoutingContext<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for RoutingContext<'a>

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

Formats the value using the given formatter.

impl<'a> Copy for RoutingContext<'a>