Struct DurableInterfaceStore 

pub struct DurableInterfaceStore { /* private fields */ }

Filesystem-backed content-addressed store for interface artifacts.

Implementations

impl DurableInterfaceStore

pub fn verify_manifest( &self, manifest: &DistributedInterfaceManifest, limits: CertificateLimits, ) -> Result<RelativeInterfaceCertificate, DistributedInterfaceError>

Recompute every fold and verify a committed manifest from stored shards.

Ignores durable progress. Checks that every recorded fold and the final result follow from the ordered shard artifacts.

impl DurableInterfaceStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, DistributedInterfaceError>

Open or create a store rooted at path.

pub fn put( &self, bytes: &[u8], ) -> Result<(ArtifactId, bool), DistributedInterfaceError>

Store exact bytes and return their content identifier.

pub fn get( &self, id: ArtifactId, maximum_bytes: usize, ) -> Result<Vec<u8>, DistributedInterfaceError>

Read an object and check its identifier.

pub fn contains(&self, id: ArtifactId) -> bool

Whether an object path exists. This does not read or verify the bytes.

pub fn commit( &self, shard_artifacts: &[Vec<u8>], separator_vertices: &[usize], output_protected_vertices: &[usize], limits: CertificateLimits, ) -> Result<DistributedInterfaceCommit, DistributedInterfaceError>

Compose shard artifacts and publish one atomic manifest.

Shards are ordered. Every intermediate fold protects the union of separator_vertices and output_protected_vertices. A retry resumes from the last durable fold for the same content-bound job.

pub fn commit_stored( &self, shard_ids: &[ArtifactId], separator_vertices: &[usize], output_protected_vertices: &[usize], limits: CertificateLimits, ) -> Result<DistributedInterfaceCommit, DistributedInterfaceError>

Compose shards already present in this store.

The coordinator loads at most one shard and one accumulator artifact for each fold. The identifiers are ordered and bind the job.

pub fn manifest( &self, job: ArtifactId, maximum_bytes: usize, ) -> Result<DistributedInterfaceManifest, DistributedInterfaceError>

Read a committed manifest by job identifier.

Trait Implementations

impl Clone for DurableInterfaceStore

fn clone(&self) -> DurableInterfaceStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DurableInterfaceStore

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

Formats the value using the given formatter.