Package io.servicetalk.opentracing.zipkin.publisher

Class ZipkinPublisher

java.lang.Object

io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher

All Implemented Interfaces:

AsyncCloseable, InMemorySpanEventListener, Closeable, AutoCloseable

public final class ZipkinPublisher
extends Object
implements InMemorySpanEventListener, AsyncCloseable, Closeable

A publisher of Spans to the zipkin transport.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ZipkinPublisher.Builder	Builder for ZipkinPublisher.

Method Summary

Modifier and Type	Method	Description
void	close()	Blocking close method delegates to closeAsync().
Completable	closeAsync()	Attempts to close the configured Reporter.
Completable	closeAsyncGracefully()	Attempts to flush and close the configured Reporter.
void	onEventLogged(InMemorySpan span, long epochMicros, String eventName)	Called when an event was logged.
void	onEventLogged(InMemorySpan span, long epochMicros, Map<String,?> fields)	Called when an event was logged.
void	onSpanFinished(InMemorySpan span, long durationMicros)	Converts a finished InMemorySpan to a Span and passes it to the Reporter.report(Object).
void	onSpanStarted(InMemorySpan span)	Called when a span has started.

Methods inherited from class java.lang.Object

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

Method Details

onSpanStarted

public void onSpanStarted(InMemorySpan span)

Description copied from interface: InMemorySpanEventListener

Called when a span has started.

Specified by:

onSpanStarted in interface InMemorySpanEventListener

Parameters:

span - the span

onEventLogged

public void onEventLogged(InMemorySpan span,
 long epochMicros,
 String eventName)

Description copied from interface: InMemorySpanEventListener

Called when an event was logged.

Specified by:

onEventLogged in interface InMemorySpanEventListener

Parameters:

span - the span the event was associated with

epochMicros - timestamp epoch in microseconds

eventName - event name

onEventLogged

public void onEventLogged(InMemorySpan span,
 long epochMicros,
 Map<String,?> fields)

Description copied from interface: InMemorySpanEventListener

Called when an event was logged.

Specified by:

onEventLogged in interface InMemorySpanEventListener

Parameters:

span - the span the event was associated with

epochMicros - timestamp epoch in microseconds

fields - fields as a map

onSpanFinished

public void onSpanFinished(InMemorySpan span,
 long durationMicros)

Converts a finished InMemorySpan to a Span and passes it to the Reporter.report(Object).

Specified by:

onSpanFinished in interface InMemorySpanEventListener

Parameters:

span - the span

durationMicros - duration in microseconds

close

public void close()

Blocking close method delegates to closeAsync().

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

closeAsync

public Completable closeAsync()

Attempts to close the configured Reporter.

Specified by:

closeAsync in interface AsyncCloseable

Returns:

a Completable that is completed when the close is done

closeAsyncGracefully

public Completable closeAsyncGracefully()

Attempts to flush and close the configured Reporter.

Specified by:

closeAsyncGracefully in interface AsyncCloseable

Returns:

a Completable that is completed when the flush and close is done