Struct SyncNode 

pub struct SyncNode { /* private fields */ }

Implementations

impl SyncNode

pub async fn start(store: Arc<Mutex<Store>>) -> Result<Arc<Self>>

Bind an endpoint and start serving. Identity is persisted, so a restart rejoins as the same peer with the same ticket.

pub fn ticket(&self) -> Ticket

pub fn peer_ids(&self) -> Vec<EndpointId>

pub fn join(&self, ticket: &Ticket) -> Result<()>

Adopt a ticket: remember the peer and, since the room key names the group, switch to theirs.

Joining is deliberately one-way — the joiner moves to the host’s room rather than negotiating — so “I sent you a ticket” has an unambiguous result.

pub async fn run(self: Arc<Self>, notify: Arc<Notify>)

Background driver: sync on every local change, and on a timer so peers that were offline still catch up.

pub async fn sync_all(&self)

pub async fn sync_with(&self, peer: EndpointId) -> Result<usize>

Dial a peer and run one full exchange. Returns how many entries this replica took from them.