Struct ReplicationReplicaClient 

pub struct ReplicationReplicaClient { /* private fields */ }

Handle to a replica’s TCP connector thread.

Implementations

impl ReplicationReplicaClient

pub fn start(config: ReplicationConfig) -> Result<Self>

Starts a replica that connects to config.replica_of, bootstraps via snapshot or backlog, and streams live mutations.

pub fn replica(&self) -> Arc<Mutex<ReplicationReplica>>

Returns the live replica handle. Holds a mutex while in use, so prefer short, read-only operations.

pub fn shutdown(&self) -> Result<()>

Trait Implementations

impl Debug for ReplicationReplicaClient

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

Formats the value using the given formatter.

impl Drop for ReplicationReplicaClient

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.