Struct dataflow::render::debezium::TrackFull [−][src]
struct TrackFull {
seen_positions: HashMap<RowCoordinates, i64>,
seen_snapshot_keys: HashSet<Row>,
max_seen_time: i64,
range: Option<TrackRange>,
started_padding: bool,
started: bool,
}
Expand description
If we need to deal with debezium possibly going back after it hasn’t seen things. During normal (non-snapshot) operation, we deduplicate based on binlog position: (pos, row), for MySQL. During the initial snapshot, (pos, row) values are all the same, but primary keys are unique and thus we can get deduplicate based on those.
Fields
seen_positions: HashMap<RowCoordinates, i64>
binlog position to (timestamp that this binlog entry was first seen)
seen_snapshot_keys: HashSet<Row>
max_seen_time: i64
The highest-ever seen timestamp, used in logging to let us know how far backwards time might go
range: Option<TrackRange>
started_padding: bool
started: bool
Whether we have started full deduplication mode
Implementations
fn from_keys_in_range(
start: NaiveDateTime,
end: NaiveDateTime,
pad_start: Option<NaiveDateTime>
) -> Self
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for TrackFull
impl UnwindSafe for TrackFull
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more