Struct SourceRoute 

pub struct SourceRoute {
    pub topic: String,
    pub dispatch: RouteDispatchPolicy,
    pub schema: RouteSchemaPolicy,
}

Complete source-side routing definition derived from ProducerConfig.

Fields

topic: String

Danube topic produced by this route.

dispatch: RouteDispatchPolicy

Dispatch policy used when creating the producer.

schema: RouteSchemaPolicy

Schema configuration applied when publishing records.

Implementations

impl SourceRoute

pub fn new( topic: impl Into<String>, dispatch: RouteDispatchPolicy, schema: RouteSchemaPolicy, ) -> Self

Create a source route from its topic, dispatch, and schema policy.

Trait Implementations

impl Clone for SourceRoute

fn clone(&self) -> SourceRoute

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceRoute

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

Formats the value using the given formatter.

impl From<ProducerConfig> for SourceRoute

fn from(config: ProducerConfig) -> Self

Converts to this type from the input type.

impl From<SourceRoute> for ProducerConfig

fn from(route: SourceRoute) -> Self

Converts to this type from the input type.