observability/me.ahoo.wow.observability/WowMetrics

WowMetrics

@InternalWowApi

object WowMetrics

The catalog of Wow's Micrometer metrics, each a MetricSpec that registers it, in OpenTelemetry's form:

a name is wow.<domain>.<noun>, lower case, dot-separated, snake_case within a segment, and is no other metric's namespace;
a duration is .duration; a counter of events is a plural noun; no name carries a unit or a .count/.total suffix, which an exporter adds (Prometheus' _seconds, _total);
no name is an error code's;
a metric's tags are its own, each an attribute of Wow's spans (WowAttributes) or of a convention whose values are bounded: never an identifier (IDENTIFIERS). A tag whose values the framework names (an outcome, a kind, a reason) lists them (MetricSpec.values), lower case, one word per concept.

Properties

ACCESS_STAMP_DURATION

val ACCESS_STAMP_DURATION: MetricSpec

val ACCESS_STAMPED: MetricSpec

ACCESS_WALK_PENDING

val ACCESS_WALK_PENDING: MetricSpec

ACCESS_WALK_WALKED

val ACCESS_WALK_WALKED: MetricSpec

val ACCESS_WALKED: MetricSpec

const val AGGREGATE: String

val ALL: List<MetricSpec>

Every metric above.

APPEND_QUEUE_DEPTH

val APPEND_QUEUE_DEPTH: MetricSpec

val BACKLOG: MetricSpec

BACKPRESSURE_REFUSALS

val BACKPRESSURE_REFUSALS: MetricSpec

const val CAPABILITY: String

COMMAND_DURATION

val COMMAND_DURATION: MetricSpec

COMMAND_REFUSALS

val COMMAND_REFUSALS: MetricSpec

COMMAND_REJECTIONS

val COMMAND_REJECTIONS: MetricSpec

const val CONTEXT: String

const val DATASET: String

DATASET_QUERY_DURATION

val DATASET_QUERY_DURATION: MetricSpec

const val ERROR_TYPE: String

OpenTelemetry's attribute of an error's type: the problem code of a refusal.

EXECUTOR_IN_FLIGHT

val EXECUTOR_IN_FLIGHT: MetricSpec

val EXECUTOR_LANES: MetricSpec

val FATAL_ERRORS: MetricSpec

FORWARD_FAILURES

val FORWARD_FAILURES: MetricSpec

const val GROUP: String

val IDENTIFIERS: Set<String>

The attributes of a span no metric carries: one value per aggregate, command, request or timer.

const val KIND: String

val OFFSET_GAPS: MetricSpec

const val OUTCOME: String

PARKED_AGGREGATES

val PARKED_AGGREGATES: MetricSpec

val PARKED_NOTICES: MetricSpec

const val PARKED_OUTCOME: String

const val PARTITION: String

const val PAUSED_KIND: String

val PAUSED_NOTICES: MetricSpec

PAUSED_PARTITIONS

val PAUSED_PARTITIONS: MetricSpec

val POSITION: MetricSpec

val PROGRESS: MetricSpec

val QUERY_DURATION: MetricSpec

QUERY_LIMIT_CURRENT

val QUERY_LIMIT_CURRENT: MetricSpec

QUERY_LIMIT_DECREASES

val QUERY_LIMIT_DECREASES: MetricSpec

val QUERY_PRESSURE: MetricSpec

const val QUERY_TYPE: String

const val REASON: String

RESERVATION_LOSSES

val RESERVATION_LOSSES: MetricSpec

const val RESUMED_KIND: String

val SIGNAL_DROPS: MetricSpec

SKIPPED_OUTCOME

const val SKIPPED_OUTCOME: String

const val STAGE: String

STATE_CACHE_EVICTIONS

val STATE_CACHE_EVICTIONS: MetricSpec

STATE_CACHE_INVALIDATIONS

val STATE_CACHE_INVALIDATIONS: MetricSpec

STATE_CACHE_LOOKUPS

val STATE_CACHE_LOOKUPS: MetricSpec

const val STORE: String

STORE_FALLBACKS

val STORE_FALLBACKS: MetricSpec

const val SUBSCRIPTION: String

SUBSCRIPTION_LAG

val SUBSCRIPTION_LAG: MetricSpec

val Stage.tagValue: String

A wait's stage as its metric names it.

val QueryType.tagValue: String

A query's type as its metric and its span name it.

val ParkedNotice.Kind.tagValue: String

A parked notice's kind as its metric names it.

val TAIL_READS: MetricSpec

const val THROTTLED_KIND: String

THROTTLED_NOTICES

val THROTTLED_NOTICES: MetricSpec

THROTTLED_PARTITIONS

val THROTTLED_PARTITIONS: MetricSpec

val TIMER_DELAY: MetricSpec

const val TOPIC: String

The topic a message came from.

UNDECODABLE_MESSAGES

val UNDECODABLE_MESSAGES: MetricSpec

UNTHROTTLED_KIND

const val UNTHROTTLED_KIND: String

val WAIT_TIMEOUTS: MetricSpec