Struct BrokerState 

pub struct BrokerState {
    pub log_path: Option<PathBuf>,
    /* 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.

Implementations

impl BrokerState

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

Creates a new empty broker state.

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.