Struct CrossClusterLink 

pub struct CrossClusterLink {
    pub throttle: SendThrottle,
    /* private fields */
}

Cross-cluster QUIC link from a mirror to its source cluster.

Manages connection establishment, cluster-id authentication, exponential backoff reconnect, and per-mirror bytes-in-flight throttle.

Fields

throttle: SendThrottle

Bytes-in-flight throttle shared with the snapshot / log sender.

Implementations

impl CrossClusterLink

pub fn new( source_cluster_id: String, source_database_id: String, source_addr: SocketAddr, endpoint: Endpoint, client_config: ClientConfig, throttle: SendThrottle, ) -> Self

Create a new (disconnected) link.

Call connect to open the initial connection.

pub fn source_cluster_id(&self) -> &str

The source cluster-id this link is targeting.

pub async fn connect( &self, last_applied_lsn: u64, ) -> Result<MirrorHelloAck, MirrorError>

Establish the initial QUIC connection and run the cross-cluster handshake. Returns the MirrorHelloAck on success.

If the source rejects the connection (cluster-id mismatch, observer violation, etc.) this returns a MirrorError immediately — no backoff is applied, because these are hard-configuration errors that won’t be fixed by retrying.

pub async fn open_bidi_stream( &self, ) -> Result<(SendStream, RecvStream), MirrorError>

Open a new QUIC bidi stream on the existing connection.

Returns an error when the link is in Disconnected state; the caller should call schedule_reconnect first.

pub async fn schedule_reconnect( &self, last_applied_lsn: u64, ) -> Result<MirrorHelloAck, MirrorError>

Reconnect with exponential backoff after a disconnect.

Drives the following sequence:

1. Mark link as Disconnected, reset throttle.
2. Sleep for the current backoff duration.
3. Dial + handshake.
4. On success, mark Connected and return the ack.
5. On failure, double the delay (capped at RECONNECT_MAX_MS) and repeat from step 2.