/// Get gRPC client given a connection string.
Get gRPC client given a connection string.
Get gRPC client given a connection string .
pub async fn grpc_client(
        &self,
        connection_string: &str,
    ) -> Result<Arc<dyn GrpcClient>, ConnectionError> {
        let res = self
            .grpc_clients
            .get_with_meta(connection_string.to_string())
            .await
            .map_err(|e| Arc::new(e) as ConnectionError)?;
        debug!(was_cached=%res.cached, %connection_string, "getting IOx client");
        Ok(res.result)
    }
pub async fn grpc_client ( & self , connection_string : & str , ) -> Result < Arc < dyn GrpcClient > , ConnectionError > { let res = self . grpc_clients . get_with_meta ( connection_string . to_string ( ) ) . await . map_err ( | e | Arc :: new ( e ) as ConnectionError ) ? ; debug ! ( was_cached res cached connection_string " " ) ; Ok ( res . result ) }
Get gRPC client given a connection string.
Get gRPC client given a connection string .
&self
connection_string
&str