Struct mz_persist::postgres::PostgresConsensusConfig
source · pub struct PostgresConsensusConfig {
url: SensitiveUrl,
knobs: Arc<dyn PostgresClientKnobs>,
metrics: PostgresClientMetrics,
}
Expand description
Configuration to connect to a Postgres backed implementation of Consensus.
Fields§
§url: SensitiveUrl
§knobs: Arc<dyn PostgresClientKnobs>
§metrics: PostgresClientMetrics
Implementations§
source§impl PostgresConsensusConfig
impl PostgresConsensusConfig
const EXTERNAL_TESTS_POSTGRES_URL: &'static str = "MZ_PERSIST_EXTERNAL_STORAGE_TEST_POSTGRES_URL"
sourcepub fn new(
url: &SensitiveUrl,
knobs: Box<dyn PostgresClientKnobs>,
metrics: PostgresClientMetrics,
) -> Result<Self, Error>
pub fn new( url: &SensitiveUrl, knobs: Box<dyn PostgresClientKnobs>, metrics: PostgresClientMetrics, ) -> Result<Self, Error>
Returns a new PostgresConsensusConfig for use in production.
sourcepub fn new_for_test() -> Result<Option<Self>, Error>
pub fn new_for_test() -> Result<Option<Self>, Error>
Returns a new PostgresConsensusConfig for use in unit tests.
By default, persist tests that use external storage (like Postgres) are
no-ops so that cargo test
works on new environments without any
configuration. To activate the tests for PostgresConsensus set the
MZ_PERSIST_EXTERNAL_STORAGE_TEST_POSTGRES_URL
environment variable
with a valid connection url 1.
Trait Implementations§
source§impl Clone for PostgresConsensusConfig
impl Clone for PostgresConsensusConfig
source§fn clone(&self) -> PostgresConsensusConfig
fn clone(&self) -> PostgresConsensusConfig
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for PostgresConsensusConfig
impl Debug for PostgresConsensusConfig
source§impl From<PostgresConsensusConfig> for PostgresClientConfig
impl From<PostgresConsensusConfig> for PostgresClientConfig
source§fn from(config: PostgresConsensusConfig) -> Self
fn from(config: PostgresConsensusConfig) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl Freeze for PostgresConsensusConfig
impl !RefUnwindSafe for PostgresConsensusConfig
impl Send for PostgresConsensusConfig
impl Sync for PostgresConsensusConfig
impl Unpin for PostgresConsensusConfig
impl !UnwindSafe for PostgresConsensusConfig
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T> ProgressEventTimestamp for T
impl<T> ProgressEventTimestamp for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.