Struct RouterState 

pub struct RouterState { /* private fields */ }

Global router state

Implementations

impl RouterState

pub fn new() -> Self

pub fn with_config(config: RouterStateConfig) -> Self

Create with specific configuration

pub fn register_signals(&self, signals: Vec<SignalDefinition>)

Register signals from an ANNOUNCE message

pub fn query_signals(&self, pattern: &str) -> Vec<SignalDefinition>

Query signals matching a pattern

pub fn all_signals(&self) -> Vec<SignalDefinition>

Get all registered signals

pub fn signal_count(&self) -> usize

Get signal count

pub fn cleanup_stale_signals(&self, ttl: Duration) -> usize

Remove stale signals that haven’t been accessed within the TTL Returns the number of signals removed

pub fn cleanup_stale_params(&self, ttl: Duration) -> usize

Remove stale params using the configured TTL Returns the number of params removed

pub fn cleanup_stale(&self) -> (usize, usize)

Run all cleanup operations using configured TTLs Returns (params_removed, signals_removed)

pub fn get(&self, address: &str) -> Option<Value>

Get a parameter value

pub fn get_state(&self, address: &str) -> Option<ParamState>

Get full parameter state

pub fn set( &self, address: &str, value: Value, writer: &SessionId, revision: Option<u64>, lock: bool, unlock: bool, ttl: Option<Ttl>, ) -> Result<u64, UpdateError>

Set a parameter value

pub fn apply_set( &self, msg: &SetMessage, writer: &SessionId, ) -> Result<u64, UpdateError>

Apply a SET message

pub fn get_matching(&self, pattern: &str) -> Vec<(String, ParamState)>

Get all parameters matching a pattern

pub fn snapshot(&self, pattern: &str) -> SnapshotMessage

Create a snapshot of all params matching a pattern

pub fn full_snapshot(&self) -> SnapshotMessage

Create a full snapshot

pub fn len(&self) -> usize

Number of parameters

pub fn is_empty(&self) -> bool

Check if empty

pub fn clear(&self)

Clear all state

Trait Implementations

impl Default for RouterState

fn default() -> Self

Returns the “default value” for a type.