Struct Peer 

pub struct Peer<L: BucketLogProvider> { /* private fields */ }

Overview of a peer’s state, generic over a bucket log provider. Provides everything that a peer needs in order to load data, interact with peers, and manage buckets.

Implementations

impl<L: BucketLogProvider> Peer<L>

pub fn logs(&self) -> &L

pub fn blobs(&self) -> &BlobsStore

pub fn endpoint(&self) -> &Endpoint

pub fn log_provider(&self) -> &L

pub fn secret(&self) -> &SecretKey

pub fn socket(&self) -> &SocketAddr

pub fn id(&self) -> NodeId

pub async fn dispatch(&self, job: SyncJob) -> Result<()>

where L::Error: Error + Send + Sync + 'static,

Dispatch a sync job to the sync provider

The provider decides when/where this executes (immediately, queued, etc.)

pub async fn ping(&self, bucket_id: Uuid) -> Result<()>

where L::Error: Error + Send + Sync + 'static,

Ping all peers in a bucket’s shares

Dispatches ping jobs to all peers listed in the bucket’s current manifest shares (except ourselves).

pub async fn ping_and_collect( &self, bucket_id: Uuid, timeout: Option<Duration>, ) -> Result<HashMap<String, PingReplyStatus>>

where L::Error: Error + Send + Sync + 'static,

Ping all peers for a bucket and collect their responses

Returns a map of peer public key hex to their ping reply status. This waits for all pings to complete before returning.

Arguments

• bucket_id - The bucket to ping peers for
• timeout - Optional timeout duration for the entire operation

pub async fn mount(&self, bucket_id: Uuid) -> Result<Mount, MountError>

Load mount at the current head of a bucket

Arguments

• bucket_id - The UUID of the bucket to load

Returns

The Mount at the current head of the bucket’s log

Errors

Returns error if:

• Bucket not found in log
• Failed to load mount from blobs

pub async fn mount_for_read(&self, bucket_id: Uuid) -> Result<Mount, MountError>

Load mount for reading based on the peer’s role in the bucket.

This method determines the appropriate version to load based on the peer’s role:

• Owners see HEAD (latest state, including unpublished changes)
• Mirrors (or unknown roles) see the latest_published version

This ensures that mirrors only see content that has been explicitly published to them, while owners always see the most recent state.

Arguments

• bucket_id - The UUID of the bucket to load

Returns

The Mount at the appropriate version for this peer’s role

Errors

Returns error if:

• Bucket not found in log
• No published version available (for mirrors)
• Failed to load mount from blobs

pub async fn save_mount( &self, mount: &Mount, publish: bool, ) -> Result<Link, MountError>

where L::Error: Error + Send + Sync + 'static,

Save a mount and append it to the bucket’s log

This method:

1. Saves the mount to blobs, getting a new link
2. Appends the new link to the bucket’s log
3. Dispatches sync jobs to notify peers

Arguments

• mount - The mount to save
• publish - If true, publish the bucket (expose the secret so mirrors can decrypt)

Returns

The new link where the mount was saved

Errors

Returns error if:

• Failed to save mount to blobs
• Failed to append to log

Trait Implementations

impl<L> Clone for Peer<L>

where L: Clone + BucketLogProvider,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<L: Debug + BucketLogProvider> Debug for Peer<L>

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

Formats the value using the given formatter.

impl<L> ProtocolHandler for Peer<L>

where L: BucketLogProvider, L::Error: Error + Send + Sync + 'static,

fn accept( &self, conn: Connection, ) -> BoxFuture<'static, Result<(), AcceptError>>

Handle an incoming connection.

fn on_connecting( &self, connecting: Connecting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Connecting state.

fn shutdown(&self) -> impl Future<Output = ()> + Send

Called when the router shuts down.