(&self, lsn: u64, sequence: u64)
| 75 | } |
| 76 | |
| 77 | pub fn record_process(&self, lsn: u64, sequence: u64) { |
| 78 | self.events_processed.fetch_add(1, Ordering::Relaxed); |
| 79 | self.last_processed_lsn.store(lsn, Ordering::Relaxed); |
| 80 | self.last_sequence.store(sequence, Ordering::Relaxed); |
| 81 | } |
| 82 | |
| 83 | /// Record event processing for a specific tenant. |
| 84 | /// |