Prometheus Proxy/io.prometheus.agent/AgentGrpcService

AgentGrpcService

internal class AgentGrpcService(val agent: Agent, options: AgentOptions, inProcessServerName: String)(source)

gRPC client that manages the agent's connection to the proxy.

Handles the full gRPC lifecycle: channel and stub creation, TLS configuration, agent registration, path registration/unregistration, heartbeat sending, and bidirectional scrape request/response streaming (including chunked transfers for large payloads). Supports reconnection by resetting stubs and channels on demand.

Parameters

agent

the parent Agent instance

options

agent configuration options (proxy hostname, keepalive, TLS, etc.)

inProcessServerName

the in-process server name (empty for Netty mode)

See also

AgentConnectionContext

AgentHttpService

Constructors

AgentGrpcService

constructor(agent: Agent, options: AgentOptions, inProcessServerName: String)

Types

object Companion

Properties

internal val agent: Agent

val agentHostName: String

val agentPort: Int

lateinit var channel: ManagedChannel

internal lateinit var grpcStub: ProxyServiceGrpcKt.ProxyServiceCoroutineStub

unaryDeadlineSecs

internal var unaryDeadlineSecs: Long

Functions

suspend fun connectAgent(transportFilterDisabled: Boolean): Boolean

suspend fun pathMapSize(): Int

readRequestsFromProxy

suspend fun readRequestsFromProxy(agentHttpService: AgentHttpService, connectionContext: AgentConnectionContext)

suspend fun registerAgent(initialConnectionLatch: CountDownLatch)

registerPathOnProxy

suspend fun registerPathOnProxy(pathVal: String, labelsJson: String): RegisterPathResponse

fun resetGrpcStubs()

suspend fun sendHeartBeat()

unregisterPathOnProxy

suspend fun unregisterPathOnProxy(pathVal: String): UnregisterPathResponse

writeResponsesToProxyUntilDisconnected

suspend fun writeResponsesToProxyUntilDisconnected(agent: Agent, connectionContext: AgentConnectionContext)