Prometheus Proxy/io.prometheus.proxy/ScrapeRequestManager

ScrapeRequestManager

internal class ScrapeRequestManager(source)

Tracks in-flight scrape requests and assigns results when responses arrive.

Maintains a concurrent map of scrape ID to ScrapeRequestWrapper. When a scrape response (or chunked summary) arrives, the corresponding wrapper is located, populated with ScrapeResults, and marked complete so the waiting HTTP handler can return. Also supports failing individual or bulk requests (e.g., on agent disconnect or chunk validation failure).

See also

ScrapeRequestWrapper

ProxyServiceImpl

Constructors

ScrapeRequestManager

constructor()

Types

object Companion

Properties

val scrapeMapSize: Int

scrapeRequestMapView

val scrapeRequestMapView: Map<Long, ScrapeRequestWrapper>

Functions

addToScrapeRequestMap

fun addToScrapeRequestMap(scrapeRequest: ScrapeRequestWrapper): ScrapeRequestWrapper?

assignScrapeResults

fun assignScrapeResults(scrapeResults: ScrapeResults)

containsScrapeRequest

fun containsScrapeRequest(scrapeId: Long): Boolean

failAllInFlightScrapeRequests

fun failAllInFlightScrapeRequests(failureReason: String)

failAllScrapeRequests

fun failAllScrapeRequests(agentId: String, failureReason: String)

failScrapeRequest

fun failScrapeRequest(scrapeId: Long, failureReason: String)

removeFromScrapeRequestMap

fun removeFromScrapeRequestMap(scrapeId: Long): ScrapeRequestWrapper?