Struct mz_stash::postgres::StashFactory
source · Fields§
§metrics: Arc<Metrics>
Implementations§
source§impl StashFactory
impl StashFactory
pub fn new(registry: &MetricsRegistry) -> StashFactory
sourcepub async fn open(
&self,
url: String,
schema: Option<String>,
tls: MakeTlsConnector
) -> Result<Stash, StashError>
pub async fn open(
&self,
url: String,
schema: Option<String>,
tls: MakeTlsConnector
) -> Result<Stash, StashError>
Opens the stash stored at the specified path.
sourcepub async fn open_readonly(
&self,
url: String,
schema: Option<String>,
tls: MakeTlsConnector
) -> Result<Stash, StashError>
pub async fn open_readonly(
&self,
url: String,
schema: Option<String>,
tls: MakeTlsConnector
) -> Result<Stash, StashError>
Opens the stash stored at the specified path in readonly mode: any mutating query will fail, and the epoch is not incremented on start.
sourcepub async fn open_savepoint(
&self,
url: String,
tls: MakeTlsConnector
) -> Result<Stash, StashError>
pub async fn open_savepoint(
&self,
url: String,
tls: MakeTlsConnector
) -> Result<Stash, StashError>
Opens the stash stored at the specified path in savepoint mode: mutating queries are allowed, but they will never be committed, and the epoch is not incremented on start. This mode is used to test migrations on a running stash.
async fn open_inner(
&self,
txn_mode: TransactionMode,
url: String,
schema: Option<String>,
tls: MakeTlsConnector
) -> Result<Stash, StashError>
Trait Implementations§
source§impl Clone for StashFactory
impl Clone for StashFactory
source§fn clone(&self) -> StashFactory
fn clone(&self) -> StashFactory
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 moreAuto Trait Implementations§
impl !RefUnwindSafe for StashFactory
impl Send for StashFactory
impl Sync for StashFactory
impl Unpin for StashFactory
impl !UnwindSafe for StashFactory
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
.