Struct LwwElementSet 

pub struct LwwElementSet { /* private fields */ }

LWW-Element-Set for synchronizing workflow YAML across peers.

Each workflow ID maps to an LwwEntry. When merging, the entry with the higher timestamp wins; ties are broken by peer ID ordering.

Implementations

impl LwwElementSet

pub fn new(local_peer: Uuid, resolution: ConflictResolution) -> Self

Create a new empty LWW-Element-Set for the given peer.

pub fn set(&mut self, workflow_id: &str, yaml: &str) -> LwwEntry

Insert or update a workflow YAML value.

pub fn remove(&mut self, workflow_id: &str) -> Option<LwwEntry>

Remove a workflow (add to tombstone set).

pub fn get(&self, workflow_id: &str) -> Option<&LwwEntry>

Get the current value for a workflow.

pub fn workflows(&self) -> Vec<String>

List all active (non-removed) workflow IDs.

pub fn merge( &mut self, workflow_id: &str, remote: &LwwEntry, ) -> (LwwEntry, Option<SyncConflict>)

Merge a remote entry for a given workflow ID. Returns the winning entry and any conflict detected.

pub fn merge_set(&mut self, remote_set: &LwwElementSet) -> Vec<SyncConflict>

Merge an entire remote element set into the local one.

Trait Implementations

impl Clone for LwwElementSet

fn clone(&self) -> LwwElementSet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LwwElementSet

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LwwElementSet

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for LwwElementSet

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TeamSync for LwwElementSet

fn push(&self, workflow_id: &str, _yaml: &str) -> Result<SyncState>

Push local changes to peers.

fn pull(&self, workflow_id: &str) -> Result<(String, SyncState)>

Pull and merge remote changes.

fn state(&self, workflow_id: &str) -> Result<SyncState>

Get the current sync state for a workflow.

fn resolve_conflict( &self, workflow_id: &str, _resolution: &ConflictResolution, ) -> Result<String>

Resolve a conflict using the configured strategy.

fn local_peer_id(&self) -> Uuid

Get this node’s unique peer identifier.