Prometheus Proxy/io.prometheus.proxy/ProxyHttpService

ProxyHttpService

internal class ProxyHttpService(proxy: Proxy, val httpPort: Int, isTestMode: Boolean) : GenericIdleService(source)

HTTP server that serves Prometheus scrape requests.

Runs a Ktor CIO embedded server on a configurable port. Incoming HTTP GET requests are routed by ProxyHttpRoutes to the appropriate agent via gRPC, and the scraped metrics are returned to Prometheus. Also serves the optional service discovery endpoint.

Parameters

proxy

the parent Proxy instance

httpPort

the HTTP listen port for Prometheus scrape requests

isTestMode

when true, suppresses verbose logging during tests

See also

ProxyHttpRoutes

Constructors

ProxyHttpService

constructor(proxy: Proxy, httpPort: Int, isTestMode: Boolean)

Types

object Companion

Properties

val httpPort: Int

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(maxWait: Duration)

fun state(): Service.State

@CanIgnoreReturnValue

fun stopAsync(): Service

fun stopSync(maxWait: Duration)

open override fun toString(): String