signal.data_platform_telemetry.metrics — com.signal-ai/data-platform-telemetry 0.1.0

*default-registry* clj

add-exponential-buckets-past-maximum clj

(add-exponential-buckets-past-maximum base-buckets)

(add-exponential-buckets-past-maximum base-buckets max-time-seconds)

decrement-messages-in-flight clj

(decrement-messages-in-flight registry)

(decrement-messages-in-flight registry n)

get-default-histogram-buckets clj

(get-default-histogram-buckets {:keys [max-batch-size] :or {max-batch-size 50}})

increment-messages-in-flight clj

(increment-messages-in-flight registry)

(increment-messages-in-flight registry n)

init clj

(init)

(init {:keys [registry ring? jvm?]
       :or {ring? true jvm? true registry *default-registry*}})

Initialises a Prometheus metrics registry and returns it.

message-ack-time clj macro

(message-ack-time registry & body)

message-process-time clj macro

(message-process-time registry & body)

message-publish-time clj macro

(message-publish-time registry & body)

message-read-time clj macro

(message-read-time registry & body)

message-result-write-time clj macro

(message-result-write-time registry & body)

message-total-time clj macro

(message-total-time registry & body)

observe-message-ack-time clj

observe-message-batch-size clj

(observe-message-batch-size registry size)

observe-message-process-time clj

observe-message-publish-time clj

observe-message-read-time clj

observe-message-result-write-time clj

observe-message-total-time clj

observe-queue-worker-error clj

(observe-queue-worker-error registry _)

observe-time-seconds clj

(observe-time-seconds metric registry start-timestamp-ms end-timestamp-ms)

Given a metric name and a start/end timestamp in milliseconds, observes the time in seconds between the two times.

pipeline-latency clj

(pipeline-latency registry {:keys [histogram-buckets-overrides] :as config})

Registers metrics to track latency from point-to-point in a pipeline to the given registry.

document-latency-buckets must be provided - be sure to include the explicit value of any SLOs in your bucket distribution.

queue-reader clj

(queue-reader registry {:keys [histogram-buckets-overrides] :as config})

Registers queue reader metrics on the given registry.

queue-writer clj

(queue-writer registry {:keys [histogram-buckets-overrides] :as config})

Registers queue worker metrics on the given registry.

record-pipeline-metrics-for-complete-document clj

(record-pipeline-metrics-for-complete-document registry
                                               {:keys [mode measured-from]}
                                               received-date-time)

ring-wrap-instrumentation clj

(ring-wrap-instrumentation registry app)

Wraps a ring application in Prometheus instrumentation.

ring-wrap-metrics-expose clj

(ring-wrap-metrics-expose registry app)

Creates a ring handler which exposes Prometheus metrics for the given registry on /internal/metrics.

take-while-and-n-more clj

(take-while-and-n-more pred n coll)