DVCaptureConsumer class
One destination's position in the log, and the delivery that moves it.
Properties
- batchSize → int
-
final
- capture → DVCapture
-
final
- hashCode → int
-
The hash code for this object.
no setterinherited
- lagThreshold → Duration?
-
Past this, lag reports
DV-CDC-003.final -
models
→ Set<
String> ? -
final
- name → String
-
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- sink → DVCaptureSink
-
final
- tenant → String?
-
final
Methods
-
backfill(
DVRecordTable table, {int chunkSize = 500, int? maxChunks, String? tenantColumn}) → Future< DVCaptureBackfillProgress> -
Copies
table's live rows to the destination,chunkSizeat a time, resuming where an earlier run stopped. -
backfillProgress(
String model) → Future< DVCaptureBackfillProgress?> -
Where the backfill of
modelstands, or null when none has started. -
behindRetention(
) → Future< bool> -
Whether this consumer stands before what the log has pruned, so
delivery cannot reach what it missed and only a backfill can
(
DV-CDC-002). -
checkpoint(
) → Future< int> - The last sequence this consumer has delivered, or 0.
-
deliverAll(
) → Future< DVCaptureDelivery> - Delivers until the consumer has reached the head of the log.
-
deliverOnce(
) → Future< DVCaptureDelivery> - Delivers up to batchSize log entries after the checkpoint.
-
lag(
) → Future< DVCaptureLag> -
How far behind this consumer is, recorded as the gauges
dv_capture_lag_secondsanddv_capture_lag_changes. -
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
position(
) → Future< int?> - The last sequence this consumer has delivered, or null when it has never delivered anything: a destination with no position yet, which has none of the history and needs a backfill.
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited