Struct KafkaProtocol 

pub struct KafkaProtocol;

Built-in Kafka protocol ("kafka").

Implementations

impl KafkaProtocol

pub fn attach_contract(&self, meta: &KafkaContractMeta) -> ProtocolAttachment

Attach contract-level Kafka metadata.

pub fn attach_channel(&self, meta: &KafkaChannelMeta) -> ProtocolAttachment

Attach channel-level Kafka metadata.

pub fn attach_operation(&self, meta: &KafkaOperationMeta) -> ProtocolAttachment

Attach operation-level Kafka metadata.

pub fn attach_message(&self, meta: &KafkaMessageMeta) -> ProtocolAttachment

Attach message-level Kafka metadata.

Trait Implementations

impl Clone for KafkaProtocol

fn clone(&self) -> KafkaProtocol

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for KafkaProtocol

impl Debug for KafkaProtocol

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

Formats the value using the given formatter.

impl Default for KafkaProtocol

fn default() -> KafkaProtocol

Returns the “default value” for a type.

impl Protocol for KafkaProtocol

fn id(&self) -> &'static str

Protocol slug (for example "http", "grpc").