Class OrchestraHttpServer

java.lang.Object

com.iantapply.orchestra.web.OrchestraHttpServer

All Implemented Interfaces:

AutoCloseable

public final class OrchestraHttpServer
extends Object
implements AutoCloseable

Small authenticated HTTP server exposing health and Prometheus metrics.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	OrchestraHttpServer.EventTrigger	Callback used by the HTTP adapter to create an immediate event execution.

Constructor Summary

Constructors

Constructor	Description
OrchestraHttpServer(InetSocketAddress address, MetricsRegistry metrics, Map<String,Actor> tokens, OrchestraHttpServer.EventTrigger eventTrigger)	Creates the HTTP listener without starting it.

Method Summary

Modifier and Type	Method	Description
void	close()	Stops accepting requests after a one-second grace period.
void	start()	Starts accepting HTTP requests.

Methods inherited from class Object

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

Constructor Details

OrchestraHttpServer

public OrchestraHttpServer(InetSocketAddress address,
 MetricsRegistry metrics,
 Map<String,Actor> tokens,
 OrchestraHttpServer.EventTrigger eventTrigger)
                    throws IOException

Creates the HTTP listener without starting it.

Parameters:

address - bind address

metrics - metrics registry exposed at /metrics

tokens - bearer-token to actor mappings

eventTrigger - callback that creates an immediate event execution

Throws:

IOException - when the listening server cannot be created

Method Details

start

public void start()

Starts accepting HTTP requests.

close

public void close()

Stops accepting requests after a one-second grace period.

Specified by:

close in interface AutoCloseable