Struct QuorumStore 

pub struct QuorumStore { /* private fields */ }

File-backed quorum episode/result store.

Implementations

impl QuorumStore

pub fn new(root: impl AsRef<Path>) -> Self

Create a quorum store rooted at root.

pub fn create_episode( &self, episode: &QuorumEpisode, ) -> Result<PathBuf, LibrarianError>

Write an episode envelope.

Errors

Returns I/O or JSON serialization errors.

pub fn load_episode(&self, id: &str) -> Result<QuorumEpisode, LibrarianError>

Load a quorum episode by id.

Errors

Returns I/O or JSON decoding errors.

pub fn save_result( &self, result: &QuorumResult, ) -> Result<PathBuf, LibrarianError>

Write the synthesized result for an episode.

Errors

Returns I/O or JSON serialization errors.

pub fn load_result( &self, episode_id: &str, ) -> Result<QuorumResult, LibrarianError>

Load the synthesized result for an episode.

Errors

Returns I/O or JSON decoding errors.

pub fn result_artifact_path(&self, episode_id: &str) -> PathBuf

Return the canonical result artifact path for an episode.

pub fn append_participant_output( &self, output: &QuorumParticipantOutput, ) -> Result<PathBuf, LibrarianError>

Append one participant output for a deliberation round.

Errors

Returns I/O, JSON serialization, duplicate-output, or protocol errors.

pub fn load_round_outputs( &self, episode_id: &str, round: QuorumRound, ) -> Result<Vec<QuorumParticipantOutput>, LibrarianError>

Load all participant outputs for one round.

Errors

Returns I/O or JSON decoding errors.

pub fn visible_outputs_for_round( &self, episode_id: &str, round: QuorumRound, ) -> Result<Vec<QuorumParticipantOutput>, LibrarianError>

Return the prior outputs that may be shown to a participant in round.

Errors

Returns a protocol error until the prior round is complete.

pub fn build_adapter_request( &self, episode_id: &str, participant_id: &str, round: QuorumRound, ) -> Result<QuorumAdapterRequest, LibrarianError>

Build the JSON request contract a participant adapter should consume.

Errors

Returns I/O, JSON decoding, or protocol errors when the participant is unknown or prior-round visibility is not available yet.

Trait Implementations

impl Clone for QuorumStore

fn clone(&self) -> QuorumStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QuorumStore

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

Formats the value using the given formatter.

impl PartialEq for QuorumStore

fn eq(&self, other: &QuorumStore) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for QuorumStore

impl StructuralPartialEq for QuorumStore