Index

A C D E F H I M N O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values

A

adoptFromRecord(ConsumerRecord<?, ?>) - Static method in class ai.signalroom.kafka.isotope.IsotopeContext

Extracts the isotope from the given record's headers (if any) and installs it as the current thread-local context.

adoptFromRecord(ConsumerRecord<?, ?>, String) - Static method in class ai.signalroom.kafka.isotope.IsotopeContext

Like IsotopeContext.adoptFromRecord(ConsumerRecord), but also emits the stateless consume-side isotope.consume.age timer attributing the adoption to consumerService.

ai.signalroom.kafka.isotope - package ai.signalroom.kafka.isotope

appendHop(Isotope.Hop) - Method in class ai.signalroom.kafka.isotope.Isotope

C

clear() - Static method in class ai.signalroom.kafka.isotope.IsotopeContext

close() - Method in class ai.signalroom.kafka.isotope.IsotopeProducerInterceptor

configure(Map<String, ?>) - Method in class ai.signalroom.kafka.isotope.IsotopeProducerInterceptor

CONSUME_EVENTS_TOPIC - Static variable in class ai.signalroom.kafka.isotope.IsotopeContext

Default topic that IsotopeContext.recordConsume(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>, java.lang.String, org.apache.kafka.clients.producer.Producer<byte[], byte[]>) writes markers to.

current() - Static method in class ai.signalroom.kafka.isotope.IsotopeContext

D

Default and registration - Search tag in class ai.signalroom.kafka.isotope.IsotopeMetrics

Section

E

equals(Object) - Method in record class ai.signalroom.kafka.isotope.Isotope.Hop

Indicates whether some other object is "equal to" this one.

F

fromHeaders(Headers) - Static method in class ai.signalroom.kafka.isotope.Isotope

Returns the isotope carried by the given headers, or null if absent.

fromJsonBytes(byte[]) - Static method in class ai.signalroom.kafka.isotope.Isotope

H

hashCode() - Method in record class ai.signalroom.kafka.isotope.Isotope.Hop

Returns a hash code value for this object.

HEADER_CONSUMER_SERVICE - Static variable in class ai.signalroom.kafka.isotope.Isotope

Consume-side marker header.

HEADER_HOP_COUNT - Static variable in class ai.signalroom.kafka.isotope.Isotope

HEADER_KEY - Static variable in class ai.signalroom.kafka.isotope.Isotope

HEADER_ORIGIN_SERVICE - Static variable in class ai.signalroom.kafka.isotope.Isotope

HEADER_ORIGIN_TS - Static variable in class ai.signalroom.kafka.isotope.Isotope

HEADER_PIPELINE - Static variable in class ai.signalroom.kafka.isotope.Isotope

HEADER_THIS_SERVICE - Static variable in class ai.signalroom.kafka.isotope.Isotope

HEADER_THIS_TOPIC - Static variable in class ai.signalroom.kafka.isotope.Isotope

HEADER_TRACE_ID - Static variable in class ai.signalroom.kafka.isotope.Isotope

Scalar reporting headers, written alongside Isotope.HEADER_KEY by IsotopeProducerInterceptor.

Hop(String, String, long) - Constructor for record class ai.signalroom.kafka.isotope.Isotope.Hop

Creates an instance of a Hop record class.

hops() - Method in class ai.signalroom.kafka.isotope.Isotope

I

isEnabled() - Static method in class ai.signalroom.kafka.isotope.IsotopeMetrics

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

isEnabled() - Method in interface ai.signalroom.kafka.isotope.IsotopeMetricsSink

True once this sink is actively recording.

Isotope - Class in ai.signalroom.kafka.isotope

Isotope.Hop - Record Class in ai.signalroom.kafka.isotope

IsotopeContext - Class in ai.signalroom.kafka.isotope

Thread-local handoff for the in-flight isotope between a consumer and a downstream producer in the same processing thread.

IsotopeMetrics - Class in ai.signalroom.kafka.isotope

Static facade that routes isotope metric emissions to a registered IsotopeMetricsSink.

IsotopeMetricsSink - Interface in ai.signalroom.kafka.isotope

The metrics seam between kafka-isotope-core (trace propagation) and any metrics backend.

IsotopeProducerInterceptor<K,V> - Class in ai.signalroom.kafka.isotope

Producer-side half of the isotope tracer.

IsotopeProducerInterceptor() - Constructor for class ai.signalroom.kafka.isotope.IsotopeProducerInterceptor

M

MAX_HOPS - Static variable in class ai.signalroom.kafka.isotope.Isotope

Bounded ring for the hop list — a payload guard, not a routing cap.

N

newTrace(String) - Static method in class ai.signalroom.kafka.isotope.Isotope

Starts a fresh trace with an unnamed pipeline ("unknown").

newTrace(String, String) - Static method in class ai.signalroom.kafka.isotope.Isotope

newTrace(String, String, long) - Static method in class ai.signalroom.kafka.isotope.Isotope

Starts a fresh trace whose origin timestamp is set explicitly (e.g.

O

onAcknowledgement(RecordMetadata, Exception) - Method in class ai.signalroom.kafka.isotope.IsotopeProducerInterceptor

onSend(ProducerRecord<K, V>) - Method in class ai.signalroom.kafka.isotope.IsotopeProducerInterceptor

originService() - Method in class ai.signalroom.kafka.isotope.Isotope

originTsMs() - Method in class ai.signalroom.kafka.isotope.Isotope

P

pipeline() - Method in class ai.signalroom.kafka.isotope.Isotope

PIPELINE_NAME_CONFIG - Static variable in class ai.signalroom.kafka.isotope.IsotopeProducerInterceptor

Names the logical pipeline a fresh trace belongs to (e.g.

R

recordConsume(String, String, String, String, long) - Static method in class ai.signalroom.kafka.isotope.IsotopeMetrics

recordConsume(String, String, String, String, long) - Method in interface ai.signalroom.kafka.isotope.IsotopeMetricsSink

Records the consume-edge count and origin→consume latency for one consume marker.

recordConsume(ConsumerRecord<?, ?>, String, Producer<byte[], byte[]>) - Static method in class ai.signalroom.kafka.isotope.IsotopeContext

Emits a best-effort consume-edge marker to "isotope_consume_edge_markers" using the default topic name.

recordConsume(ConsumerRecord<?, ?>, String, Producer<byte[], byte[]>, String) - Static method in class ai.signalroom.kafka.isotope.IsotopeContext

Emits a best-effort consume-edge marker describing the consumption of record by consumerService.

recordConsumeAge(String, String, String, String, long) - Static method in class ai.signalroom.kafka.isotope.IsotopeMetrics

recordConsumeAge(String, String, String, String, long) - Method in interface ai.signalroom.kafka.isotope.IsotopeMetricsSink

Records the consume-side "age" timer (now - originTs) for one consumed record — emitted once on every consuming stage.

recordHop(String, String, String, String, long, int) - Static method in class ai.signalroom.kafka.isotope.IsotopeMetrics

recordHop(String, String, String, String, long, int) - Method in interface ai.signalroom.kafka.isotope.IsotopeMetricsSink

Records the stateless-aggregation metrics for one produced hop: origin→hop latency plus the hop-distribution counter.

register(IsotopeMetricsSink) - Static method in class ai.signalroom.kafka.isotope.IsotopeMetrics

Installs the active sink.

reset() - Static method in class ai.signalroom.kafka.isotope.IsotopeMetrics

Restores the no-op sink.

S

service() - Method in record class ai.signalroom.kafka.isotope.Isotope.Hop

Returns the value of the service record component.

SERVICE_NAME_CONFIG - Static variable in class ai.signalroom.kafka.isotope.IsotopeProducerInterceptor

set(Isotope) - Static method in class ai.signalroom.kafka.isotope.IsotopeContext

sink() - Static method in class ai.signalroom.kafka.isotope.IsotopeMetrics

The currently installed sink (never null).

T

toJsonBytes() - Method in class ai.signalroom.kafka.isotope.Isotope

topic() - Method in record class ai.signalroom.kafka.isotope.Isotope.Hop

Returns the value of the topic record component.

toString() - Method in record class ai.signalroom.kafka.isotope.Isotope.Hop

Returns a string representation of this record class.

TRACE_ID_BYTES - Static variable in class ai.signalroom.kafka.isotope.Isotope

traceId() - Method in class ai.signalroom.kafka.isotope.Isotope

traceIdHex() - Method in class ai.signalroom.kafka.isotope.Isotope

truncated() - Method in class ai.signalroom.kafka.isotope.Isotope

tsMs() - Method in record class ai.signalroom.kafka.isotope.Isotope.Hop

Returns the value of the tsMs record component.

U

uuidV7String() - Static method in class ai.signalroom.kafka.isotope.Isotope

Convenience: a fresh UUIDv7 in canonical xxxxxxxx-...-7xxx-yxxx-... string form.

A C D E F H I M N O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values