Struct RouteSubscriptionPolicy 

pub struct RouteSubscriptionPolicy {
    pub consumer_name: String,
    pub subscription: String,
    pub subscription_type: SubscriptionType,
}

Subscription behavior for a sink route.

Fields

consumer_name: String

Consumer name used when creating the Danube consumer.

subscription: String

Subscription name shared by consumers of the same route.

subscription_type: SubscriptionType

Danube subscription type for this route.

Implementations

impl RouteSubscriptionPolicy

pub fn new( consumer_name: impl Into<String>, subscription: impl Into<String>, subscription_type: SubscriptionType, ) -> Self

Create a subscription policy from explicit consumer settings.

Trait Implementations

impl Clone for RouteSubscriptionPolicy

fn clone(&self) -> RouteSubscriptionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RouteSubscriptionPolicy

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

Formats the value using the given formatter.