pub struct PubSubBuilder { /* private fields */ }Expand description
Builder for creating pub/sub infrastructure.
Implementations§
Source§impl PubSubBuilder
impl PubSubBuilder
Sourcepub fn new() -> PubSubBuilder
pub fn new() -> PubSubBuilder
Create a new builder.
Sourcepub fn max_subscribers_per_topic(self, count: usize) -> PubSubBuilder
pub fn max_subscribers_per_topic(self, count: usize) -> PubSubBuilder
Set maximum subscribers per topic.
Sourcepub fn channel_buffer_size(self, size: usize) -> PubSubBuilder
pub fn channel_buffer_size(self, size: usize) -> PubSubBuilder
Set channel buffer size.
Sourcepub fn max_retained_messages(self, count: usize) -> PubSubBuilder
pub fn max_retained_messages(self, count: usize) -> PubSubBuilder
Set maximum retained messages.
Sourcepub fn enable_persistence(self, enable: bool) -> PubSubBuilder
pub fn enable_persistence(self, enable: bool) -> PubSubBuilder
Enable message persistence.
Sourcepub fn default_qos(self, qos: QoS) -> PubSubBuilder
pub fn default_qos(self, qos: QoS) -> PubSubBuilder
Set default QoS.
Sourcepub fn build(self) -> Arc<PubSubBroker>
pub fn build(self) -> Arc<PubSubBroker>
Build the pub/sub broker.
Trait Implementations§
Source§impl Default for PubSubBuilder
impl Default for PubSubBuilder
Source§fn default() -> PubSubBuilder
fn default() -> PubSubBuilder
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for PubSubBuilder
impl RefUnwindSafe for PubSubBuilder
impl Send for PubSubBuilder
impl Sync for PubSubBuilder
impl Unpin for PubSubBuilder
impl UnwindSafe for PubSubBuilder
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Gets the layout of the type.