Struct Config

pub struct Config {
    pub worker_threads: usize,
    pub max_blocking_threads: usize,
    pub catch_panics: bool,
    pub read_timeout: Duration,
    pub write_timeout: Duration,
    pub tcp_nodelay: Option<bool>,
    pub storage_directory: PathBuf,
    pub maximum_buffer_size: usize,
}

Configuration for the tokio runtime.

Fields

worker_threads: usize

Number of threads to use for handling async tasks.

Worker threads are always active (waiting for work).

Tokio sets the default value to the number of logical CPUs.

max_blocking_threads: usize

Maximum number of threads to use for blocking tasks.

Unlike worker threads, blocking threads are created as needed and exit if left idle for too long.

Tokio sets the default value to 512 to avoid hanging on lower-level operations that require blocking (like fs and writing to Stdout).

catch_panics: bool

Whether or not to catch panics.

read_timeout: Duration

Duration after which to close the connection if no message is read.

write_timeout: Duration

Duration after which to close the connection if a message cannot be written.

tcp_nodelay: Option<bool>

Whether or not to disable Nagle’s algorithm.

The algorithm combines a series of small network packets into a single packet before sending to reduce overhead of sending multiple small packets which might not be efficient on slow, congested networks. However, to do so the algorithm introduces a slight delay as it waits to accumulate more data. Latency-sensitive networks should consider disabling it to send the packets as soon as possible to reduce latency.

Note: Make sure that your compile target has and allows this configuration otherwise panics or unexpected behaviours are possible.

storage_directory: PathBuf

Base directory for all storage operations.

maximum_buffer_size: usize

Maximum buffer size for operations on blobs.

Tokio sets the default value to 2MB.

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for Config

fn default() -> Self

Returns the “default value” for a type.