Struct Coordinator 

pub struct Coordinator {
    pub threads: Vec<BThread>,
    pub roles: Vec<Role>,
    pub partitions: Vec<PartitionDef>,
    pub active_locks: HashMap<String, ActiveLock>,
    pub event_log: Vec<TimestampedEvent>,
}

The b-thread coordinator.

Fields

threads: Vec<BThread>

roles: Vec<Role>

partitions: Vec<PartitionDef>

active_locks: HashMap<String, ActiveLock>

event_log: Vec<TimestampedEvent>

Implementations

impl Coordinator

pub fn new() -> Coordinator

Create an empty coordinator.

pub fn expire_locks(&mut self)

Expire any locks that have exceeded their TTL.

pub fn evaluate(&self, event: &Event) -> Decision

Core evaluation: given a proposed event, check all b-threads.

Evaluation order (by b-thread priority, then rule type): BlockAlways -> Role check -> Partition -> Mutex -> Require -> BlockUntil -> RateLimit -> Timeout

Returns the first blocking/waiting decision found.

pub fn evaluate_full(&self, event: &Event) -> Decision

Full evaluation including role checks.

pub fn record(&mut self, event: &Event) -> Result<(), Error>

Record that an event occurred. Updates locks, appends to event log.

pub fn release(&mut self, lock_key: &str, _agent: &str) -> Result<(), Error>

Release a specific mutex lock.

pub fn release_all( &mut self, agent: &str, task_id: Option<&str>, ) -> Result<(), Error>

Release all locks held by an agent, optionally filtered by task.

Trait Implementations

impl Default for Coordinator

fn default() -> Coordinator

Returns the “default value” for a type.