Module dipstick::queue [] [src]

Queue metrics for write on a separate thread, Metrics definitions are still synchronous. If queue size is exceeded, calling code reverts to blocking.

Structs

MetricQueue

A metric command-queue using a sync channel. Each client thread gets it's own scope and sender. Writes are dispatched by a single receiving thread.

QueueCommand

Functions

queue

Cache metrics to prevent them from being re-defined on every use. Use of this should be transparent, this has no effect on the values. Stateful sinks (i.e. Aggregate) may naturally cache their definitions.

Type Definitions

QueueSender

Thread safe sender to the queue