Class ZipkinTracer

java.lang.Object

io.vertx.tracing.zipkin.ZipkinTracer

All Implemented Interfaces:

VertxTracer<brave.Span, BiConsumer<Object, Throwable>>

public class ZipkinTracer
extends Object
implements VertxTracer<brave.Span, BiConsumer<Object, Throwable>>

Instrumenting a library.

Thrift module: zipkinCore

Field Summary

Fields inherited from interface VertxTracer

NOOP

Constructor Summary

Constructors

Constructor	Description
ZipkinTracer(boolean closeTracer, brave.http.HttpTracing httpTracing, VertxSender sender)
ZipkinTracer(boolean closeTracer, brave.Tracing tracing, VertxSender sender)

Method Summary

Modifier and Type	Method	Description
static brave.propagation.TraceContext	activeContext()
static brave.Span	activeSpan()
static void	clearContext()	Remove any active context.
static void	clearSpan()	Remove any active span.
void	close()	Close the tracer.
static String	exportTraceId()	Export active traceId otherwise null.
brave.Tracing	getTracing()
static void	importTraceId(String traceId)	Import traceId.
<R> brave.Span	receiveRequest(Context context, SpanKind kind, TracingPolicy policy, R request, String operation, Iterable<Map.Entry<String,String>> headers, TagExtractor<R> tagExtractor)	Signal a request has been received and will be processed.
<R> void	receiveResponse(Context context, R response, BiConsumer<Object, Throwable> payload, Throwable failure, TagExtractor<R> tagExtractor)	Signal a response has been received.
VertxSender	sender()
<R> BiConsumer<Object, Throwable>	sendRequest(Context context, SpanKind kind, TracingPolicy policy, R request, String operation, BiConsumer<String,String> headers, TagExtractor<R> tagExtractor)	Signal a request is sent.
<R> void	sendResponse(Context context, R response, brave.Span span, Throwable failure, TagExtractor<R> tagExtractor)	Signal the response is sent.
static void	setSpan(brave.Span span)	Set active Span.
static void	setTraceContext(brave.propagation.TraceContext context)	Set active TraceContext.

Methods inherited from class Object

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

Constructor Details

ZipkinTracer

public ZipkinTracer(boolean closeTracer,
 brave.Tracing tracing,
 VertxSender sender)

ZipkinTracer

public ZipkinTracer(boolean closeTracer,
 brave.http.HttpTracing httpTracing,
 VertxSender sender)

Method Details

sender

public VertxSender sender()

activeSpan

public static brave.Span activeSpan()

Returns:

the current active Span otherwise null

activeContext

public static brave.propagation.TraceContext activeContext()

Returns:

the current active TraceContext otherwise null

getTracing

public brave.Tracing getTracing()

receiveRequest

public <R> brave.Span receiveRequest(Context context,
 SpanKind kind,
 TracingPolicy policy,
 R request,
 String operation,
 Iterable<Map.Entry<String,String>> headers,
 TagExtractor<R> tagExtractor)

Description copied from interface: VertxTracer

Signal a request has been received and will be processed.

Specified by:

receiveRequest in interface VertxTracer<brave.Span, BiConsumer<Object, Throwable>>

Parameters:

context - the context data attached to the request

kind - the span kind

policy - the policy to apply

request - the request object

operation - the request operation

headers - a read-only view of the request headers

tagExtractor - the request tag extractor

Returns:

the request trace

sendResponse

public <R> void sendResponse(Context context,
 R response,
 brave.Span span,
 Throwable failure,
 TagExtractor<R> tagExtractor)

Description copied from interface: VertxTracer

Signal the response is sent.

Specified by:

sendResponse in interface VertxTracer<brave.Span, BiConsumer<Object, Throwable>>

Parameters:

context - the context data attached to the request

response - the response sent

span - the payload returned by VertxTracer.receiveRequest(Context, SpanKind, TracingPolicy, R, String, Iterable, TagExtractor)

failure - the failure when not null

tagExtractor - the response tag extractor

sendRequest

public <R> BiConsumer<Object, Throwable> sendRequest(Context context,
 SpanKind kind,
 TracingPolicy policy,
 R request,
 String operation,
 BiConsumer<String,String> headers,
 TagExtractor<R> tagExtractor)

Description copied from interface: VertxTracer

Signal a request is sent.

When the method returns null, no propagation happens and the client shall not call VertxTracer.receiveResponse(Context, R, O, Throwable, TagExtractor).

Specified by:

sendRequest in interface VertxTracer<brave.Span, BiConsumer<Object, Throwable>>

Parameters:

context - the context data attached to the request

kind - the span kind

policy - the policy to apply

request - the request object

operation - the request operation

headers - a write only-view of the request headers

tagExtractor - the request tag extractor

Returns:

the request trace

receiveResponse

public <R> void receiveResponse(Context context,
 R response,
 BiConsumer<Object, Throwable> payload,
 Throwable failure,
 TagExtractor<R> tagExtractor)

Description copied from interface: VertxTracer

Signal a response has been received.

Specified by:

receiveResponse in interface VertxTracer<brave.Span, BiConsumer<Object, Throwable>>

Parameters:

context - the context data attached to the request

response - the response sent

payload - the payload returned by VertxTracer.sendRequest(Context, SpanKind, TracingPolicy, R, String, BiConsumer, TagExtractor)

failure - the failure when not null

tagExtractor - the response tag extractor

close

public void close()

Description copied from interface: VertxTracer

Close the tracer.

Specified by:

close in interface VertxTracer<brave.Span, BiConsumer<Object, Throwable>>

clearContext

public static void clearContext()

Remove any active context.

clearSpan

public static void clearSpan()

Remove any active span.

importTraceId

public static void importTraceId(String traceId)

Import traceId.

exportTraceId

public static String exportTraceId()

Export active traceId otherwise null.

setTraceContext

public static void setTraceContext(brave.propagation.TraceContext context)

Set active TraceContext.

setSpan

public static void setSpan(brave.Span span)

Set active Span.