wow-core/me.ahoo.wow.metrics/Metrics

Metrics

object Metrics

Properties

const val AGGREGATE_KEY: String

const val COMMAND_KEY: String

val enabled: Boolean

const val EVENT_KEY: String

const val PROCESSOR_KEY: String

const val SOURCE_KEY: String

SUBSCRIBER_CONTEXT_KEY

const val SUBSCRIBER_CONTEXT_KEY: String

const val SUBSCRIBER_KEY: String

Functions

getMetricsSubscriber

fun ContextView.getMetricsSubscriber(): String?

fun <T : Any> T.metrizable(): T

fun DistributedCommandBus.metrizable(): DistributedCommandBus

fun LocalCommandBus.metrizable(): LocalCommandBus

fun DistributedDomainEventBus.metrizable(): DistributedDomainEventBus

fun DomainEventHandler.metrizable(): DomainEventHandler

fun LocalDomainEventBus.metrizable(): LocalDomainEventBus

fun EventStore.metrizable(): EventStore

fun SnapshotHandler.metrizable(): SnapshotHandler

fun SnapshotRepository.metrizable(): SnapshotRepository

fun SnapshotStrategy.metrizable(): SnapshotStrategy

fun DistributedStateEventBus.metrizable(): DistributedStateEventBus

fun LocalStateEventBus.metrizable(): LocalStateEventBus

fun CommandHandler.metrizable(): CommandHandler

fun ProjectionHandler.metrizable(): ProjectionHandler

fun StatelessSagaHandler.metrizable(): StatelessSagaHandler

inline fun <T> T.metrizable(block: (T) -> T): T

setMetricsSubscriber

fun Context.setMetricsSubscriber(metricsSubscriber: String): Context

tagMetricsSubscriber

fun <T> Flux<T>.tagMetricsSubscriber(): Flux<T>

writeMetricsSubscriber

fun <T> Flux<T>.writeMetricsSubscriber(metricsSubscriber: String): Flux<T>