observability/me.ahoo.wow.observability/OtelQueryObserver

OtelQueryObserver

class OtelQueryObserver(openTelemetry: OpenTelemetry, meters: MeterRegistry) : QueryObserver

Observes every query a gateway runs: a span query <context>.<aggregate> with its query type, the child of the span the query is asked in, and its time in the WowMetrics.QUERY_DURATION timer of meters, tagged with how it ended: ok, cached, error or cancelled. A query of a dataset is tagged with the dataset (WowMetrics.DATASET) instead of an aggregate type, and timed in WowMetrics.DATASET_QUERY_DURATION.

Constructors

OtelQueryObserver

constructor(openTelemetry: OpenTelemetry, meters: MeterRegistry)

Functions

start

open override fun start(aggregateType: AggregateType, queryType: QueryType, model: QueryModel): Observation