Struct mz_persist_client::cache::PersistClientCache

pub struct PersistClientCache { /* private fields */ }

A cache of PersistClients indexed by PersistLocations.

There should be at most one of these per process. All production PersistClients should be created through this cache.

This is because, in production, persist is heavily limited by the number of server-side Postgres/Aurora connections. This cache allows PersistClients to share, for example, these Postgres connections.

Implementations

impl PersistClientCache

pub fn new(cfg: PersistConfig, registry: &MetricsRegistry) -> Self

Returns a new PersistClientCache.

pub fn cfg(&self) -> &PersistConfig

Returns the PersistConfig being used by this cache.

pub async fn open(
    &self,
    location: PersistLocation
) -> Result<PersistClient, ExternalError>

Returns a new PersistClient for interfacing with persist shards made durable to the given PersistLocation.

The same location may be used concurrently from multiple processes.

Trait Implementations

impl Debug for PersistClientCache

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

Formats the value using the given formatter.