Struct LoadBalancedClient 

pub struct LoadBalancedClient<T, C, S>
where
    T: MessageChannel<C>,
    C: Codec,
    S: LoadBalanceStrategy,
{ /* private fields */ }

Implementations

impl<T, C, S> LoadBalancedClient<T, C, S>

where T: MessageChannel<C> + 'static, C: Codec + Clone + Default + 'static, S: LoadBalanceStrategy + 'static,

pub fn new( load_balancer: Arc<LoadBalancer<S>>, factory: Arc<dyn ClientFactory<T, C>>, ) -> Self

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

pub async fn call<Req, Resp>(&self, method: &str, request: &Req) -> Result<Resp>

where Req: Serialize, Resp: for<'de> Deserialize<'de>,

pub async fn call_server_stream<Req, Resp>( &self, method: &str, request: &Req, ) -> Result<StreamReceiver<Resp, C>>

where Req: Serialize, Resp: for<'de> Deserialize<'de>,

pub async fn notify<Req: Serialize>( &self, method: &str, request: &Req, ) -> Result<()>

pub fn load_balancer(&self) -> &LoadBalancer<S>

pub fn connection_count(&self) -> usize

pub fn release_stream(&self, stream_id: StreamId)

Trait Implementations

impl<T, C, S> Debug for LoadBalancedClient<T, C, S>

where T: MessageChannel<C>, C: Codec, S: LoadBalanceStrategy + 'static,

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

Formats the value using the given formatter.