QueueMetricsModule

PackageAxial.Telemetry

OpenTelemetry-compatible queue and hub-subscription metrics on the Axial meter.

Summary

Name	Signature	Synopsis
Operations
observe	QueueMetrics.observe name queue	Reports a queue's metrics under name until the current scope closes.

Operations

kind:member

observe

QueueMetrics.observe name queue

Member

Reports a queue's metrics under name until the current scope closes.

Parameters

Name	Type	Description
name	string	The value of the `axial.queue.name` tag.
queue	Dequeue<'a>	The queue or subscription to report.

Returns

Flow<'env, 'error, unit>

Verification Examples

flow {
    let! history = readings |> Hub.subscribe (QueueStrategy.BackPressure 10_000)
    do! history |> QueueMetrics.observe "historian"
    do! history |> FlowStream.fromDequeue |> FlowStream.runForEachFlow record
}