Struct fibers_rpc::channel::ChannelOptions

pub struct ChannelOptions {
    pub read_buffer_size: usize,
    pub write_buffer_size: usize,
    pub max_transmit_queue_len: usize,
    pub yield_threshold: usize,
    pub tcp_connect_timeout: Duration,
    pub tcp_write_timeout: Duration,
}

Options for a RPC channel.

Fields

read_buffer_size: usize

The byte size of the application level read buffer.

write_buffer_size: usize

The byte size of the application level write buffer.

max_transmit_queue_len: usize

The maximum length of the transmit queue.

If the queue exceeds this value, the RPC channel (i.e., TCP connection) will be disconnected.

yield_threshold: usize

Maximum number of iterations in a Future::poll() call.

If it exceeds this value, it will break the loop by calling fibers::fiber::yield_poll().

tcp_connect_timeout: Duration

TCP connect timeout duration.

tcp_write_timeout: Duration

Timeout duration of a write operation.

Methods

impl ChannelOptions

pub const DEFAULT_READ_BUFFER_SIZE: usize

The default value of read_buffer_size field.

pub const DEFAULT_WRITE_BUFFER_SIZE: usize

The default value of write_buffer_size field.

pub const DEFAULT_MAX_TRANSMIT_QUEUE_LEN: usize

The default value of max_transmit_queue_len field.

pub const DEFAULT_YIELD_THRESHOLD: usize

The default value of yield_threshold field.

pub const DEFAULT_TCP_CONNECT_TIMEOUT_SECONDS: u64

The default duration of tcp_connect_timeout field.

pub const DEFAULT_TCP_WRITE_TIMEOUT_SECONDS: u64

The default duration of tcp_write_timeout field.

Trait Implementations

impl Clone for ChannelOptions

fn clone(&self) -> ChannelOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for ChannelOptions

fn default() -> Self

Returns the "default value" for a type.

impl Debug for ChannelOptions

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

Formats the value using the given formatter.