1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
package admin
import (
"net/http"
"sort"
"github.com/valinurovam/garagemq/metrics"
"github.com/valinurovam/garagemq/server"
)
type QueuesHandler struct {
amqpServer *server.Server
}
type QueuesResponse struct {
Items []*Queue `json:"items"`
}
type Queue struct {
Name string `json:"name"`
Vhost string `json:"vhost"`
Durable bool `json:"durable"`
AutoDelete bool `json:"auto_delete"`
Exclusive bool `json:"exclusive"`
Counters map[string]*metrics.TrackItem `json:"counters"`
}
func NewQueuesHandler(amqpServer *server.Server) http.Handler {
return &QueuesHandler{amqpServer: amqpServer}
}
func (h *QueuesHandler) ServeHTTP(resp http.ResponseWriter, req *http.Request) {
response := &QueuesResponse{}
for vhostName, vhost := range h.amqpServer.GetVhosts() {
for _, queue := range vhost.GetQueues() {
ready := queue.GetMetrics().Ready.Track.GetLastTrackItem()
total := queue.GetMetrics().Total.Track.GetLastTrackItem()
unacked := queue.GetMetrics().Unacked.Track.GetLastTrackItem()
incoming := queue.GetMetrics().Incoming.Track.GetLastDiffTrackItem()
deliver := queue.GetMetrics().Deliver.Track.GetLastDiffTrackItem()
get := queue.GetMetrics().Get.Track.GetLastDiffTrackItem()
ack := queue.GetMetrics().Ack.Track.GetLastDiffTrackItem()
response.Items = append(
response.Items,
&Queue{
Name: queue.GetName(),
Vhost: vhostName,
Durable: queue.IsDurable(),
AutoDelete: queue.IsAutoDelete(),
Exclusive: queue.IsExclusive(),
Counters: map[string]*metrics.TrackItem{
"ready": ready,
"total": total,
"unacked": unacked,
"get": get,
"ack": ack,
"incoming": incoming,
"deliver": deliver,
},
},
)
}
}
sort.Slice(
response.Items,
func(i, j int) bool {
return response.Items[i].Name > response.Items[j].Name
},
)
JSONResponse(resp, response, 200)
}
|
