Struct RemoteSync 

pub struct RemoteSync { /* private fields */ }

Manages subscription tracking and restore for remote (non-peer) connections.

Event-driven interface used by the message processor:

• on_forwarded_subscription: a sub was sent to a remote conn
• on_connection_drop: a remote connection was lost
• get_subscriptions_for_reconnect: snapshot before client reconnect
• restore: replay subscriptions after reconnect

Implementations

impl RemoteSync

pub fn on_forwarded_subscription( &self, source: ProtoName, name: ProtoName, source_identity: String, conn: u64, add: bool, subscription_id: u64, )

Record that a subscription was forwarded (or unforwarded) on a remote connection.

pub fn on_connection_drop(&self, conn: u64) -> HashSet<SubscriptionInfo>

A remote connection dropped — remove and return its tracked subscriptions.

pub fn get_subscriptions_for_reconnect( &self, conn: u64, ) -> HashSet<SubscriptionInfo>

Snapshot the subscriptions forwarded on a connection (for client-side reconnect). Unlike on_connection_drop, this does NOT remove them from the table.

pub async fn restore( &self, mp: &MessageProcessor, remote_subs: &HashSet<SubscriptionInfo>, conn_index: u64, restore_tracking: bool, )

Re-send previously-forwarded subscriptions to a remote connection after reconnect.

When restore_tracking is true, also re-registers each subscription in the tracking table.

When restore_tracking is false (client-side reconnect), the tracking table was never cleaned (reconnect reuses the same slot), so no re-registration is needed.

Trait Implementations

impl Debug for RemoteSync

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

Formats the value using the given formatter.

impl Default for RemoteSync

fn default() -> RemoteSync

Returns the “default value” for a type.