Struct BrokerState 

pub struct BrokerState {
    pub log_path: Option<PathBuf>,
    pub learnings: Option<SharedLearnings>,
    /* private fields */
}

Shared broker state.

Wraps BrokerStateInner in an RwLock for concurrent read access. The sequence counter is a standalone AtomicU64 outside the lock so that sequence numbers can be allocated without coupling to the write lock.

Fields

log_path: Option<PathBuf>

Optional path for periodic log flush to disk.

learnings: Option<SharedLearnings>

Optional learnings aggregator. Populated when supervisor + learnings mode is active; the publish path forwards every observed message.

Implementations

impl BrokerState

pub fn new(log_path: Option<PathBuf>) -> Self

Creates a new empty broker state.

pub fn attach_learnings(&mut self, aggregator: SharedLearnings)

Attaches a learnings aggregator. Replaces any previously attached instance. Must be called before start_broker so the publish path observes every message from the first one.

pub fn read(&self) -> RwLockReadGuard<'_, BrokerStateInner>

Acquires a read lock on the inner state.

Panics

Panics if the lock is poisoned (a thread panicked while holding it).

pub fn write(&self) -> RwLockWriteGuard<'_, BrokerStateInner>

Acquires a write lock on the inner state.

Panics

Panics if the lock is poisoned (a thread panicked while holding it).

pub fn next_seq(&self) -> u64

Atomically allocates the next sequence number (starting at 1).

pub fn uptime_seconds(&self) -> u64

Returns the number of seconds since the broker was started.

Used by the HTTP /status handler to report uptime.

Trait Implementations

impl Debug for BrokerState

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

Formats the value using the given formatter.