Struct MigrationCoordinator 

pub struct MigrationCoordinator { /* private fields */ }

Coordinates connection migration from relay to direct path

Implementations

impl MigrationCoordinator

pub fn new(config: MigrationConfig) -> Self

Create a new migration coordinator

pub fn stats(&self) -> Arc<MigrationStats>

Get statistics

pub async fn set_relay(&self, relay: SocketAddr)

Set the relay address for this coordinator

pub async fn state(&self, peer: SocketAddr) -> MigrationState

Get current migration state for a peer

pub async fn add_candidates(&self, peer: SocketAddr, addrs: Vec<SocketAddr>)

Register candidate addresses for a peer

pub async fn start_migration(&self, peer: SocketAddr)

Start migration attempt for a peer

pub async fn poll(&self, peer: SocketAddr) -> MigrationState

Poll migration progress - should be called periodically

pub async fn report_validated_path( &self, peer: SocketAddr, path: SocketAddr, rtt: Duration, )

Report a validated path (called when PATH_RESPONSE received)

pub async fn complete_migration(&self, peer: SocketAddr)

Complete migration to direct path

pub async fn fallback_to_relay(&self, peer: SocketAddr, reason: &str)

Force fallback to relay

pub async fn reset(&self, peer: SocketAddr)

Reset migration state for a peer

pub async fn migrating_peers(&self) -> Vec<SocketAddr>

Get all peers currently migrating

pub async fn direct_peers(&self) -> Vec<SocketAddr>

Get all peers with direct paths

Trait Implementations

impl Debug for MigrationCoordinator

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

Formats the value using the given formatter.