()
| 183 | |
| 184 | #[test] |
| 185 | fn core_metrics_basics() { |
| 186 | let m = CoreMetrics::new(); |
| 187 | m.record_emit(); |
| 188 | m.record_emit(); |
| 189 | m.record_process(100, 1); |
| 190 | m.record_process(200, 2); |
| 191 | m.record_drop(3); |
| 192 | |
| 193 | assert_eq!(m.events_emitted.load(Ordering::Relaxed), 2); |
| 194 | assert_eq!(m.events_processed.load(Ordering::Relaxed), 2); |
| 195 | assert_eq!(m.events_dropped.load(Ordering::Relaxed), 3); |
| 196 | assert_eq!(m.last_processed_lsn.load(Ordering::Relaxed), 200); |
| 197 | assert_eq!(m.last_sequence.load(Ordering::Relaxed), 2); |
| 198 | } |
| 199 | |
| 200 | #[test] |
| 201 | fn per_tenant_tracking() { |
nothing calls this directly
no test coverage detected