Struct Replica 

pub struct Replica { /* private fields */ }

One workspace root and its replica store.

Implementations

impl Replica

pub fn open(config: ReplicaConfig, clock: Arc<dyn Clock>) -> Result<Self>

pub fn replica_id(&self) -> ReplicaId

pub fn vv(&self) -> &VersionVector

pub fn config(&self) -> &ReplicaConfig

pub fn state(&self, path: &str) -> Result<Option<PathState>>

pub fn states(&self) -> Result<Vec<(String, PathState)>>

pub fn pause_reason(&self) -> Result<Option<PauseReason>>

Why this replica must not scan or apply right now. A root or marker that is missing while files were written would otherwise read as “everything deleted”.

pub fn scan(&mut self) -> Result<ScanOutcome>

Record every unrecorded edit under the root and finish pending writes.

pub fn delta_for(&self, peer: &VersionVector) -> Result<Vec<PathUpdate>>

Path states the peer with version vector peer has not merged.

pub fn apply( &mut self, updates: &[PathUpdate], source: &dyn ContentSource, ) -> Result<Report>

Join updates received from a peer, fetching content from source.

pub fn commit_session(&mut self, peer: &VersionVector) -> Result<()>

Declare that every update of a session with peer has been applied.

pub fn fetch_missing(&mut self, source: &dyn ContentSource) -> Result<Report>

Retry writes that were waiting for content.

pub fn read_content(&self, hash: &ContentHash) -> Result<Option<Vec<u8>>>

Bytes with hash from a file on disk or the staging directory.

Trait Implementations

impl ContentSource for Replica

fn fetch(&self, hash: &ContentHash) -> Option<Vec<u8>>