Struct grpc::Client

pub struct Client { /* fields omitted */ }

gRPC client implementation. Used by generated code.

Methods

impl Client

pub fn new_plain(host: &str, port: u16, conf: ClientConf) -> Result<Client>

Create a client connected to specified host and port.

pub fn clone(&self) -> Client

Create a clone of this client but refer to same httpbis::Client.

pub fn new_tls<C: TlsConnector>(
    host: &str,
    port: u16,
    conf: ClientConf
) -> Result<Client>

Create a client connected to specified host and port.

pub fn new_expl<C: TlsConnector>(
    addr: &SocketAddr,
    host: &str,
    tls: ClientTlsOption<C>,
    conf: ClientConf
) -> Result<Client>

pub fn new_resp_channel<Resp: Send + 'static>(
    &self
) -> Oneshot<(UnboundedSender<ResultOrEof<Resp, Error>>, GrpcStream<Resp>)>

pub fn call_unary<Req, Resp>(
    &self,
    o: RequestOptions,
    req: Req,
    method: Arc<MethodDescriptor<Req, Resp>>
) -> SingleResponse<Resp> where
    Req: Send + 'static,
    Resp: Send + 'static, 

pub fn call_server_streaming<Req, Resp>(
    &self,
    o: RequestOptions,
    req: Req,
    method: Arc<MethodDescriptor<Req, Resp>>
) -> StreamingResponse<Resp> where
    Req: Send + 'static,
    Resp: Send + 'static, 

pub fn call_client_streaming<Req, Resp>(
    &self,
    o: RequestOptions,
    req: StreamingRequest<Req>,
    method: Arc<MethodDescriptor<Req, Resp>>
) -> SingleResponse<Resp> where
    Req: Send + 'static,
    Resp: Send + 'static, 

pub fn call_bidi<Req, Resp>(
    &self,
    o: RequestOptions,
    req: StreamingRequest<Req>,
    method: Arc<MethodDescriptor<Req, Resp>>
) -> StreamingResponse<Resp> where
    Req: Send + 'static,
    Resp: Send + 'static, 

Trait Implementations