Struct MessageBusOptions 

pub struct MessageBusOptions {
    pub name: String,
    pub topics: Vec<String>,
    pub topic_policy: MessageBusTopicPolicy,
    pub retention: MessageBusRetentionPolicy,
    pub dedupe: MessageBusDedupePolicy,
    pub now: Rc<dyn Fn() -> u64>,
}

MessageBusOptions data container.

Fields

name: String

name field for name.

topics: Vec<String>

topics field for topics.

topic_policy: MessageBusTopicPolicy

topic_policy field for topic policy.

retention: MessageBusRetentionPolicy

retention field for retention.

dedupe: MessageBusDedupePolicy

dedupe field for dedupe.

now: Rc<dyn Fn() -> u64>

now field for now.

Implementations

impl MessageBusOptions

pub fn named(name: impl Into<String>) -> Self

Creates or computes named.

pub fn with_topics( self, topics: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Updates or reads with_topics.

pub fn with_topic_policy(self, policy: MessageBusTopicPolicy) -> Self

Updates or reads with_topic_policy.

pub fn with_retention(self, retention: MessageBusRetentionPolicy) -> Self

Updates or reads with_retention.

pub fn with_dedupe(self, dedupe: MessageBusDedupePolicy) -> Self

Updates or reads with_dedupe.

pub fn with_now(self, now: impl Fn() -> u64 + 'static) -> Self

Updates or reads with_now.

Trait Implementations

impl Clone for MessageBusOptions

fn clone(&self) -> MessageBusOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MessageBusOptions

fn default() -> Self

Returns the “default value” for a type.