Class DistributedMonitor

java.lang.Object

org.episteme.core.technical.monitoring.DistributedMonitor

public class DistributedMonitor
extends Object

Master Monitoring Control for distributed benchmarks. Standardizes metrics collection via Micrometer and Prometheus.

Method Summary

Modifier and Type	Method	Description
static DistributedMonitor	getInstance()
io.micrometer.prometheus.PrometheusMeterRegistry	getRegistry()
boolean	isAvailable()
void	recordDistributedTask(String taskId, String node, long latencyNs)
void	recordExecution(String benchmarkId, String domain, long durationNs)
void	startServer()	Starts the metrics server on port 7070.
void	stopServer()

Methods inherited from class Object

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

Method Details

getInstance

public static DistributedMonitor getInstance()

getRegistry

public io.micrometer.prometheus.PrometheusMeterRegistry getRegistry()

isAvailable

public boolean isAvailable()

startServer

public void startServer()

Starts the metrics server on port 7070.

stopServer

public void stopServer()

recordExecution

public void recordExecution(String benchmarkId,
 String domain,
 long durationNs)

recordDistributedTask

public void recordDistributedTask(String taskId,
 String node,
 long latencyNs)