io.servicetalk.opentracing.zipkin.publisher.reporter

Class UdpReporter

java.lang.Object

zipkin2.Component

io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter

All Implemented Interfaces:

AsyncCloseable, java.io.Closeable, java.lang.AutoCloseable, zipkin2.reporter.Reporter<zipkin2.Span>

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

A Span Reporter that will publish to a UDP listener with a configurable encoding Codec.

Nested Class Summary

Nested Classes

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

Field Summary

Fields inherited from interface zipkin2.reporter.Reporter

CONSOLE, NOOP

Method Summary

Modifier and Type	Method and 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 Detail

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 java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

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.