pub struct TripleClient { /* private fields */ }
Implementations§
source§impl TripleClient
impl TripleClient
pub fn connect(host: String) -> Self
pub fn new(builder: ClientBuilder) -> Self
pub fn with_cluster(self, invoker: ClusterInvoker) -> Self
pub fn map_request( &self, uri: Uri, path: PathAndQuery, body: SdkBody ) -> Request<SdkBody>
pub async fn unary<C, M1, M2>( &mut self, req: Request<M1>, codec: C, path: PathAndQuery, invocation: RpcInvocation ) -> Result<Response<M2>, Status>where C: Codec<Encode = M1, Decode = M2>, M1: Send + Sync + 'static, M2: Send + Sync + 'static,
pub async fn bidi_streaming<C, M1, M2>( &mut self, req: impl IntoStreamingRequest<Message = M1>, codec: C, path: PathAndQuery, invocation: RpcInvocation ) -> Result<Response<Decoding<M2>>, Status>where C: Codec<Encode = M1, Decode = M2>, M1: Send + Sync + 'static, M2: Send + Sync + 'static,
pub async fn client_streaming<C, M1, M2>( &mut self, req: impl IntoStreamingRequest<Message = M1>, codec: C, path: PathAndQuery, invocation: RpcInvocation ) -> Result<Response<M2>, Status>where C: Codec<Encode = M1, Decode = M2>, M1: Send + Sync + 'static, M2: Send + Sync + 'static,
pub async fn server_streaming<C, M1, M2>( &mut self, req: Request<M1>, codec: C, path: PathAndQuery, invocation: RpcInvocation ) -> Result<Response<Decoding<M2>>, Status>where C: Codec<Encode = M1, Decode = M2>, M1: Send + Sync + 'static, M2: Send + Sync + 'static,
Trait Implementations§
source§impl Clone for TripleClient
impl Clone for TripleClient
source§fn clone(&self) -> TripleClient
fn clone(&self) -> TripleClient
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for TripleClient
impl Debug for TripleClient
source§impl Default for TripleClient
impl Default for TripleClient
source§fn default() -> TripleClient
fn default() -> TripleClient
Returns the “default value” for a type. Read more