Struct PathOpLog 

pub struct PathOpLog { /* private fields */ }

The path operation log - an operation-based CRDT

This is a grow-only set of operations with causal ordering. Conflict resolution is deterministic based on:

1. Lamport timestamp (higher wins for concurrent ops on same path)
2. Peer ID (lexicographic tie-breaker)

Implementations

impl PathOpLog

pub fn new() -> Self

Create a new empty log

pub fn from_operation(op: &PathOperation) -> Self

Create a log containing a single operation

pub fn rebuild_clock(&mut self)

Rebuild local clock from operations (call after deserialization)

pub fn record( &mut self, peer_id: PublicKey, op_type: OpType, path: impl Into<PathBuf>, content_link: Option<Link>, is_dir: bool, ) -> OpId

Record a new local operation

The peer_id identifies who is recording this operation. Returns the OpId of the recorded operation.

pub fn merge(&mut self, other: &PathOpLog) -> usize

Merge operations from another log (CRDT merge)

Returns the number of new operations added

pub fn merge_with_resolver( &mut self, other: &PathOpLog, resolver: &dyn ConflictResolver, local_peer: &PublicKey, ) -> MergeResult

Merge operations from another log with conflict resolution

Unlike the basic merge(), this method:

1. Detects conflicts between local and incoming operations
2. Uses the provided resolver to decide how to handle each conflict
3. Returns detailed information about what conflicts were found and resolved

Arguments

• other - The incoming log to merge
• resolver - The conflict resolution strategy to use
• local_peer - The local peer’s identity (for tie-breaking)

Returns

A MergeResult containing:

• Number of operations added
• List of resolved conflicts
• List of unresolved conflicts (when using ForkOnConflict)

pub fn operations(&self) -> &BTreeMap<OpId, PathOperation>

Get all operations

pub fn resolve_path(&self, path: impl AsRef<Path>) -> Option<&PathOperation>

Resolve the current state of a path

Returns the winning operation for the path (if any). The operation with the highest OpId wins.

pub fn resolve_all(&self) -> BTreeMap<PathBuf, &PathOperation>

Resolve the entire filesystem state from operations

Returns a map of path -> winning operation for all paths that currently exist (excludes paths where Remove was the winning op)

pub fn len(&self) -> usize

Get the number of operations

pub fn is_empty(&self) -> bool

Check if empty

pub fn clear_preserving_clock(&mut self)

Clear operations but preserve the local clock value.

This is used after persisting operations to a manifest. We clear the operations (since they’re now saved) but keep the clock so future operations have unique timestamps across save cycles.

pub fn ops_for_path(&self, path: impl AsRef<Path>) -> Vec<&PathOperation>

Get operations affecting a specific path, in order

pub fn ops_in_order(&self) -> impl Iterator<Item = &PathOperation>

Get all operations in order (oldest to newest)

Trait Implementations

impl BlockEncoded<DagCborCodec> for PathOpLog

fn encode(&self) -> Result<Vec<u8>, CodecError>

fn decode(data: &[u8]) -> Result<Self, CodecError>

fn codec(&self) -> u64

impl Clone for PathOpLog

fn clone(&self) -> PathOpLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PathOpLog

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

Formats the value using the given formatter.

impl Default for PathOpLog

fn default() -> PathOpLog

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PathOpLog

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for PathOpLog

fn eq(&self, other: &PathOpLog) -> 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 Serialize for PathOpLog

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PathOpLog