96 lines
2.1 KiB
Erlang
96 lines
2.1 KiB
Erlang
-define(EMPTY_METRICS,
|
|
?METRICS(
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0
|
|
)
|
|
).
|
|
|
|
-define(METRICS(
|
|
Batched,
|
|
Dropped,
|
|
DroppedOther,
|
|
DroppedQueueFull,
|
|
DroppedQueueNotEnabled,
|
|
DroppedResourceNotFound,
|
|
DroppedResourceStopped,
|
|
Matched,
|
|
Queued,
|
|
Retried,
|
|
SentFailed,
|
|
SentInflight,
|
|
SentSucc,
|
|
RATE,
|
|
RATE_5,
|
|
RATE_MAX,
|
|
Rcvd
|
|
),
|
|
#{
|
|
'batching' => Batched,
|
|
'dropped' => Dropped,
|
|
'dropped.other' => DroppedOther,
|
|
'dropped.queue_full' => DroppedQueueFull,
|
|
'dropped.queue_not_enabled' => DroppedQueueNotEnabled,
|
|
'dropped.resource_not_found' => DroppedResourceNotFound,
|
|
'dropped.resource_stopped' => DroppedResourceStopped,
|
|
'matched' => Matched,
|
|
'queuing' => Queued,
|
|
'retried' => Retried,
|
|
'failed' => SentFailed,
|
|
'inflight' => SentInflight,
|
|
'success' => SentSucc,
|
|
rate => RATE,
|
|
rate_last5m => RATE_5,
|
|
rate_max => RATE_MAX,
|
|
received => Rcvd
|
|
}
|
|
).
|
|
|
|
-define(metrics(
|
|
Batched,
|
|
Dropped,
|
|
DroppedOther,
|
|
DroppedQueueFull,
|
|
DroppedQueueNotEnabled,
|
|
DroppedResourceNotFound,
|
|
DroppedResourceStopped,
|
|
Matched,
|
|
Queued,
|
|
Retried,
|
|
SentFailed,
|
|
SentInflight,
|
|
SentSucc,
|
|
RATE,
|
|
RATE_5,
|
|
RATE_MAX,
|
|
Rcvd
|
|
),
|
|
#{
|
|
'batching' := Batched,
|
|
'dropped' := Dropped,
|
|
'dropped.other' := DroppedOther,
|
|
'dropped.queue_full' := DroppedQueueFull,
|
|
'dropped.queue_not_enabled' := DroppedQueueNotEnabled,
|
|
'dropped.resource_not_found' := DroppedResourceNotFound,
|
|
'dropped.resource_stopped' := DroppedResourceStopped,
|
|
'matched' := Matched,
|
|
'queuing' := Queued,
|
|
'retried' := Retried,
|
|
'failed' := SentFailed,
|
|
'inflight' := SentInflight,
|
|
'success' := SentSucc,
|
|
rate := RATE,
|
|
rate_last5m := RATE_5,
|
|
rate_max := RATE_MAX,
|
|
received := Rcvd
|
|
}
|
|
).
|
|
|
|
-define(METRICS_EXAMPLE, #{
|
|
metrics => ?EMPTY_METRICS,
|
|
node_metrics => [
|
|
#{
|
|
node => node(),
|
|
metrics => ?EMPTY_METRICS
|
|
}
|
|
]
|
|
}).
|