| 260 | use super::*; |
| 261 | |
| 262 | fn make_event(seq: u64, lsn: u64) -> CdcEvent { |
| 263 | let now_ms = std::time::SystemTime::now() |
| 264 | .duration_since(std::time::UNIX_EPOCH) |
| 265 | .unwrap() |
| 266 | .as_millis() as u64; |
| 267 | CdcEvent { |
| 268 | sequence: seq, |
| 269 | partition: 0, |
| 270 | collection: "test".into(), |
| 271 | op: "INSERT".into(), |
| 272 | row_id: format!("row-{seq}"), |
| 273 | event_time: now_ms + seq * 1000, |
| 274 | lsn, |
| 275 | tenant_id: 1, |
| 276 | new_value: None, |
| 277 | old_value: None, |
| 278 | schema_version: 0, |
| 279 | field_diffs: None, |
| 280 | system_time_ms: None, |
| 281 | valid_time_ms: None, |
| 282 | } |
| 283 | } |
| 284 | |
| 285 | #[test] |
| 286 | fn push_and_read() { |