io.opentracing.contrib.agent.helper

Class CassandraHelper

java.lang.Object

org.jboss.byteman.rule.helper.Helper

io.opentracing.contrib.agent.OpenTracingHelper

io.opentracing.contrib.agent.helper.DDAgentTracingHelper<com.datastax.driver.core.Session>

io.opentracing.contrib.agent.helper.CassandraHelper

public class CassandraHelper
extends DDAgentTracingHelper<com.datastax.driver.core.Session>

Patch each new sessions created when trying to connect to a Cassandra cluster.

Nested Class Summary

Nested classes/interfaces inherited from class io.opentracing.contrib.agent.OpenTracingHelper

OpenTracingHelper.AgentSpanBuilder, OpenTracingHelper.AgentTracer

Field Summary

Fields inherited from class io.opentracing.contrib.agent.helper.DDAgentTracingHelper

tracer

Fields inherited from class org.jboss.byteman.rule.helper.Helper

rule

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CassandraHelper(org.jboss.byteman.rule.Rule rule)

Method Summary

Modifier and Type	Method and Description
protected com.datastax.driver.core.Session	doPatch(com.datastax.driver.core.Session session) Strategy: each time we build a connection to a Cassandra cluster, the com.datastax.driver.core.Cluster$Manager.newSession() method is called.
com.datastax.driver.core.Session	patch(com.datastax.driver.core.Session session) This method takes an object and applies some mutation in order to add tracing capabilities.

Methods inherited from class io.opentracing.contrib.agent.helper.DDAgentTracingHelper

info, logStackTrace, warning

Methods inherited from class io.opentracing.contrib.agent.OpenTracingHelper

associateSpan, finishedSpan, getState, getTracer, ignore, initTracer, isFinished, retrieveSpan, setState

Methods inherited from class org.jboss.byteman.rule.helper.Helper

activated, addCountDown, callerCheck, callerEquals, callerEquals, callerEquals, callerEquals, callerEquals, callerEquals, callerEquals, callerEquals, callerEquals, callerMatches, callerMatches, callerMatches, callerMatches, callerMatches, callerMatches, callerMatches, callerMatches, callerMatches, clear, closeTrace, countDown, createCountDown, createCounter, createCounter, createJoin, createLinkMap, createRendezvous, createRendezvous, createTimer, deactivated, debug, decrementCounter, delay, deleteCounter, deleteLinkMap, deleteRendezvous, deleteTimer, err, errTraceException, flag, flagged, formatAllStacks, formatAllStacks, formatAllStacks, formatAllStacks, formatStack, formatStack, formatStack, formatStack, formatStackBetween, formatStackBetween, formatStackBetween, formatStackBetween, formatStackBetween, formatStackBetween, formatStackBetweenMatches, formatStackBetweenMatches, formatStackBetweenMatches, formatStackBetweenMatches, formatStackBetweenMatches, formatStackBetweenMatches, formatStackMatching, formatStackMatching, formatStackMatching, formatStackMatching, formatStackMatching, formatStackMatching, formatStackRange, formatThreadStack, formatThreadStack, formatThreadStack, formatThreadStack, getCountDown, getElapsedTimeFromTimer, getObjectSize, getRendezvous, getStack, incrementCounter, incrementCounter, installed, isCountDown, isJoin, isRendezvous, joinEnlist, joinWait, joinWait, killJVM, killJVM, killThread, link, link, linked, linked, matchIndex, noisy, noisyTraceException, openTrace, openTrace, out, outTraceException, printFrame, printlnFrame, readCounter, readCounter, rendezvous, rendezvous, resetTimer, setTriggering, signalKill, signalKill, signalThrow, signalThrow, signalWake, signalWake, toString, trace, trace, traceAllStacks, traceAllStacks, traceAllStacks, traceAllStacks, traceAllStacks, traceAllStacks, traceClose, traceln, traceln, traceOpen, traceOpen, traceStack, traceStack, traceStack, traceStack, traceStack, traceStack, traceStackBetween, traceStackBetween, traceStackBetween, traceStackBetween, traceStackBetween, traceStackBetween, traceStackBetween, traceStackBetween, traceStackBetween, traceStackBetweenMatches, traceStackBetweenMatches, traceStackBetweenMatches, traceStackBetweenMatches, traceStackBetweenMatches, traceStackBetweenMatches, traceStackBetweenMatches, traceStackBetweenMatches, traceStackBetweenMatches, traceStackMatching, traceStackMatching, traceStackMatching, traceStackMatching, traceStackMatching, traceStackMatching, traceStackMatching, traceStackMatching, traceStackMatching, traceStackRange, traceThreadStack, traceThreadStack, traceThreadStack, traceThreadStack, traceThreadStack, traceThreadStack, triggerIndex, uninstalled, unlink, unlink, verbose, verboseTraceException, waitFor, waitFor, waiting

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraHelper

protected CassandraHelper(org.jboss.byteman.rule.Rule rule)

Method Detail

patch

public com.datastax.driver.core.Session patch(com.datastax.driver.core.Session session)

Description copied from class: DDAgentTracingHelper

This method takes an object and applies some mutation in order to add tracing capabilities. This method should never return any Exception in order to not stop the app traced.

This method should be defined as final, but something Byteman need to define this one with the explicit type (i.e. without using generic), so this is why we don't use final here.

Overrides:

patch in class DDAgentTracingHelper<com.datastax.driver.core.Session>

Parameters:

session - The object to patch, the type is defined by the subclass instantiation

Returns:

The object patched

doPatch

protected com.datastax.driver.core.Session doPatch(com.datastax.driver.core.Session session)
                                            throws Exception

Strategy: each time we build a connection to a Cassandra cluster, the com.datastax.driver.core.Cluster$Manager.newSession() method is called. The opentracing contribution is a simple wrapper, so we just have to wrap the new session.

Specified by:

doPatch in class DDAgentTracingHelper<com.datastax.driver.core.Session>

Parameters:

session - The fresh session to patch

Returns:

A new tracing session

Throws:

Exception