Package dev.restate.sdk.interceptor.micrometer

Class MicrometerHelpers

java.lang.Object

dev.restate.sdk.interceptor.micrometer.MicrometerHelpers

@Internal
public final class MicrometerHelpers
extends Object

Shared helpers for building Micrometer observations that mirror the spans produced by sdk-interceptor-opentelemetry: same span names and the same attribute set ( restate.invocation.id, restate.invocation.target, restate.run.name).

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INVOCATION_ID
static final String	INVOCATION_OBSERVATION
static final String	INVOCATION_TARGET
static final String	RUN_NAME
static final String	RUN_OBSERVATION

Method Summary

Modifier and Type	Method	Description
static io.micrometer.observation.transport.ReceiverContext<HeadersAccessor>	headersReceiverContext(HeadersAccessor headers)	Build a ReceiverContext wrapping the attempt headers for W3C / B3 extraction.
static io.micrometer.observation.Observation	startHandlerObservation(io.micrometer.observation.ObservationRegistry registry, io.micrometer.observation.transport.ReceiverContext<HeadersAccessor> recvCtx, HandlerRequest request)
static io.micrometer.observation.Observation	startRunObservation(io.micrometer.observation.ObservationRegistry registry, @Nullable String runName)

Methods inherited from class java.lang.Object

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

Field Details

INVOCATION_OBSERVATION

public static final String INVOCATION_OBSERVATION

See Also:

• Constant Field Values

RUN_OBSERVATION

public static final String RUN_OBSERVATION

See Also:

• Constant Field Values

INVOCATION_ID

public static final String INVOCATION_ID

See Also:

• Constant Field Values

INVOCATION_TARGET

public static final String INVOCATION_TARGET

See Also:

• Constant Field Values

RUN_NAME

public static final String RUN_NAME

See Also:

• Constant Field Values

Method Details

headersReceiverContext

public static io.micrometer.observation.transport.ReceiverContext<HeadersAccessor> headersReceiverContext(HeadersAccessor headers)

Build a ReceiverContext wrapping the attempt headers for W3C / B3 extraction.

startHandlerObservation

public static io.micrometer.observation.Observation startHandlerObservation(io.micrometer.observation.ObservationRegistry registry,
 io.micrometer.observation.transport.ReceiverContext<HeadersAccessor> recvCtx,
 HandlerRequest request)

startRunObservation

public static io.micrometer.observation.Observation startRunObservation(io.micrometer.observation.ObservationRegistry registry,
 @Nullable String runName)