Struct mz_persist::postgres::PostgresConsensusConfig
source · pub struct PostgresConsensusConfig { /* private fields */ }
Expand description
Configuration to connect to a Postgres backed implementation of Consensus.
Implementations§
source§impl PostgresConsensusConfig
impl PostgresConsensusConfig
sourcepub fn new(
url: &str,
knobs: Box<dyn PostgresClientKnobs>,
metrics: PostgresClientMetrics
) -> Result<Self, Error>
pub fn new( url: &str, 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 !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> 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
.