Struct mz_storage::source::PostgresSourceReader
source · pub struct PostgresSourceReader {
receiver_stream: Receiver<(usize, InternalMessage)>,
last_lsn: PgLsn,
data_capability: Capability<MzOffset>,
upper_capability: Capability<MzOffset>,
}
Expand description
Information required to sync data from Postgres
Fields§
§receiver_stream: Receiver<(usize, InternalMessage)>
§last_lsn: PgLsn
The lsn we last emitted data at. Used to fabricate timestamps for errors. This should ideally go away and only emit errors that we can associate with source timestamps
data_capability: Capability<MzOffset>
Capabilities used to produce messages
upper_capability: Capability<MzOffset>
Auto Trait Implementations§
impl !RefUnwindSafe for PostgresSourceReader
impl !Send for PostgresSourceReader
impl !Sync for PostgresSourceReader
impl Unpin for PostgresSourceReader
impl !UnwindSafe for PostgresSourceReader
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<T> Pointable for T
impl<T> Pointable 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
.