[−][src]Struct amiquip::ConnectionTuning
Tuning parameters for the amiquip client.
The options are solely used to control local behavior of the client. They are not part of the
AMQP spec and are not communicated with the server in any way. For options that configure the
AMQP connection, see ConnectionOptions
.
Fields
mem_channel_bound: usize
Set the bound used when creating mio_extras::channel::sync_channel()
channels for sending
messages to the connection's I/O thread. The default value for this field is 16.
See the discussion on connection tuning for more information.
buffered_writes_high_water: usize
Set the maximum amount of data in bytes that the I/O thread will buffer before it begins to
apply backpressure on clients by not reading from their channels. If the high water mark is
reached, the I/O loop will not resume reading from client channels until the amount of
buffered data drops below
buffered_writes_low_water
bytes. The default value for this field is 16 MiB.
See the discussion on connection tuning for more information.
buffered_writes_low_water: usize
Set the low water mark for the I/O thread to resume reading from client channels. The default value for this field is 0 bytes.
See the discussion on connection tuning for more information.
Implementations
impl ConnectionTuning
[src]
pub fn mem_channel_bound(self, mem_channel_bound: usize) -> Self
[src]
Set the channel memory bound.
pub fn buffered_writes_high_water(
self,
buffered_writes_high_water: usize
) -> Self
[src]
self,
buffered_writes_high_water: usize
) -> Self
Set the high water mark for buffered data to be written to the underlying stream.
pub fn buffered_writes_low_water(self, buffered_writes_low_water: usize) -> Self
[src]
Set the low water mark for buffered data to be written to the underlying stream.
Trait Implementations
impl Clone for ConnectionTuning
[src]
fn clone(&self) -> ConnectionTuning
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for ConnectionTuning
[src]
impl Default for ConnectionTuning
[src]
Auto Trait Implementations
impl RefUnwindSafe for ConnectionTuning
impl Send for ConnectionTuning
impl Sync for ConnectionTuning
impl Unpin for ConnectionTuning
impl UnwindSafe for ConnectionTuning
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,