Struct Replica 

pub struct Replica<C: Crdt> { /* private fields */ }

Owned state and admitted history. A nonempty initial state need not be reproducible from its initially empty log.

Implementations

impl<C: Crdt> Replica<C>

pub fn new(state: C) -> Self

pub fn state(&self) -> &C

pub fn log(&self) -> &EventLog<C::Delta>

pub fn version(&self) -> &VersionVector

pub fn since(&self, peer: &VersionVector) -> Vec<Record<C::Delta>>

where C::Delta: Clone,

pub fn admit(&mut self, record: Record<C::Delta>) -> Admission

where C::Delta: Clone + PartialEq,

A Collision verdict also raises the collision alarm; see Self::collisions and Self::collision_report_bytes.

pub fn append( &mut self, author: u64, delta: C::Delta, ) -> Result<Record<C::Delta>, ReplicaError>

where C::Delta: Clone + PartialEq,

pub fn inspect_record_bytes( bytes: &[u8], limits: CollectionLimits, ) -> Result<Record<C::Delta>, ReplicaError>

where C::Delta: WireDecode,

Decode only; no admission validation or mutation.

pub fn merge_record_bytes( &mut self, bytes: &[u8], limits: CollectionLimits, ) -> Result<Admission, ReplicaError>

where C::Delta: Clone + PartialEq + WireDecode,

pub fn decode_log_bytes( &self, bytes: &[u8], limits: DecodeLimits, ) -> Result<Vec<Record<C::Delta>>, ReplicaError>

where C::Delta: Clone + PartialEq + WireDecode + WireSchema,

Validate the complete batch and preserve every input occurrence.

pub fn merge_log_bytes( &mut self, bytes: &[u8], limits: DecodeLimits, ) -> Result<Vec<Admission>, ReplicaError>

where C::Delta: Clone + PartialEq + WireDecode + WireSchema,

pub fn log_bytes(&self) -> Result<Vec<u8>, ReplicaError>

where C::Delta: WireEncode + WireSchema,

pub fn restore( state: C, bytes: &[u8], limits: DecodeLimits, ) -> Result<Self, ReplicaError>

where C::Delta: Clone + PartialEq + WireDecode + WireSchema,

Supply a matching empty/bottom state. Publish only a fully checked candidate.

pub fn collisions(&self) -> Vec<RecordCollision<C::Delta>>

where C::Delta: Clone,

Held record IDs a peer holds with a different payload, raised when a peer’s offer collided here or a peer’s report named one. In memory only; Self::restore starts with none.

pub fn collision_report_bytes(&self) -> Result<Option<Vec<u8>>, ReplicaError>

where C::Delta: Clone + WireEncode + WireSchema,

The collision report to send back to a peer after merging its batch, or None when no alarm is raised here.

pub fn merge_collision_report_bytes( &mut self, bytes: &[u8], limits: DecodeLimits, ) -> Result<Vec<(RecordId, CollisionVerdict)>, ReplicaError>

where C::Delta: PartialEq + WireDecode + WireSchema,

Merge a peer’s collision report; one verdict per entry, in order. Only the alarm can change: never the records, version or state.