Struct lapin_futures_tls_api::lapin::channel::BasicQosOptions

pub struct BasicQosOptions {
    pub prefetch_size: u32,
    pub prefetch_count: u16,
    pub global: bool,
}

Quality of service" settings. The QoS can be specified for the current channel or for all channels on the connection. The particular properties and semantics of a qos method always depend on the content class semantics. Though the qos method could in principle apply to both peers, it is currently meaningful only for the server.

Fields

prefetch_size: u32

The client can request that messages be sent in advance so that when the client finishes processing a message, the following message is already held locally, rather than needing to be sent down the channel. Prefetching gives a performance improvement. This field specifies the prefetch window size in octets. The server will send a message in advance if it is equal to or smaller in size than the available prefetch size (and also falls into other prefetch limits). May be set to zero, meaning "no specific limit", although other prefetch limits may still apply. The prefetch-size is ignored if the no-ack option is set.

prefetch_count: u16

Specifies a prefetch window in terms of whole messages. This field may be used in combination with the prefetch-size field; a message will only be sent in advance if both prefetch windows (and those at the channel and connection level) allow it. The prefetch-count is ignored if the no-ack option is set.

global: bool

RabbitMQ has reinterpreted this field. The original specification said: "By default the QoS settings apply to the current channel only. If this field is set, they are applied to the entire connection." Instead, RabbitMQ takes global=false to mean that the QoS settings should apply per-consumer (for new consumers on the channel; existing ones being unaffected) and global=true to mean that the QoS settings should apply per-channel.

Trait Implementations

impl PartialEq<BasicQosOptions> for BasicQosOptions

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl Default for BasicQosOptions

fn default() -> BasicQosOptions

Returns the "default value" for a type.

impl Debug for BasicQosOptions

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

Formats the value using the given formatter.

impl Clone for BasicQosOptions

fn clone(&self) -> BasicQosOptions

Returns a copy of the value.

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

Performs copy-assignment from source.