Struct mz_postgres_client::PostgresClient
source · pub struct PostgresClient {
pub(crate) pool: Pool,
pub(crate) metrics: PostgresClientMetrics,
}
Expand description
A Postgres client wrapper that uses deadpool as a connection pool.
Fields§
§pool: Pool
§metrics: PostgresClientMetrics
Implementations§
source§impl PostgresClient
impl PostgresClient
sourcepub fn open(config: PostgresClientConfig) -> Result<Self, PostgresError>
pub fn open(config: PostgresClientConfig) -> Result<Self, PostgresError>
Open a PostgresClient using the given config
.
pub(crate) fn status_metrics(&self, status: Status)
sourcepub async fn get_connection(&self) -> Result<Object, PoolError>
pub async fn get_connection(&self) -> Result<Object, PoolError>
Gets connection from the pool or waits for one to become available.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for PostgresClient
impl !RefUnwindSafe for PostgresClient
impl Send for PostgresClient
impl Sync for PostgresClient
impl Unpin for PostgresClient
impl !UnwindSafe for PostgresClient
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