public abstract class HttpForwardingMetricsServer extends Object
A server that can listen for metrics from the HttpForwardingMetricsConsumer.
Constructor and Description |
---|
HttpForwardingMetricsServer(Map<String,Object> conf)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
int |
getPort() |
String |
getUrl() |
abstract void |
handle(IMetricsConsumer.TaskInfo taskInfo,
Collection<IMetricsConsumer.DataPoint> dataPoints,
String topologyId) |
void |
serve() |
void |
serve(Integer port)
Start the server.
|
public abstract void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId)
public void serve(Integer port)
Start the server.
port
- the port it shuld listen on, or null/<= 0 to pick a free ephemeral port.public void serve()
public int getPort()
public String getUrl()
Copyright © 2022 The Apache Software Foundation. All rights reserved.