Prometheus Proxy/io.prometheus.proxy/ProxyServiceImpl

ProxyServiceImpl

internal class ProxyServiceImpl(proxy: Proxy) : ProxyServiceGrpcKt.ProxyServiceCoroutineImplBase(source)

Server-side implementation of the ProxyService gRPC service.

Handles all gRPC RPCs defined in proxy_service.proto: agent connection and registration, path registration/unregistration, heartbeat processing, and bidirectional scrape request/response streaming (including chunked transfers for large payloads). Validates agent identity on every call and delegates state management to AgentContextManager, ProxyPathManager, and ScrapeRequestManager.

Parameters

proxy

the parent Proxy instance

See also

Constructors

Link copied to clipboard
constructor(proxy: Proxy)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard

Functions

Link copied to clipboard
override fun bindService(): ServerServiceDefinition
Link copied to clipboard
open suspend override fun connectAgent(request: Empty): Empty

Returns the response to an RPC for ProxyService.connectAgent.

Link copied to clipboard
open suspend override fun connectAgentWithTransportFilterDisabled(request: Empty): AgentInfo

Returns the response to an RPC for ProxyService.connectAgentWithTransportFilterDisabled.

Link copied to clipboard
open suspend override fun pathMapSize(request: PathMapSizeRequest): PathMapSizeResponse

Returns the response to an RPC for ProxyService.pathMapSize.

Link copied to clipboard
open override fun readRequestsFromProxy(request: AgentInfo): Flow<ScrapeRequest>

Returns a Flow of responses to an RPC for ProxyService.readRequestsFromProxy.

Link copied to clipboard
open suspend override fun registerAgent(request: RegisterAgentRequest): RegisterAgentResponse

Returns the response to an RPC for ProxyService.registerAgent.

Link copied to clipboard
open suspend override fun registerPath(request: RegisterPathRequest): RegisterPathResponse

Returns the response to an RPC for ProxyService.registerPath.

Link copied to clipboard
open suspend override fun sendHeartBeat(request: HeartBeatRequest): HeartBeatResponse

Returns the response to an RPC for ProxyService.sendHeartBeat.

Link copied to clipboard
open suspend override fun unregisterPath(request: UnregisterPathRequest): UnregisterPathResponse

Returns the response to an RPC for ProxyService.unregisterPath.

Link copied to clipboard
open suspend override fun writeChunkedResponsesToProxy(requests: Flow<ChunkedScrapeResponse>): Empty

Returns the response to an RPC for ProxyService.writeChunkedResponsesToProxy.

Link copied to clipboard
open suspend override fun writeResponsesToProxy(requests: Flow<ScrapeResponse>): Empty

Returns the response to an RPC for ProxyService.writeResponsesToProxy.

Generated by Dokka
© 2026 Copyright