Struct grpcio::ChannelBuilder

pub struct ChannelBuilder { /* fields omitted */ }

Channel configuration object.

Methods

impl ChannelBuilder

pub fn override_ssl_target<S: Into<Vec<u8>>>(self, target: S) -> ChannelBuilder

The caller of the secure_channel_create functions may override the target name used for SSL host name checking using this channel argument. This should be used for testing only.

pub fn secure_connect(self, addr: &str, creds: ChannelCredentials) -> Channel

impl ChannelBuilder

pub fn new(env: Arc<Environment>) -> ChannelBuilder

pub fn default_authority<S: Into<Vec<u8>>>(self, authority: S) -> ChannelBuilder

Default authority to pass if none specified on call construction.

pub fn max_concurrent_stream(self, num: i32) -> ChannelBuilder

Maximum number of concurrent incoming streams to allow on a http2 connection.

pub fn max_receive_message_len(self, len: i32) -> ChannelBuilder

Maximum message length that the channel can receive. usize::MAX means unlimited.

pub fn max_send_message_len(self, len: i32) -> ChannelBuilder

Maximum message length that the channel can send. -1 means unlimited.

pub fn max_reconnect_backoff(self, backoff: Duration) -> ChannelBuilder

The maximum time between subsequent connection attempts.

pub fn initial_reconnect_backoff(self, backoff: Duration) -> ChannelBuilder

The time between the first and second connection attempts.

pub fn https_initial_seq_number(self, number: i32) -> ChannelBuilder

Initial sequence number for http2 transports.

pub fn stream_initial_window_size(self, window_size: i32) -> ChannelBuilder

Amount to read ahead on individual streams. Defaults to 64kb, larger values can help throughput on high-latency connections.

pub fn primary_user_agent(self, agent: &str) -> ChannelBuilder

Primary user agent: goes at the start of the user-agent metadata sent on each request.

pub fn reuse_port(self, reuse: bool) -> ChannelBuilder

If enable, allow the use of SO_REUSEPORT if it's available (default true).

pub fn tcp_read_chunk_size(self, bytes: i32) -> ChannelBuilder

How large a slice to try and read from the wire each time.

pub fn tcp_min_read_chunk_size(self, bytes: i32) -> ChannelBuilder

How minimal large a slice to try and read from the wire each time.

pub fn tcp_max_read_chunk_size(self, bytes: i32) -> ChannelBuilder

How maximal large a slice to try and read from the wire each time.

pub fn http2_write_buffer_size(self, size: i32) -> ChannelBuilder

How much data are we willing to queue up per stream if write_buffer_hint is set. This is an upper bound.

pub fn http2_max_frame_size(self, size: i32) -> ChannelBuilder

How big a frame are we willing to receive via HTTP2. Min 16384, max 16777215. Larger values give lower CPU usage for large messages, but more head of line blocking for small messages.

pub fn http2_bdp_probe(self, enable: bool) -> ChannelBuilder

Set BDP probing.

pub fn http2_min_sent_ping_interval_without_data(     self,     interval: Duration ) -> ChannelBuilder

Minimum time between sending successive ping frames without receiving any data frame.

pub fn http2_min_recv_ping_interval_without_data(     self,     interval: Duration ) -> ChannelBuilder

Minimum allowed time between receiving successive ping frames without sending any data frame.

pub fn http2_max_pings_without_data(self, num: i32) -> ChannelBuilder

How many pings can we send before needing to send a data frame or header frame? (0 indicates that an infinite number of pings can be sent without sending a data frame or header frame)

pub fn http2_max_ping_strikes(self, num: i32) -> ChannelBuilder

How many misbehaving pings the server can bear before sending goaway and closing the transport? (0 indicates that the server can bear an infinite number of misbehaving pings)

pub fn default_compression_algorithm(     self,     algo: CompressionAlgorithms ) -> ChannelBuilder

Default compression algorithm for the channel.

pub fn default_compression_level(     self,     level: CompressionLevel ) -> ChannelBuilder

Default compression level for the channel.

pub fn keepalive_time(self, timeout: Duration) -> ChannelBuilder

After a duration of this time the client/server pings its peer to see if the transport is still alive.

pub fn keepalive_timeout(self, timeout: Duration) -> ChannelBuilder

After waiting for a duration of this time, if the keepalive ping sender does not receive the ping ack, it will close the transport.

pub fn keepalive_permit_without_calls(self, allow: bool) -> ChannelBuilder

Is it permissible to send keepalive pings without any outstanding streams.

pub fn optimize_for(self, target: OptTarget) -> ChannelBuilder

Optimize a channel.

Default is OptTarget::Blend.

pub fn build_args(&self) -> ChannelArgs

Build a channel args from the current configuration.

pub fn connect(self, addr: &str) -> Channel

Build an insure connection to the address.