Package io.servicetalk.opentracing.zipkin.publisher.reporter

Class HttpReporter

java.lang.Object

zipkin2.Component

io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter

All Implemented Interfaces:

AsyncCloseable, Closeable, AutoCloseable, zipkin2.reporter.Reporter<zipkin2.Span>

public final class HttpReporter
extends zipkin2.Component
implements zipkin2.reporter.Reporter<zipkin2.Span>, AsyncCloseable

A Span Reporter that will publish to an HTTP endpoint with a configurable encoding Codec.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	HttpReporter.Builder	A builder to create a new HttpReporter.

Field Summary

Fields inherited from interface zipkin2.reporter.Reporter

CONSOLE, NOOP

Method Summary

Modifier and Type	Method	Description
zipkin2.CheckResult	check()
void	close()
Completable	closeAsync()	Used to close/shutdown a resource.
Completable	closeAsyncGracefully()	Used to close/shutdown a resource, similar to AsyncCloseable.closeAsync(), but attempts to cleanup state before abruptly closing.
void	report(zipkin2.Span span)

Methods inherited from class java.lang.Object

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

Method Details

check

public zipkin2.CheckResult check()

Overrides:

check in class zipkin2.Component

report

public void report(zipkin2.Span span)

Specified by:

report in interface zipkin2.reporter.Reporter<zipkin2.Span>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class zipkin2.Component

closeAsync

public Completable closeAsync()

Description copied from interface: AsyncCloseable

Used to close/shutdown a resource.

Specified by:

closeAsync in interface AsyncCloseable

Returns:

A Completable that is notified once the close is complete.

closeAsyncGracefully

public Completable closeAsyncGracefully()

Description copied from interface: AsyncCloseable

Used to close/shutdown a resource, similar to AsyncCloseable.closeAsync(), but attempts to cleanup state before abruptly closing. This provides a hint that implementations can use to stop accepting new work and finish in flight work. This method is implemented on a "best effort" basis and may be equivalent to AsyncCloseable.closeAsync().

Note: Implementations may or may not apply a timeout for this operation to complete, if a caller does not want to wait indefinitely, and are unsure if the implementation applies a timeout, it is advisable to apply a timeout and force a call to AsyncCloseable.closeAsync().

Specified by:

closeAsyncGracefully in interface AsyncCloseable

Returns:

A Completable that is notified once the close is complete.