Struct RuleDistribution 

pub struct RuleDistribution { /* private fields */ }

In-memory cluster rule store with merge + escalation.

Implementations

impl RuleDistribution

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

Create an empty store for local_node.

pub fn upsert_local(&mut self, rule: GovernanceRule, now_unix: u64)

Insert or replace a locally authored rule (starts at v1 or bumps).

pub fn active_rules(&self) -> Vec<GovernanceRule>

Snapshot of active rules (for engine injection).

pub fn set_version(&self) -> u64

Aggregate set version (sum of per-rule versions).

pub fn gossip_full(&self) -> RuleGossipEnvelope

Build a gossip envelope of the full local set.

pub fn merge(&mut self, envelope: &RuleGossipEnvelope) -> usize

Merge a remote gossip envelope (LWW on version, then timestamp, then origin).

Returns the number of rules accepted (inserted or upgraded).

pub fn escalate( &mut self, agent_id: &str, action: &str, local_decision: &GovernanceDecision, now_unix: u64, ) -> EscalationOutcome

After a local Deny, decide whether to escalate to a peer that holds a newer version of a rule matching action.

pub fn escalation_log(&self) -> &[EscalationRecord]

Escalation audit trail.

pub fn len(&self) -> usize

Number of rules currently held.

pub fn is_empty(&self) -> bool

True when no rules are held.

Trait Implementations

impl Debug for RuleDistribution

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

Formats the value using the given formatter.

impl Default for RuleDistribution

fn default() -> Self

Returns the “default value” for a type.