Struct Libp2pSyncNode 

pub struct Libp2pSyncNode {
    pub peer_id: PeerId,
    /* private fields */
}

A running libp2p sync node. Spawn it on a tokio runtime; drive it with the async methods.

Fields

peer_id: PeerId

Implementations

impl Libp2pSyncNode

pub fn spawn(relay: SyncOpRelay) -> Self

Spawn a node on the current tokio runtime, serving relay to inbound peers.

pub async fn listen(&self, addr: &str) -> Result<Multiaddr, String>

Listen on addr (e.g. /ip4/127.0.0.1/tcp/0), returning the actual bound multiaddr.

pub fn add_peer(&self, peer: PeerId, addr: Multiaddr)

Teach this node a peer’s address so publish/pull can reach (and auto-dial) it.

pub async fn publish( &self, peer: PeerId, frames: Vec<Vec<u8>>, ) -> Result<u64, String>

Publish opaque signed-op frames to peer; returns how many were newly accepted.

pub async fn pull( &self, peer: PeerId, since: u64, ) -> Result<(Vec<Vec<u8>>, u64), String>

Pull peer’s frames after since; returns them plus the next cursor.