streamStateCollector exposes scrape-time gauges derived from p.chatStreams. Scrape cost is O(n) with a brief per-state mutex held for two len() reads; acceptable at typical scrape cadences.
| 1347 | // p.chatStreams. Scrape cost is O(n) with a brief per-state mutex |
| 1348 | // held for two len() reads; acceptable at typical scrape cadences. |
| 1349 | type streamStateCollector struct { |
| 1350 | server *Server |
| 1351 | } |
| 1352 | |
| 1353 | var ( |
| 1354 | streamsActiveDesc = prometheus.NewDesc( |
nothing calls this directly
no outgoing calls
no test coverage detected