pub struct TimestampCdcConfig {
pub tables: Vec<TimestampTableConfig>,
pub poll_batch_size: u32,
pub delete_detection: DeleteDetection,
}Expand description
Top-level configuration for crate::TimestampCdcConsumer.
Describes the set of tables to replicate and the parameters that apply to every table uniformly (batch size, delete detection).
Fields§
§tables: Vec<TimestampTableConfig>Tables to poll from the external source, one TimestampTableConfig
per table.
poll_batch_size: u32Maximum number of rows to fetch per table per poll cycle.
Smaller values reduce memory pressure and latency jitter; larger values amortize query round-trips during initial bulk sync.
delete_detection: DeleteDetectionStrategy for detecting rows deleted in the source.
See DeleteDetection for the available options.
Trait Implementations§
Source§impl Clone for TimestampCdcConfig
impl Clone for TimestampCdcConfig
Source§fn clone(&self) -> TimestampCdcConfig
fn clone(&self) -> TimestampCdcConfig
Returns a duplicate 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 Freeze for TimestampCdcConfig
impl RefUnwindSafe for TimestampCdcConfig
impl Send for TimestampCdcConfig
impl Sync for TimestampCdcConfig
impl Unpin for TimestampCdcConfig
impl UnsafeUnpin for TimestampCdcConfig
impl UnwindSafe for TimestampCdcConfig
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more