Struct GrpcClientBuilder 

pub struct GrpcClientBuilder {
    pub endpoint: Endpoint,
    pub send_compressed: Option<CompressionEncoding>,
    pub accept_compressed: Option<CompressionEncoding>,
    pub max_decoding_message_size: Option<usize>,
    pub max_encoding_message_size: Option<usize>,
    pub interceptor: GrpcInterceptor,
}

Fields

endpoint: Endpoint

send_compressed: Option<CompressionEncoding>

accept_compressed: Option<CompressionEncoding>

max_decoding_message_size: Option<usize>

max_encoding_message_size: Option<usize>

interceptor: GrpcInterceptor

Implementations

impl GrpcClientBuilder

pub fn from_shared(endpoint: impl Into<Bytes>) -> Result<Self, Error>

pub fn from_static(endpoint: &'static str) -> Self

pub fn connect_timeout(self, dur: Duration) -> Self

pub fn buffer_size(self, sz: impl Into<Option<usize>>) -> Self

pub fn http2_adaptive_window(self, enabled: bool) -> Self

pub fn http2_keep_alive_interval(self, interval: Duration) -> Self

pub fn initial_connection_window_size(self, sz: impl Into<Option<u32>>) -> Self

pub fn initial_stream_window_size(self, sz: impl Into<Option<u32>>) -> Self

pub fn keep_alive_timeout(self, duration: Duration) -> Self

pub fn keep_alive_while_idle(self, enabled: bool) -> Self

pub fn tcp_keepalive(self, tcp_keepalive: Option<Duration>) -> Self

pub fn tcp_nodelay(self, enabled: bool) -> Self

pub fn timeout(self, dur: Duration) -> Self

pub fn tls_config( self, tls_config: ClientTlsConfig, ) -> Result<Self, GrpcClientBuilderError>

pub async fn tls_config_native_roots( self, ca_certificate: Option<&PathBuf>, ) -> Result<Self, GrpcClientBuilderError>

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

pub fn max_decoding_message_size(self, limit: usize) -> Self

pub fn max_encoding_message_size(self, limit: usize) -> Self

pub fn x_token<T>( self, x_token: Option<T>, ) -> Result<Self, InvalidMetadataValueBytes>

where T: TryInto<AsciiMetadataValue, Error = InvalidMetadataValueBytes>,

pub async fn connect(self) -> Result<GrpcClient<impl Interceptor>, Error>

pub fn connect_lazy(self) -> Result<GrpcClient<impl Interceptor>, Error>

Trait Implementations

impl Debug for GrpcClientBuilder

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

Formats the value using the given formatter.