Struct PubSubBuilder 

pub struct PubSubBuilder {
    config: PubSubConfig,
}

Builder for creating pub/sub infrastructure.

Fields

config: PubSubConfig

Implementations

impl PubSubBuilder

pub fn new() -> Self

Create a new builder.

pub fn max_subscribers_per_topic(self, count: usize) -> Self

Set maximum subscribers per topic.

pub fn channel_buffer_size(self, size: usize) -> Self

Set channel buffer size.

pub fn max_retained_messages(self, count: usize) -> Self

Set maximum retained messages.

pub fn enable_persistence(self, enable: bool) -> Self

Enable message persistence.

pub fn default_qos(self, qos: QoS) -> Self

Set default QoS.

pub fn build(self) -> Arc<PubSubBroker>

Build the pub/sub broker.

Trait Implementations

impl Default for PubSubBuilder

fn default() -> Self

Returns the “default value” for a type.