Config

Struct Config 

Source
pub struct Config {
    pub bind_addr: Vec<SocketAddr>,
    pub stream_config: StreamConfig,
    pub receive_buffer_size: usize,
    pub receive_backpressure_control: Option<NonZeroUsize>,
}
Expand description

Configuration parameters for the reactor.

Fields§

§bind_addr: Vec<SocketAddr>

The list of socket addresses where the reactor listens for inbound connections.

§stream_config: StreamConfig

Configuration parameters for individual peer connections. This allows the fine tuning of internal buffer sizes etc. Most consumers won’t have to modify the default values.

§receive_buffer_size: usize

The size of the shared receive buffer, i.e. the max number of bytes that can be read in one receive operation. Setting this too low can cause many reads to happen, whereas too high a figure will use up more memory. The default is 1 megabyte.

§receive_backpressure_control: Option<NonZeroUsize>

Whether the reactor should perform backpressure control on the receive side. Setting this to Some(n) means that the reactor will start blocking on sending events to the consumer when the receive channel of size n is full and events are not being read. Setting it to None means that the capacity of the event channel is unbounded and the reactor will send events to the consumer as fast as it can, regardless of whether those events are being read (at all). The default is no backpressure control (None).

Trait Implementations§

Source§

impl Debug for Config

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for Config

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

§

impl Freeze for Config

§

impl RefUnwindSafe for Config

§

impl Send for Config

§

impl Sync for Config

§

impl Unpin for Config

§

impl UnwindSafe for Config

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.