Struct CoordinatorClient 

pub struct CoordinatorClient { /* private fields */ }

A coordinator client wrapper with automatic reconnection.

This wrapper maintains a connection to the coordinator and automatically attempts to reconnect if the connection is lost.

Implementations

impl CoordinatorClient

pub fn new(addr: SocketAddr) -> Self

Create a new coordinator client.

This does not establish a connection immediately; the connection is created lazily on the first call to get.

pub fn with_config(addr: SocketAddr, config: ClientConfig) -> Self

Create a new coordinator client with custom configuration.

pub async fn get(&self) -> Result<CoordinatorServiceClient, Error>

Get the coordinator client, creating a connection if needed.

pub async fn reconnect(&self) -> Result<CoordinatorServiceClient, Error>

Force a reconnection.

Useful after detecting a connection failure.

pub async fn invalidate(&self)

Invalidate the cached connection without reconnecting.

pub fn addr(&self) -> SocketAddr

Get the coordinator’s address.

Trait Implementations

impl Clone for CoordinatorClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.