Struct ChannelConfig

pub struct ChannelConfig {

    pub timeout: Option<Duration>,
    pub connect_timeout: Option<Duration>,
    pub concurrency_limit: Option<usize>,
    pub rate_limit: Option<(u64, Duration)>,
    pub initial_stream_window_size: Option<u32>,
    pub initial_connection_window_size: Option<u32>,
    pub http2_keep_alive_interval: Option<Duration>,
    pub http2_keep_alive_timeout: Option<Duration>,
    pub http2_keep_alive_while_idle: Option<bool>,
    pub http2_adaptive_window: Option<bool>,
    pub tcp_keepalive: Option<Duration>,
    pub tcp_nodelay: bool,
    pub client_tls: Option<ClientTlsOption>,
    pub max_recv_message_size: ReadableSize,
    pub max_send_message_size: ReadableSize,
}

Fields

timeout: Option<Duration>

connect_timeout: Option<Duration>

concurrency_limit: Option<usize>

rate_limit: Option<(u64, Duration)>

initial_stream_window_size: Option<u32>

initial_connection_window_size: Option<u32>

http2_keep_alive_interval: Option<Duration>

http2_keep_alive_timeout: Option<Duration>

http2_keep_alive_while_idle: Option<bool>

http2_adaptive_window: Option<bool>

tcp_keepalive: Option<Duration>

tcp_nodelay: bool

client_tls: Option<ClientTlsOption>

max_recv_message_size: ReadableSize

max_send_message_size: ReadableSize

Implementations

impl ChannelConfig

pub fn new() -> Self

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

A timeout to each request.

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

A timeout to connecting to the uri.

Defaults to no timeout.

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

A concurrency limit to each request.

pub fn rate_limit(self, limit: u64, duration: Duration) -> Self

A rate limit to each request.

pub fn initial_stream_window_size(self, size: u32) -> Self

Sets the SETTINGS_INITIAL_WINDOW_SIZE option for HTTP2 stream-level flow control. Default is 65,535

pub fn initial_connection_window_size(self, size: u32) -> Self

Sets the max connection-level flow control for HTTP2

Default is 65,535

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

Set http2 KEEP_ALIVE_INTERVAL. Uses hyper’s default otherwise.

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

Set http2 KEEP_ALIVE_TIMEOUT. Uses hyper’s default otherwise.

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

Set http2 KEEP_ALIVE_WHILE_IDLE. Uses hyper’s default otherwise.

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

Sets whether to use an adaptive flow control. Uses hyper’s default otherwise.

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

Set whether TCP keepalive messages are enabled on accepted connections.

If None is specified, keepalive is disabled, otherwise the duration specified will be the time to remain idle before sending TCP keepalive probes.

Default is no keepalive (None)

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

Set the value of TCP_NODELAY option for accepted connections.

Enabled by default.

pub fn client_tls_config(self, client_tls_option: ClientTlsOption) -> Self

Set the value of tls client auth.

Disabled by default.

Trait Implementations

impl Clone for ChannelConfig

fn clone(&self) -> ChannelConfig

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChannelConfig

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

Formats the value using the given formatter.

impl Default for ChannelConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for ChannelConfig

fn eq(&self, other: &ChannelConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ChannelConfig

impl StructuralPartialEq for ChannelConfig