Skip to main content

BufferConfig

Struct BufferConfig 

Source
pub struct BufferConfig { /* private fields */ }
Expand description

The configuration for the network buffers

Implementations§

Source§

impl BufferConfig

Source

pub fn from_config(config: &Config) -> BufferConfig

Tries to deserialise a configuration instance from the specified in the given config.

Returns the same values as BufferConfig::default if it fails to read from the config.

Source

pub fn from_config_file<P>(path: P) -> BufferConfig
where P: Into<PathBuf>,

Tries to deserialise a BufferConfig from a TOML file at path

Returns the same values as BufferConfig::default if it fails to read from the config.

§Panics

Panics if it fails to load the file or fails to load the file as TOML.

Source

pub fn chunk_size(&mut self, size: usize)

Sets the chunk_size to the given number of bytes.

Specifies the size in bytes of each BufferChunk instance produced by pools using this configuration.

Must be at least 128 bytes, and must also be greater than encode_buf_min_free_space.

Source

pub fn chunk_size_bytes(&self) -> usize

Returns the configured chunk size in bytes.

Source

pub fn initial_chunk_count(&mut self, count: usize)

Sets the initial_chunk_count to the given number.

Specifies the number of BufferChunk instances that pools using this configuration create initially.

May be at most the value of max_chunk_count.

Source

pub fn max_chunk_count(&mut self, count: usize)

Sets the max_chunk_count to the given number.

Specifies the maximum number of BufferChunk instances that pools using this configuration may create.

Must be at least the value of initial_chunk_count.

Source

pub fn encode_buf_min_free_space(&mut self, size: usize)

Sets the encode_buf_min_free_space to the given number of bytes.

This sets the minimum number of bytes an EncodeBuffer must have available before attempting any serialisation into it.

Must be less than chunk_size.

Source

pub fn validate(&self)

Performs basic sanity checks on the config parameters and panics if it is invalid.

This method is called automatically by any BufferPool on creation.

Trait Implementations§

Source§

impl Clone for BufferConfig

Source§

fn clone(&self) -> BufferConfig

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for BufferConfig

Source§

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

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

impl Default for BufferConfig

Source§

fn default() -> BufferConfig

Create a new configuration with default values which may then be overwritten

Source§

impl PartialEq for BufferConfig

Source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 (const: unstable) · Source§

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

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

impl Eq for BufferConfig

Source§

impl StructuralPartialEq for BufferConfig

Auto Trait Implementations§

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> DispatchEvent for T
where T: Any + Send + Debug,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any + Send>

Convert this event into an erased Any payload for downcasting.
Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
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> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
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> TryClone for T
where T: Clone,

Source§

fn try_clone(&self) -> Result<T, SerError>

Tries to produce a copy of self or returns an error
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.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> Erased for T

Source§

impl<M> MessageBounds for M
where M: Debug + Send + 'static,

Source§

impl<T> SendSyncUnwindSafe for T
where T: Send + Sync + UnwindSafe + ?Sized,