Struct TaskListSync 

pub struct TaskListSync { /* private fields */ }

Synchronization wrapper for a TaskList.

Manages automatic background synchronization of a TaskList using anti-entropy gossip. Changes are propagated via deltas published to a gossip topic.

Implementations

impl TaskListSync

pub fn new( task_list: TaskList, pubsub: Arc<PubSubManager>, topic: String, sync_interval_secs: u64, ) -> Result<Self>

Create a new TaskList synchronization manager.

Arguments

• task_list - The TaskList to synchronize
• pubsub - Pub/sub manager for gossip messaging
• topic - Topic name for pub/sub (typically task list ID)
• sync_interval_secs - How often to run anti-entropy (seconds)

Returns

A new TaskListSync instance ready to start.

Errors

Returns an error if initialization fails.

Example

let task_list = TaskList::new(id, "My List".to_string(), peer_id);
let sync = TaskListSync::new(
    task_list,
    pubsub,
    "tasklist-abc123".to_string(),
    30, // Sync every 30 seconds
)?;

pub async fn start(&self) -> Result<()>

Start background synchronization.

Subscribes to the gossip topic and begins receiving remote deltas. This method returns immediately; synchronization runs in the background.

Returns

Ok(()) if started successfully.

Errors

Returns an error if subscription or anti-entropy startup fails.

pub async fn stop(&self) -> Result<()>

Stop background synchronization.

Unsubscribes from the gossip topic.

Returns

Ok(()) if stopped successfully.

Errors

Returns an error if operations fail.

pub async fn apply_remote_delta( &self, peer_id: PeerId, delta: TaskListDelta, ) -> Result<()>

Apply a delta received from a remote peer.

This is called when a delta is received via the gossip topic. The delta is merged into the local TaskList using CRDT semantics.

Arguments

• peer_id - The peer who sent this delta
• delta - The delta to apply

Returns

Ok(()) if the delta was applied successfully.

Errors

Returns an error if the merge fails.

pub async fn publish_delta( &self, local_peer_id: PeerId, delta: TaskListDelta, ) -> Result<()>

Publish a local delta to the gossip network.

Call this after making local changes to propagate them to other peers.

Arguments

• local_peer_id - The local peer’s ID
• delta - The delta to publish

Returns

Ok(()) if published successfully.

Errors

Returns an error if serialization or publishing fails.

pub async fn read(&self) -> RwLockReadGuard<'_, TaskList>

Get a read-only reference to the task list.

Useful for querying the current state without modifying it.

Returns

A read guard to the TaskList.

pub async fn write(&self) -> RwLockWriteGuard<'_, TaskList>

Get a mutable reference to the task list.

Use this to make local changes. After modifying, call publish_delta to propagate changes to peers.

Returns

A write guard to the TaskList.

pub fn topic(&self) -> &str

Get the topic name for this task list.