Struct CorrosionPooledClient 

pub struct CorrosionPooledClient { /* private fields */ }

Client to connect to a pool of Corrosion nodes.

Selects the first address from the list and tries to connect to it. On I/O errors the client falls back to the next address; once a request succeeds the client “sticks” to that peer until it has been failing continuously for the configured stickiness_timeout.

Implementations

impl CorrosionPooledClient

pub fn new( addrs: Vec<String>, stickiness_timeout: Duration, resolver: Resolver<TokioRuntimeProvider>, ) -> Self

Build a new pooled client.

• addrs — ordered list of agent addresses. Each entry can be either a host:port string (resolved through resolver) or an already resolved SocketAddr formatted as a string. Entries are tried in the supplied order; once a peer has been successful the client prefers it for as long as it stays healthy.
• stickiness_timeout — how long the client keeps retrying a previously successful peer after it starts failing before rotating to the next address.
• resolver — DNS resolver used to translate hostnames to addresses.

pub async fn query_typed<T: DeserializeOwned + Unpin>( &self, statement: &Statement, timeout: Option<u64>, ) -> Result<QueryStream<T>, Error>

Run a one-shot query against the currently selected peer.

Equivalent to CorrosionApiClient::query_typed

pub async fn subscribe_typed<T: DeserializeOwned + Unpin>( &self, statement: &Statement, skip_rows: bool, from: Option<ChangeId>, ) -> Result<SubscriptionStream<T>, Error>

Open a new subscription against the currently selected peer.

pub async fn subscription_typed<T: DeserializeOwned + Unpin>( &self, id: Uuid, skip_rows: bool, from: Option<ChangeId>, ) -> Result<SubscriptionStream<T>, Error>

Reconnect to an existing subscription by id against the currently selected peer. See CorrosionApiClient::subscription_typed.

Trait Implementations

impl Clone for CorrosionPooledClient

fn clone(&self) -> CorrosionPooledClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.