org.apache.hadoop.hbase.client.trace

Class ConnectionSpanBuilder

java.lang.Object

org.apache.hadoop.hbase.client.trace.ConnectionSpanBuilder

All Implemented Interfaces:

Supplier<io.opentelemetry.api.trace.Span>

@InterfaceAudience.Private
public class ConnectionSpanBuilder
extends Object
implements Supplier<io.opentelemetry.api.trace.Span>

Construct Span instances originating from the client side of a connection.

Field Summary

Fields

Modifier and Type	Field and Description
private Map<io.opentelemetry.api.common.AttributeKey<?>,Object>	attributes
private String	name

Constructor Summary

Constructors

Constructor and Description
ConnectionSpanBuilder(AsyncConnectionImpl conn)

Method Summary

Modifier and Type	Method and Description
<T> ConnectionSpanBuilder	addAttribute(io.opentelemetry.api.common.AttributeKey<T> key, T value)
io.opentelemetry.api.trace.Span	build()
io.opentelemetry.api.trace.Span	get()
(package private) static void	populateConnectionAttributes(Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes, AsyncConnectionImpl conn) Static utility method that performs the primary logic of this builder.
(package private) static void	populateConnectionAttributes(Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes, ClusterConnection conn)
(package private) static void	populateConnectionAttributes(Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes, Supplier<String> connectionStringSupplier, Supplier<User> userSupplier) Static utility method that performs the primary logic of this builder.
ConnectionSpanBuilder	setName(String name)

Methods inherited from class java.lang.Object

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

Field Detail

name

private String name

attributes

private final Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes

Constructor Detail

ConnectionSpanBuilder

public ConnectionSpanBuilder(AsyncConnectionImpl conn)

Method Detail

get

public io.opentelemetry.api.trace.Span get()

Specified by:

get in interface Supplier<io.opentelemetry.api.trace.Span>

setName

public ConnectionSpanBuilder setName(String name)

addAttribute

public <T> ConnectionSpanBuilder addAttribute(io.opentelemetry.api.common.AttributeKey<T> key,
                                              T value)

build

public io.opentelemetry.api.trace.Span build()

populateConnectionAttributes

static void populateConnectionAttributes(Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes,
                                         ClusterConnection conn)

See Also:

populateConnectionAttributes(Map, AsyncConnectionImpl)

populateConnectionAttributes

static void populateConnectionAttributes(Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes,
                                         AsyncConnectionImpl conn)

Static utility method that performs the primary logic of this builder. It is visible to other classes in this package so that other builders can use this functionality as a mix-in.

Parameters:

attributes - the attributes map to be populated.

conn - the source of connection attribute values.

populateConnectionAttributes

static void populateConnectionAttributes(Map<io.opentelemetry.api.common.AttributeKey<?>,Object> attributes,
                                         Supplier<String> connectionStringSupplier,
                                         Supplier<User> userSupplier)

Static utility method that performs the primary logic of this builder. It is visible to other classes in this package so that other builders can use this functionality as a mix-in.

Parameters:

attributes - the attributes map to be populated.

connectionStringSupplier - the source of the db.connection_string attribute value.

userSupplier - the source of the db.user attribute value.