Struct ConnQuota 

pub struct ConnQuota {
    pub max_conns: usize,
    pub max_subs_per_conn: usize,
    pub supports_multiplex: bool,
}

Connection and subscription quotas of one broker user.

BrokerLimiter only stores and returns these numbers (see BrokerLimiter::conn_quota). It does not open or close connections. A connector decides what to do with them. For example the Finam connector reads max_subs_per_conn and refuses a new stream with [brokapi_core::Error::Rejected] once the quota is used. The other fields are carried for the connectors that need them and are not enforced by the runtime.

Examples

use brokapi_runtime::ConnQuota;

let q = ConnQuota::default();
assert_eq!((q.max_conns, q.max_subs_per_conn), (2, 50));
assert!(!q.supports_multiplex);

Fields

max_conns: usize

How many connections the broker lets one user hold at the same time.

max_subs_per_conn: usize

How many subscriptions (streams) one connection may carry.

supports_multiplex: bool

Whether one connection can carry several subscriptions at once.

Trait Implementations

impl Clone for ConnQuota

fn clone(&self) -> ConnQuota

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnQuota

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

Formats the value using the given formatter.

impl Default for ConnQuota

fn default() -> Self

Cautious values: 2 connections, 50 subscriptions per connection, no multiplexing.

impl<'de> Deserialize<'de> for ConnQuota

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ConnQuota

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for ConnQuota