service-utils/com.pambrose.common.service/ZipkinReporterService

ZipkinReporterService

class ZipkinReporterService : GenericIdleService

A Guava GenericIdleService that manages a Zipkin span reporter lifecycle.

Creates an OkHttpSender and AsyncReporter for sending trace spans to a Zipkin server, and provides a factory method for creating Tracing instances bound to this reporter. Stopping the service sends the spans still queued before closing the reporter.

Constructors

constructor(url: String, defaultServiceName: String = DEFAULT_SERVICE_NAME, initBlock: ZipkinReporterService.() -> Unit = {})

Creates a reporter that sends spans to the Zipkin collector at url.

Types

Companion

object Companion

Properties

defaultServiceName

val defaultServiceName: String

The service name newTracing uses when none is given.

isRunning

val isRunning: Boolean

Functions

addListener

fun addListener(listener: Service.Listener?, executor: Executor?)

awaitRunning

fun awaitRunning()

fun awaitRunning(timeout: Duration?)

fun awaitRunning(timeout: Long, unit: TimeUnit?)

awaitTerminated

fun awaitTerminated()

fun awaitTerminated(timeout: Duration?)

fun awaitTerminated(timeout: Long, unit: TimeUnit?)

failureCause

fun failureCause(): Throwable?

newTracing

fun newTracing(serviceName: String = defaultServiceName): Tracing

Creates a new Tracing instance configured with the given service name and this reporter's span handler.

startAsync

@CanIgnoreReturnValue

fun startAsync(): Service?

startSync

fun startSync(timeout: Duration)

state

fun state(): Service.State?

stopAsync

@CanIgnoreReturnValue

fun stopAsync(): Service?

stopSync

fun stopSync(timeout: Duration)

toString

open override fun toString(): String