Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore: queue_state metric use 1 for running/idle, 0 for flow/etc #415

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

chore: queue_state metric use 1 for running/idle, 0 for flow/etc #415

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 9 additions & 2 deletions exporter_queue.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ func newExporterQueue() Exporter {
limitsGauge: litmitsGaugeVecActual,
queueMetricsGauge: queueGaugeVecActual,
queueMetricsCounter: queueCounterVecActual,
stateMetric: newGaugeVec("queue_state", "A metric with a value of constant '1' if the queue is in a certain state", append(queueLabels, "state")),
stateMetric: newGaugeVec("queue_state", "A metric with a value of queue state, 1(running,idle), 0(flow,blocked,unblocked)", append(queueLabels, "state")),
idleSinceMetric: newGaugeVec("queue_idle_since_seconds", "starttime where the queue switched to idle state; in seconds since epoch (1970).", queueLabels),
}
}
Expand Down Expand Up @@ -212,7 +212,14 @@ func (e exporterQueue) Collect(ctx context.Context, ch chan<- prometheus.Metric)
log.WithError(err).WithField("idle_since", idleSince).Warn("error parsing idle since time")
}
}
e.stateMetric.WithLabelValues(append(labelValues, state)...).Set(1)

switch state {
case "idle", "running":
e.stateMetric.WithLabelValues(append(labelValues, state)...).Set(1)
default:
// flow,blocked,unblocked
e.stateMetric.WithLabelValues(append(labelValues, state)...).Set(0)
}

if _, ok := limitsGaugeVec["max-length"]; ok {
if f := collectLowerMetric("arguments.x-max-length", "effective_policy_definition.max-length", queue); f >= 0 {
Expand Down
2 changes: 1 addition & 1 deletion metrics.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ metric | description
|queue_max_length|How many (ready) messages a queue can contain before it starts to drop them from its head.|
|queue_idle_since_seconds|starttime where the queue switched to idle state; seconds since epoch (1970); only set if queue state is idle|
|queue_reductions_total|Number of reductions which take place on this process.|
|queue_state|A metric with a value of constant '1' if the queue is in a certain state. Labels: vhost, queue, *state* (running, idle, flow,..)|
|queue_state|A metric with a value of queue state, 1(running,idle), 0(flow,blocked,unblocked) Labels: vhost, queue, *state* (running, idle, flow,..)|
|queue_slave_nodes_len|Number of slave nodes attached to the queue|
|queue_synchronised_slave_nodes_len|Number of slave nodes in sync to the queue|

Expand Down