Package ai.signalroom.kafka.isotope

Class IsotopeMetrics

java.lang.Object

ai.signalroom.kafka.isotope.IsotopeMetrics

public final class IsotopeMetrics
extends Object

Static facade that routes isotope metric emissions to a registered IsotopeMetricsSink. This is the seam that keeps kafka-isotope-core free of any metrics dependency: IsotopeProducerInterceptor and IsotopeContext call these static methods unconditionally, and they delegate to whatever sink is installed.

Default and registration

The default sink is NoOpMetricsSink — isEnabled() is false and every record* call is inert, so propagation works with zero metrics overhead. The optional kafka-isotope-metrics module's PrometheusIsotopeMetrics calls register(IsotopeMetricsSink) when its exporter binds, after which emissions flow to Micrometer/Prometheus.

The historic contract is preserved: emission is a no-op until a sink that reports isEnabled() is registered, so the interceptor may call recordHop(java.lang.String, java.lang.String, java.lang.String, java.lang.String, long, int) unguarded on every send.

Method Summary

Modifier and Type	Method	Description
static boolean	isEnabled()	True once a recording sink is installed; gates emission in recordHop(java.lang.String, java.lang.String, java.lang.String, java.lang.String, long, int).
static void	recordConsume(String pipeline, String originService, String consumerService, String thisTopic, long latencyMs)
static void	recordConsumeAge(String pipeline, String originService, String consumerService, String thisTopic, long ageMs)
static void	recordHop(String pipeline, String originService, String thisService, String thisTopic, long latencyMs, int hopCount)
static void	register(IsotopeMetricsSink newSink)	Installs the active sink.
static void	reset()	Restores the no-op sink.
static IsotopeMetricsSink	sink()	The currently installed sink (never null).

Methods inherited from class java.lang.Object

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

Method Details

register

public static void register(IsotopeMetricsSink newSink)

Installs the active sink. Passing null restores the no-op sink. Called by kafka-isotope-metrics when its exporter starts.

reset

public static void reset()

Restores the no-op sink. Primarily for tests and exporter shutdown.

sink

public static IsotopeMetricsSink sink()

The currently installed sink (never null).

isEnabled

public static boolean isEnabled()

True once a recording sink is installed; gates emission in recordHop(java.lang.String, java.lang.String, java.lang.String, java.lang.String, long, int).

recordHop

public static void recordHop(String pipeline,
 String originService,
 String thisService,
 String thisTopic,
 long latencyMs,
 int hopCount)

See Also:

• IsotopeMetricsSink.recordHop(java.lang.String, java.lang.String, java.lang.String, java.lang.String, long, int)

recordConsume

public static void recordConsume(String pipeline,
 String originService,
 String consumerService,
 String thisTopic,
 long latencyMs)

See Also:

• IsotopeMetricsSink.recordConsume(java.lang.String, java.lang.String, java.lang.String, java.lang.String, long)

recordConsumeAge

public static void recordConsumeAge(String pipeline,
 String originService,
 String consumerService,
 String thisTopic,
 long ageMs)

See Also:

• IsotopeMetricsSink.recordConsumeAge(java.lang.String, java.lang.String, java.lang.String, java.lang.String, long)