Struct BasiliskClient 

pub struct BasiliskClient {
    pub gateway: GatewayApiClient,
    pub bus: BusClient,
    pub service_id: String,
    pub instance_id: String,
}

High-level client that combines gateway registration APIs and the service-bus client.

Fields

gateway: GatewayApiClient

Gateway API client handle.

bus: BusClient

Service bus client handle.

service_id: String

Current service id.

instance_id: String

Registered instance id.

Implementations

impl BasiliskClient

pub async fn connect(config: BasiliskClientConfig) -> Result<Self>

Registers the instance with the gateway and opens an authenticated bus connection.

pub async fn deregister(&self) -> Result<()>

Deregisters this instance from the gateway registry.

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

Subscribes this client to the provided topics.

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

Unsubscribes this client from the provided topics.

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

Publishes an event and returns the number of subscribers that received it.

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

Publishes a fully constructed event envelope.

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

Sends a forward request and waits for a forward response.

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.

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 keyed by message type.

Trait Implementations

impl Clone for BasiliskClient

fn clone(&self) -> BasiliskClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.