go-pkg/asynqmon
2
0
Fork 0
mirror of https://github.com/hibiken/asynqmon.git synced 2025-10-26 08:16:10 +08:00
Code Issues Projects Releases Wiki Activity

Add Queue Latency chart

Browse Source
This commit is contained in:
Ken Hibino
2021-12-12 07:08:31 -08:00
parent 110ab4167c
commit fcd9708f0a
7 changed files with 64 additions and 77 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
metrics_handler.go
View File

@@ -13,6 +13,7 @@ import (
type getMetricsResponse struct {
QueueSize *json.RawMessage `json:"queue_size"`
QueueLatency *json.RawMessage `json:"queue_latency_seconds"`
PendingTasksByQueue *json.RawMessage `json:"pending_tasks_by_queue"`
RetryTasksByQueue *json.RawMessage `json:"retry_tasks_by_queue"`
ArchivedTasksByQueue *json.RawMessage `json:"archived_tasks_by_queue"`
@@ -46,6 +47,7 @@ func newGetMetricsHandlerFunc(client *http.Client, prometheusAddr string) http.H
// List of queries (i.e. promQL) to send to prometheus server.
queries := []string{
"asynq_queue_size",
"asynq_queue_latency_seconds",
"asynq_tasks_enqueued_total{state=\"pending\"}",
"asynq_tasks_enqueued_total{state=\"retry\"}",
"asynq_tasks_enqueued_total{state=\"archived\"}",
@@ -71,6 +73,8 @@ func newGetMetricsHandlerFunc(client *http.Client, prometheusAddr string) http.H
switch r.query {
case "asynq_queue_size":
resp.QueueSize = r.msg
case "asynq_queue_latency_seconds":
resp.QueueLatency = r.msg
case "asynq_tasks_enqueued_total{state=\"pending\"}":
resp.PendingTasksByQueue = r.msg
case "asynq_tasks_enqueued_total{state=\"retry\"}":