Struct StreamingHandlerRegistration 

pub struct StreamingHandlerRegistration {
    pub topic: &'static str,
    pub group: Option<&'static str>,
    pub name: &'static str,
    pub kind: StreamingHandlerKind,
    pub consumer_factory: Option<Arc<dyn ConsumerFactory>>,
}

A registered streaming handler (producer or consumer).

Fields

topic: &'static str

Topic associated with the handler.

group: Option<&'static str>

Consumer group for consumer handlers.

name: &'static str

Logical handler name used for registration and lookup.

kind: StreamingHandlerKind

Handler direction.

consumer_factory: Option<Arc<dyn ConsumerFactory>>

Factory for spawning consumer tasks. None for producers.

Trait Implementations

impl Clone for StreamingHandlerRegistration

fn clone(&self) -> StreamingHandlerRegistration

Returns a duplicate of the value.

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

Performs copy-assignment from source.