Package io.prometheus.client.exporter

Class HTTPServer

java.lang.Object

io.prometheus.client.exporter.HTTPServer

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class HTTPServer
extends java.lang.Object
implements java.io.Closeable

Expose Prometheus metrics using a plain Java HttpServer.

Example Usage:

 
 HTTPServer server = new HTTPServer(1234);
 
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HTTPServer.Builder	We keep the original constructors of HTTPServer for compatibility, but new configuration parameters like sampleNameFilter must be configured using the Builder.
static class	HTTPServer.HTTPMetricHandler	Handles Metrics collections from the given registry.
private static class	HTTPServer.LocalByteArray
(package private) static class	HTTPServer.NamedDaemonThreadFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.ExecutorService	executorService
protected com.sun.net.httpserver.HttpServer	server

Constructor Summary

Constructors

Modifier	Constructor	Description
	HTTPServer(int port)	Start an HTTP server serving the default Prometheus registry using non-daemon threads.
	HTTPServer(int port, boolean daemon)	Start an HTTP server serving the default Prometheus registry.
	HTTPServer(com.sun.net.httpserver.HttpServer httpServer, CollectorRegistry registry, boolean daemon)	Start an HTTP server serving Prometheus metrics from the given registry using the given HttpServer.
	HTTPServer(java.lang.String host, int port)	Start an HTTP server serving the default Prometheus registry using non-daemon threads.
	HTTPServer(java.lang.String host, int port, boolean daemon)	Start an HTTP server serving the default Prometheus registry.
	HTTPServer(java.net.InetSocketAddress addr, CollectorRegistry registry)	Start an HTTP server serving Prometheus metrics from the given registry using non-daemon threads.
	HTTPServer(java.net.InetSocketAddress addr, CollectorRegistry registry, boolean daemon)	Start an HTTP server serving Prometheus metrics from the given registry.
private	HTTPServer(java.util.concurrent.ExecutorService executorService, com.sun.net.httpserver.HttpServer httpServer, CollectorRegistry registry, boolean daemon, Supplier<Predicate<java.lang.String>> sampleNameFilterSupplier, com.sun.net.httpserver.Authenticator authenticator)

Method Summary

Modifier and Type	Method	Description
void	close()	Stop the HTTPServer.
int	getPort()	Gets the port number.
protected static java.util.Set<java.lang.String>	parseQuery(java.lang.String query)
protected static boolean	shouldUseCompression(com.sun.net.httpserver.HttpExchange exchange)
private void	start(boolean daemon)	Start an HTTP server by making sure that its background thread inherit proper daemon flag.
void	stop()	Deprecated. renamed to close(), so that the HTTPServer can be used in try-with-resources.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

server

protected final com.sun.net.httpserver.HttpServer server

executorService

protected final java.util.concurrent.ExecutorService executorService

Constructor Detail

HTTPServer

public HTTPServer(com.sun.net.httpserver.HttpServer httpServer,
                  CollectorRegistry registry,
                  boolean daemon)
           throws java.io.IOException

Start an HTTP server serving Prometheus metrics from the given registry using the given HttpServer. The httpServer is expected to already be bound to an address

Throws:

java.io.IOException

HTTPServer

public HTTPServer(java.net.InetSocketAddress addr,
                  CollectorRegistry registry,
                  boolean daemon)
           throws java.io.IOException

Start an HTTP server serving Prometheus metrics from the given registry.

Throws:

java.io.IOException

HTTPServer

public HTTPServer(java.net.InetSocketAddress addr,
                  CollectorRegistry registry)
           throws java.io.IOException

Start an HTTP server serving Prometheus metrics from the given registry using non-daemon threads.

Throws:

java.io.IOException

HTTPServer

public HTTPServer(int port,
                  boolean daemon)
           throws java.io.IOException

Start an HTTP server serving the default Prometheus registry.

Throws:

java.io.IOException

HTTPServer

public HTTPServer(int port)
           throws java.io.IOException

Start an HTTP server serving the default Prometheus registry using non-daemon threads.

Throws:

java.io.IOException

HTTPServer

public HTTPServer(java.lang.String host,
                  int port,
                  boolean daemon)
           throws java.io.IOException

Start an HTTP server serving the default Prometheus registry.

Throws:

java.io.IOException

HTTPServer

public HTTPServer(java.lang.String host,
                  int port)
           throws java.io.IOException

Start an HTTP server serving the default Prometheus registry using non-daemon threads.

Throws:

java.io.IOException

HTTPServer

private HTTPServer(java.util.concurrent.ExecutorService executorService,
                   com.sun.net.httpserver.HttpServer httpServer,
                   CollectorRegistry registry,
                   boolean daemon,
                   Supplier<Predicate<java.lang.String>> sampleNameFilterSupplier,
                   com.sun.net.httpserver.Authenticator authenticator)

Method Detail

shouldUseCompression

protected static boolean shouldUseCompression(com.sun.net.httpserver.HttpExchange exchange)

parseQuery

protected static java.util.Set<java.lang.String> parseQuery(java.lang.String query)
                                                     throws java.io.IOException

Throws:

java.io.IOException

start

private void start(boolean daemon)

Start an HTTP server by making sure that its background thread inherit proper daemon flag.

stop

public void stop()

Deprecated.

renamed to close(), so that the HTTPServer can be used in try-with-resources.

Stop the HTTP server.

close

public void close()

Stop the HTTPServer.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

getPort

public int getPort()

Gets the port number.