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

ZipkinReporterService

class ZipkinReporterService(url: String, initBlock: ZipkinReporterService.() -> Unit = {}) : 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.

Parameters

url

The full URL of the Zipkin collector endpoint.

initBlock

An optional initialization block invoked after the service listener is registered.

Constructors

ZipkinReporterService

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

Types

Companion

object Companion

Properties

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): 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(maxWait: Duration)

state

fun state(): Service.State?

stopAsync

@CanIgnoreReturnValue

fun stopAsync(): Service?

stopSync

fun stopSync(maxWait: Duration)

toString

open override fun toString(): String