Struct Config 

pub struct Config {
    pub url: String,
    pub credentials: Option<String>,
    pub max_messages: i64,
    pub max_bytes: i64,
    pub inbox_max_messages: i64,
    pub inbox_max_bytes: i64,
}

Connection settings. Kept away from the bus’s own configuration: this is infrastructure an operator points at, never something a client supplies.

Fields

url: String

e.g. nats://127.0.0.1:4222. TLS in production; the fixture runs plaintext on a private port.

credentials: Option<String>

Runtime credential: publish and fetch only. Provisioning uses a different one, which the server process does not hold.

max_messages: i64

Per-team stream ceilings for the body stream. Quotas are an operator decision — the right number depends on the disk the broker actually has — so they are configuration with a documented default, not a constant.

max_bytes: i64

inbox_max_messages: i64

The inbox stream’s own ceilings, independent of the body stream’s.

inbox_max_bytes: i64

Implementations

impl Config

pub fn new(url: impl Into<String>) -> Self

Production defaults: bounded, file-backed, refusing new writes when full rather than discarding history.

pub fn with_limits(self, max_messages: i64, max_bytes: i64) -> Self

Smaller ceilings for both streams, for a fixture whose broker has a small store.

pub fn with_inbox_limits(self, max_messages: i64, max_bytes: i64) -> Self

Ceilings for the inbox stream alone.

pub fn validate_quotas(&self) -> BusResult<()>

Refuse quotas that could never work before the broker is asked: a body stream must hold at least one maximum-size message, and a count of zero would refuse every write.

Trait Implementations

impl Clone for Config

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.