Struct BusClient 

pub struct BusClient { /* private fields */ }

Low-level TCP service-bus client.

Implementations

impl BusClient

pub async fn connect( host: &str, port: u16, service_id: impl Into<String>, instance_id: impl Into<String>, token: impl Into<String>, ) -> ClientResult<Self>

Opens a TCP connection and authenticates with a connect protocol frame.

pub async fn subscribe(&self, topics: Vec<String>) -> ClientResult<()>

Subscribes to one or more topics and waits for an ack.

pub async fn unsubscribe(&self, topics: Vec<String>) -> ClientResult<()>

Unsubscribes from topics without waiting for a response frame.

pub async fn publish( &self, topic: impl Into<String>, message_type: impl Into<String>, payload: HashMap<String, Value>, ) -> ClientResult<i32>

Publishes a topic + message-type payload and returns subscriber count.

pub async fn publish_event( &self, event: ServiceBusEventEnvelope, ) -> ClientResult<i32>

Publishes a fully formed event envelope and returns the subscriber count.

pub async fn forward( &self, request: ForwardRequest, ) -> ClientResult<ServiceBusForwardResponse>

Sends a forward request and validates a forward_response frame.

pub async fn on_event<F, Fut>( &self, topic: impl Into<String>, handler: F, ) -> ClientResult<()>

where F: Fn(ServiceBusEventEnvelope) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Registers an async event handler for a topic and subscribes automatically.

pub async fn on_request<F, Fut>( &self, topic: impl Into<String>, responder: F, ) -> ClientResult<()>

where F: Fn(ServiceBusRequest, RequestResponder) -> Fut + Send + Sync + 'static, Fut: Future<Output = ClientResult<()>> + Send + 'static,

Registers an async request responder by message type.

Trait Implementations

impl Clone for BusClient

fn clone(&self) -> BusClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.