Struct StreamNames 

pub struct StreamNames {
    pub room: String,
    pub wake: String,
    pub peer: String,
    pub effect: String,
    pub effect_dead: String,
    pub event: String,
}

All six stream names owned by one account.

Fields

room: String

wake: String

peer: String

effect: String

effect_dead: String

event: String

Module events (ck.{acct}.event.>), read by the flow engine.

Implementations

impl StreamNames

pub fn all(&self) -> [&str; 6]

pub fn agent_streams(&self) -> [&str; 3]

The streams that hold per-agent durables (c_{agent_id}): WAKE, PEER, EFFECT.

Grants that let a credential read any agent’s durable use a whole-token * in the consumer position on exactly these streams (NATS wildcards cannot match a c_ prefix), which admits every consumer on them. So no non-agent durable may ever be created on these streams; ck-bus asserts that against this list. ROOM, EFFECT_DEAD and EVENT are not agent streams: EVENT and ROOM hold module durables (m_{module_id}), never a c_ durable.

Trait Implementations

impl Clone for StreamNames

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 StreamNames

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

Formats the value using the given formatter.

impl Eq for StreamNames

impl PartialEq for StreamNames

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamNames