Package com.mongodb.observability.micrometer

Class MongodbObservationContext

java.lang.Object

io.micrometer.observation.Observation.Context

io.micrometer.observation.transport.SenderContext<Object>

com.mongodb.observability.micrometer.MongodbObservationContext

All Implemented Interfaces:

io.micrometer.observation.Observation.ContextView

public class MongodbObservationContext
extends io.micrometer.observation.transport.SenderContext<Object>

A MongoDB-specific SenderContext for Micrometer observations.

Extends SenderContext with Kind.CLIENT to preserve the client span kind in the tracing bridge. Provides a MongoDB-specific type that users can filter on when registering ObservationHandler or ObservationConvention instances.

Domain fields (commandName, databaseName, etc.) are populated by the driver after the observation is started and before it is stopped. The ObservationConvention reads these fields at stop time to produce the final tag key-values.

Since:

5.7

Constructor Summary

Constructors

Constructor	Description
MongodbObservationContext()

Method Summary

Modifier and Type	Method	Description
String	getCollectionName()
String	getCommandName()
ConnectionId	getConnectionId()
Long	getCursorId()
String	getDatabaseName()
MongodbObservation	getObservationType()
String	getQueryText()
String	getResponseStatusCode()
ServerAddress	getServerAddress()
String	getSessionId()
Long	getTransactionNumber()
boolean	isUnixSocket()
void	setCollectionName(String collectionName)
void	setCommandName(String commandName)
void	setConnectionId(ConnectionId connectionId)
void	setCursorId(Long cursorId)
void	setDatabaseName(String databaseName)
void	setObservationType(MongodbObservation observationType)
void	setQueryText(String queryText)
void	setResponseStatusCode(String responseStatusCode)
void	setServerAddress(ServerAddress serverAddress)
void	setSessionId(String sessionId)
void	setTransactionNumber(Long transactionNumber)
void	setUnixSocket(boolean unixSocket)

Methods inherited from class io.micrometer.observation.transport.SenderContext

getCarrier, getKind, getRemoteServiceAddress, getRemoteServiceName, getSetter, setCarrier, setRemoteServiceAddress, setRemoteServiceName

Methods inherited from class io.micrometer.observation.Observation.Context

addHighCardinalityKeyValue, addHighCardinalityKeyValues, addLowCardinalityKeyValue, addLowCardinalityKeyValues, clear, computeIfAbsent, containsKey, get, getAllKeyValues, getContextualName, getError, getHighCardinalityKeyValue, getHighCardinalityKeyValues, getLowCardinalityKeyValue, getLowCardinalityKeyValues, getName, getOrDefault, getParentObservation, getRequired, put, remove, removeHighCardinalityKeyValue, removeHighCardinalityKeyValues, removeLowCardinalityKeyValue, removeLowCardinalityKeyValues, setContextualName, setError, setName, setParentObservation, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micrometer.observation.Observation.ContextView

getOrDefault

Constructor Details

MongodbObservationContext

public MongodbObservationContext()

Method Details

getCommandName

@Nullable
public String getCommandName()

setCommandName

public void setCommandName(@Nullable
 String commandName)

getDatabaseName

@Nullable
public String getDatabaseName()

setDatabaseName

public void setDatabaseName(@Nullable
 String databaseName)

getCollectionName

@Nullable
public String getCollectionName()

setCollectionName

public void setCollectionName(@Nullable
 String collectionName)

getServerAddress

@Nullable
public ServerAddress getServerAddress()

setServerAddress

public void setServerAddress(@Nullable
 ServerAddress serverAddress)

getConnectionId

@Nullable
public ConnectionId getConnectionId()

setConnectionId

public void setConnectionId(@Nullable
 ConnectionId connectionId)

getObservationType

@Nullable
public MongodbObservation getObservationType()

setObservationType

public void setObservationType(MongodbObservation observationType)

getCursorId

@Nullable
public Long getCursorId()

setCursorId

public void setCursorId(@Nullable
 Long cursorId)

getTransactionNumber

@Nullable
public Long getTransactionNumber()

setTransactionNumber

public void setTransactionNumber(@Nullable
 Long transactionNumber)

getSessionId

@Nullable
public String getSessionId()

setSessionId

public void setSessionId(@Nullable
 String sessionId)

isUnixSocket

public boolean isUnixSocket()

setUnixSocket

public void setUnixSocket(boolean unixSocket)

getQueryText

@Nullable
public String getQueryText()

setQueryText

public void setQueryText(@Nullable
 String queryText)

getResponseStatusCode

@Nullable
public String getResponseStatusCode()

setResponseStatusCode

public void setResponseStatusCode(@Nullable
 String responseStatusCode)