Package io.bytestreams.exchange.core

Class OTel

java.lang.Object

io.bytestreams.exchange.core.OTel

public final class OTel
extends Object

OpenTelemetry constants and helpers.

Public AttributeKey constants define the metric and span attribute names used by channel implementations. These are the canonical keys for querying telemetry data.

The meter() and tracer() helpers delegate to GlobalOpenTelemetry.get(), which returns a no-op provider unless the OpenTelemetry SDK is configured by the application.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	OTel.Direction	Identifies the traffic direction for a channel, used as an OTel metric attribute.

Field Summary

Fields

Modifier and Type	Field	Description
static final io.opentelemetry.api.common.AttributeKey<String>	CHANNEL_ID
static final io.opentelemetry.api.common.AttributeKey<String>	CHANNEL_TYPE
static final io.opentelemetry.api.common.AttributeKey<String>	DIRECTION
static final io.opentelemetry.api.common.AttributeKey<String>	ERROR_TYPE
static final io.opentelemetry.api.common.AttributeKey<String>	MESSAGE_ID
static final io.opentelemetry.api.common.AttributeKey<String>	MESSAGE_TYPE
static final String	NAMESPACE
static final double	NANOS_PER_MS
static final io.opentelemetry.api.common.AttributeKey<String>	NETWORK_PEER_ADDRESS
static final io.opentelemetry.api.common.AttributeKey<Long>	NETWORK_PEER_PORT
static final io.opentelemetry.api.common.AttributeKey<String>	NETWORK_TRANSPORT
static final io.opentelemetry.api.common.AttributeKey<String>	NETWORK_TYPE
static final io.opentelemetry.api.common.AttributeKey<String>	SERVER_ADDRESS
static final io.opentelemetry.api.common.AttributeKey<Long>	SERVER_PORT
static final String	UNIT_ATTEMPT
static final String	UNIT_REQUEST

Method Summary

Modifier and Type	Method	Description
static void	endSpan(io.opentelemetry.api.trace.Span span, Throwable error)
static io.opentelemetry.api.metrics.Meter	meter()	Returns the default Meter, resolved lazily from GlobalOpenTelemetry.
static io.opentelemetry.api.trace.Tracer	tracer()	Returns the default Tracer, resolved lazily from GlobalOpenTelemetry.
static io.opentelemetry.api.common.Attributes	withError(io.opentelemetry.api.common.Attributes attrs, Throwable error)	Returns the given attributes with error_type added if the throwable is non-null.

Methods inherited from class java.lang.Object

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

Field Details

CHANNEL_ID

public static final io.opentelemetry.api.common.AttributeKey<String> CHANNEL_ID

CHANNEL_TYPE

public static final io.opentelemetry.api.common.AttributeKey<String> CHANNEL_TYPE

DIRECTION

public static final io.opentelemetry.api.common.AttributeKey<String> DIRECTION

ERROR_TYPE

public static final io.opentelemetry.api.common.AttributeKey<String> ERROR_TYPE

MESSAGE_ID

public static final io.opentelemetry.api.common.AttributeKey<String> MESSAGE_ID

MESSAGE_TYPE

public static final io.opentelemetry.api.common.AttributeKey<String> MESSAGE_TYPE

SERVER_ADDRESS

public static final io.opentelemetry.api.common.AttributeKey<String> SERVER_ADDRESS

SERVER_PORT

public static final io.opentelemetry.api.common.AttributeKey<Long> SERVER_PORT

NETWORK_TRANSPORT

public static final io.opentelemetry.api.common.AttributeKey<String> NETWORK_TRANSPORT

NETWORK_TYPE

public static final io.opentelemetry.api.common.AttributeKey<String> NETWORK_TYPE

NETWORK_PEER_ADDRESS

public static final io.opentelemetry.api.common.AttributeKey<String> NETWORK_PEER_ADDRESS

NETWORK_PEER_PORT

public static final io.opentelemetry.api.common.AttributeKey<Long> NETWORK_PEER_PORT

NANOS_PER_MS

public static final double NANOS_PER_MS

See Also:

• Constant Field Values

NAMESPACE

public static final String NAMESPACE

See Also:

• Constant Field Values

UNIT_ATTEMPT

public static final String UNIT_ATTEMPT

See Also:

• Constant Field Values

UNIT_REQUEST

public static final String UNIT_REQUEST

See Also:

• Constant Field Values

Method Details

meter

public static io.opentelemetry.api.metrics.Meter meter()

Returns the default Meter, resolved lazily from GlobalOpenTelemetry.

tracer

public static io.opentelemetry.api.trace.Tracer tracer()

Returns the default Tracer, resolved lazily from GlobalOpenTelemetry.

endSpan

public static void endSpan(io.opentelemetry.api.trace.Span span,
 Throwable error)

withError

public static io.opentelemetry.api.common.Attributes withError(io.opentelemetry.api.common.Attributes attrs,
 Throwable error)

Returns the given attributes with error_type added if the throwable is non-null.