Struct MessageBus 

pub struct MessageBus<T = AnyValue> {
    pub commands: Node<MessageBusCommand<T>>,
    pub messages: Node<MessageEnvelope<T>>,
    pub status: Node<MessageBusStatus>,
    pub issues: Node<DataIssue>,
    /* private fields */
}

MessageBus data container.

Fields

commands: Node<MessageBusCommand<T>>

commands field for commands.

messages: Node<MessageEnvelope<T>>

messages field for messages.

status: Node<MessageBusStatus>

status field for status.

issues: Node<DataIssue>

issues field for issues.

Implementations

impl<T: Clone + 'static> MessageBus<T>

pub fn new( graph: &Graph, topics: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Creates or computes new.

pub fn with_options(graph: &Graph, opts: MessageBusOptions) -> Self

Creates or computes with_options.

pub fn ensure_topic( &self, topic: impl Into<String>, command_id: Option<String>, ) -> MessageBusCommand<T>

Updates or reads ensure_topic.

pub fn close_topic( &self, topic: impl Into<String>, command_id: Option<String>, ) -> MessageBusCommand<T>

Updates or reads close_topic.

pub fn publish( &self, topic: impl Into<String>, payload: T, key: Option<String>, command_id: Option<String>, idempotency_key: Option<String>, ) -> MessageBusCommand<T>

Updates or reads publish.

pub fn set_topic_policy( &self, topic_policy: MessageBusTopicPolicy, command_id: Option<String>, ) -> MessageBusCommand<T>

Updates or reads set_topic_policy.

pub fn topic(&self, topic: impl Into<String>) -> MessageBusTopicProjection<T>

Updates or reads topic.

pub fn topic_named( &self, topic: impl Into<String>, name: Option<impl Into<String>>, ) -> MessageBusTopicProjection<T>

Updates or reads topic_named.

pub fn catalog(&self) -> MessageBusPullProjection<MessageBusCatalogPage>

Updates or reads catalog.

pub fn catalog_named( &self, name: Option<impl Into<String>>, ) -> MessageBusPullProjection<MessageBusCatalogPage>

Updates or reads catalog_named.

pub fn dead_letter( &self, ) -> MessageBusPullProjection<MessageBusDeadLetterPage<T>>

Updates or reads dead_letter.

pub fn dead_letter_named( &self, name: Option<impl Into<String>>, ) -> MessageBusPullProjection<MessageBusDeadLetterPage<T>>

Updates or reads dead_letter_named.

pub fn subscription( &self, opts: MessageBusSubscriptionOptions, ) -> MessageBusSubscription<T>

Updates or reads subscription.

Trait Implementations

impl<T: Clone> Clone for MessageBus<T>

fn clone(&self) -> MessageBus<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.