Prometheus Proxy/io.prometheus.proxy/AgentContext

AgentContext

internal class AgentContext(remoteAddr: String)(source)

Represents a single connected agent on the proxy side.

Each agent connection creates an AgentContext that holds the agent's identity (ID, name, hostname), validity state, activity timestamps, and a queue of pending scrape requests. The proxy writes scrape requests into the queue and the gRPC streaming RPC drains them. When the agent disconnects or is evicted, the context is invalidated and all pending requests are drained and closed.

Parameters

remoteAddr

the remote address of the connected agent

See also

AgentContextManager

ProxyPathManager

Constructors

constructor(remoteAddr: String)

Types

object Companion

Properties

val agentId: String

var agentName: String

var consolidated: Boolean

internal val desc: String

var hostName: String

inactivityDuration

val inactivityDuration: Duration

scrapeRequestBacklogSize

val scrapeRequestBacklogSize: Int

Functions

assignProperties

fun assignProperties(request: RegisterAgentRequest)

open operator override fun equals(other: Any?): Boolean

open override fun hashCode(): Int

fun invalidate()

fun isNotValid(): Boolean

fun isValid(): Boolean

markActivityTime

fun markActivityTime(isRequest: Boolean)

readScrapeRequest

suspend fun readScrapeRequest(): ScrapeRequestWrapper?

open override fun toString(): String

writeScrapeRequest

suspend fun writeScrapeRequest(scrapeRequest: ScrapeRequestWrapper)