Config

Struct Config 

Source
pub struct Config {
    pub bind_addr: Vec<SocketAddr>,
    pub stream_config: StreamConfig,
    pub receive_buffer_size: usize,
    pub receive_channel_size: 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.

§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 and open up your application to DoS attacks. The default is 1 MB.

This figure is capped by Message::MAX_SIZE since there is no need to ever take in more data in one read than the biggest message requires to decode.

§receive_channel_size: 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 Clone for Config

Source§

fn clone(&self) -> Config

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
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> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. 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> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
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.