Prometheus Proxy/io.prometheus.proxy/AgentContextCleanupService

AgentContextCleanupService

internal class AgentContextCleanupService(proxy: Proxy, configVals: ConfigVals.Proxy2.Internal2, initBlock: AgentContextCleanupService.() -> Unit = {}) : GenericExecutionThreadService(source)

Background service that periodically evicts stale agent contexts.

Runs a loop that checks for agents whose last activity exceeds maxAgentInactivitySecs. Stale agents are removed from the path map and context manager, and their in-flight scrape requests are failed. A TOCTOU re-check guards against evicting agents that sent a heartbeat between the scan and the eviction.

Parameters

proxy

the parent Proxy instance

configVals

internal proxy configuration (inactivity timeout, check interval)

initBlock

optional initialization block run after listener registration

See also

AgentContextManager

Constructors

AgentContextCleanupService

constructor(proxy: Proxy, configVals: ConfigVals.Proxy2.Internal2, initBlock: AgentContextCleanupService.() -> Unit = {})

Types

object Companion

Properties

val isRunning: Boolean

Functions

fun addListener(listener: Service.Listener, executor: Executor)

fun awaitRunning()

fun awaitRunning(timeout: Duration)

fun awaitRunning(timeout: Long, unit: TimeUnit)

awaitTerminated

fun awaitTerminated()

fun awaitTerminated(timeout: Duration)

fun awaitTerminated(timeout: Long, unit: TimeUnit)

fun failureCause(): Throwable

@CanIgnoreReturnValue

fun startAsync(): Service

fun startSync(timeout: Duration)

fun state(): Service.State

@CanIgnoreReturnValue

fun stopAsync(): Service

fun stopSync(timeout: Duration)

open override fun toString(): String