Struct mz_postgres_util::Config
source · pub struct Config {
pub(crate) inner: Config,
pub(crate) tunnel: TunnelConfig,
}
Expand description
Configuration for PostgreSQL connections.
This wraps tokio_postgres::Config
to allow the configuration of a
tunnel via a TunnelConfig
.
Fields§
§inner: Config
§tunnel: TunnelConfig
Implementations§
source§impl Config
impl Config
pub fn new(inner: Config, tunnel: TunnelConfig) -> Result<Self, PostgresError>
sourcepub async fn connect(&self, task_name: &str) -> Result<Client, PostgresError>
pub async fn connect(&self, task_name: &str) -> Result<Client, PostgresError>
Connects to the configured PostgreSQL database.
sourcepub async fn connect_replication(&self) -> Result<Client, PostgresError>
pub async fn connect_replication(&self) -> Result<Client, PostgresError>
Starts a replication connection to the configured PostgreSQL database.
pub(crate) fn address(&self) -> Result<(&str, u16), PostgresError>
pub(crate) async fn connect_internal<F>(
&self,
task_name: &str,
configure: F
) -> Result<Client, PostgresError>where
F: FnOnce(&mut Config),
Trait Implementations§
source§impl PartialEq<Config> for Config
impl PartialEq<Config> for Config
impl StructuralPartialEq for Config
Auto Trait Implementations§
impl RefUnwindSafe for Config
impl Send for Config
impl Sync for Config
impl Unpin for Config
impl UnwindSafe for Config
Blanket Implementations§
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
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
.