Struct StreamingRouter 

pub struct StreamingRouter { /* private fields */ }

Collects producer and consumer handler registrations.

Use the streaming_routes! macro or builder methods to populate.

Implementations

impl StreamingRouter

pub fn new() -> Self

Create an empty streaming router.

pub fn producer(self, topic: &'static str, name: &'static str) -> Self

Register a producer handler by topic and name.

pub fn into_handlers(self) -> Vec<StreamingHandlerRegistration>

Consume the router and return the registered handlers.

pub fn consumer( self, topic: &'static str, group: &'static str, name: &'static str, factory: Arc<dyn ConsumerFactory>, ) -> Self

Register a consumer handler with a factory.

Trait Implementations

impl Default for StreamingRouter

fn default() -> StreamingRouter

Returns the “default value” for a type.