Struct Client 

pub struct Client { /* private fields */ }

A client for the server part of bunbun-worker

Implementations

impl Client

pub async fn new(address: &str) -> Result<Self, Error>

Creates an bunbun-worker client.

Examples

// Create a client and send a message
use bunbun_worker::client::Client;
let client = Client::new("amqp://127.0.0.1:5672");

pub async fn rpc_call<T>( &self, data: T, options: BasicCallOptions, ) -> Result<Result<T::Result, T::ErroredResult>, ClientError>

where T: Serialize + DeserializeOwned + RPCClientTask + Send + Debug,

A method to call for a RPC

Arguments

• data The job that will be sent to the queue, must implement Deserialize and Serialize
• options BasicCallOptions, used to control the timeout and message version

pub async fn call<T>( &self, data: T, options: BasicCallOptions, ) -> Result<(), ClientError>

where T: Serialize + DeserializeOwned,

Sends a basic Task to the queue

Arguments

• data The job that will be sent to the queue, must implement Deserialize and Serialize
• options BasicCallOptions, used to control the timeout and message version

Trait Implementations

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.