Struct Board 

pub struct Board { /* private fields */ }

Implementations

impl Board

pub fn open(path: &Path, run_id: &str) -> Result<Self, BoardError>

Opens (creating as needed) the board for one run.

Errors

Returns BoardError when the database cannot be opened or migrated.

pub fn register(&self, agent: &str) -> Result<(), BoardError>

Registers (or re-registers, idempotently) an agent in this run.

Errors

Returns BoardError on storage failure.

pub fn set_status(&self, agent: &str, status: &str) -> Result<(), BoardError>

Updates an agent’s free-text status line.

Errors

Returns BoardError on storage failure.

pub fn peers(&self, agent: &str) -> Result<Vec<Peer>, BoardError>

All agents in this run except agent itself.

Errors

Returns BoardError on storage failure.

impl Board

pub fn broadcast(&self, from_agent: &str, body: &str) -> Result<(), BoardError>

Queues a message to every current peer (to_agent NULL = broadcast).

Errors

Returns BoardError on storage failure.

pub fn send( &self, from_agent: &str, to_agent: &str, body: &str, ) -> Result<(), BoardError>

Queues a directed message.

Errors

Returns BoardError on storage failure.

pub fn read(&self, agent: &str) -> Result<Vec<Message>, BoardError>

Unread messages for agent (broadcasts + directed), advancing the auto-cursor so a second read never redelivers.

Errors

Returns BoardError on storage failure.

pub fn claim(&self, agent: &str, path_glob: &str) -> Result<(), BoardError>

Claims a path glob for agent. Idempotent for the holder; a claim held by another agent in this run is a loud conflict.

Errors

Returns BoardError::BadGlob for an invalid glob, Storage for conflicts (constraint violation) and other database failures.

pub fn release(&self, agent: &str, path_glob: &str) -> Result<bool, BoardError>

Releases a claim; only the holder can release.

Errors

Returns BoardError on storage failure.

pub fn claims(&self) -> Result<Vec<Claim>, BoardError>

Active claims in this run.

Errors

Returns BoardError on storage failure.

pub fn blocking_holder( &self, agent: &str, file: &str, ) -> Result<Option<String>, BoardError>

The holder of a claim covering file, when that holder is not agent — i.e. the gate-side question “is this write blocked?”.

Errors

Returns BoardError on storage failure.