Struct mz_timestamp_oracle::postgres_oracle::PostgresTimestampOracleConfig

pub struct PostgresTimestampOracleConfig {
    url: SensitiveUrl,
    pub metrics: Arc<Metrics>,
    pub dynamic: Arc<DynamicConfig>,
}

Configuration to connect to a Postgres-backed implementation of TimestampOracle.

Fields

url: SensitiveUrl

metrics: Arc<Metrics>

dynamic: Arc<DynamicConfig>

Configurations that can be dynamically updated.

Implementations

impl PostgresTimestampOracleConfig

pub(crate) const EXTERNAL_TESTS_POSTGRES_URL: &'static str = "COCKROACH_URL"

pub fn new(url: &SensitiveUrl, metrics_registry: &MetricsRegistry) -> Self

Returns a new instance of PostgresTimestampOracleConfig with default tuning.

pub fn new_for_test() -> Option<Self>

Returns a new PostgresTimestampOracleConfig for use in unit tests.

By default, postgres oracle tests are no-ops so that cargo test works on new environments without any configuration. To activate the tests for PostgresTimestampOracle set the COCKROACH_URL environment variable with a valid connection url 1.

Trait Implementations

impl Clone for PostgresTimestampOracleConfig

fn clone(&self) -> PostgresTimestampOracleConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresTimestampOracleConfig

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

Formats the value using the given formatter.

impl From<PostgresTimestampOracleConfig> for PostgresClientConfig

fn from(config: PostgresTimestampOracleConfig) -> Self

Converts to this type from the input type.

impl PostgresClientKnobs for PostgresTimestampOracleConfig

fn connection_pool_max_size(&self) -> usize

Maximum number of connections allowed in a pool.

fn connection_pool_max_wait(&self) -> Option<Duration>

The maximum time to wait to obtain a connection, if any.

fn connection_pool_ttl(&self) -> Duration

Minimum TTL of a connection. It is expected that connections are routinely culled to balance load to the backing store.

fn connection_pool_ttl_stagger(&self) -> Duration

Minimum time between TTLing connections. Helps stagger reconnections to avoid stampeding the backing store.

fn connect_timeout(&self) -> Duration

Time to wait for a connection to be made before trying.

fn tcp_user_timeout(&self) -> Duration

TCP user timeout for connection attempts.