()
| 215 | |
| 216 | #[test] |
| 217 | fn tenant_tracking_bounded() { |
| 218 | let m = CoreMetrics::new(); |
| 219 | // Fill up the tenant map to MAX_TRACKED_TENANTS. |
| 220 | for i in 0..MAX_TRACKED_TENANTS as u64 { |
| 221 | m.record_process_for_tenant(i, i, i); |
| 222 | } |
| 223 | let counts = m.tenant_event_counts(); |
| 224 | assert_eq!(counts.len(), MAX_TRACKED_TENANTS); |
| 225 | |
| 226 | // One more tenant should be silently skipped. |
| 227 | m.record_process_for_tenant(9999, 9999, MAX_TRACKED_TENANTS as u64 + 1); |
| 228 | let counts = m.tenant_event_counts(); |
| 229 | assert_eq!(counts.len(), MAX_TRACKED_TENANTS); |
| 230 | // But global counter still incremented. |
| 231 | assert_eq!( |
| 232 | m.events_processed.load(Ordering::Relaxed), |
| 233 | MAX_TRACKED_TENANTS as u64 + 1 |
| 234 | ); |
| 235 | } |
| 236 | |
| 237 | #[test] |
| 238 | fn aggregate_from_cores() { |
nothing calls this directly
no test coverage detected