blob: 871dfd57eef28b40bde3d162e6f8fbaee7703073 (
plain)
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
78
79
80
81
82
|
// SPDX-License-Identifier: GPL-3.0-or-later
package rabbitmq
// https://www.rabbitmq.com/monitoring.html#cluster-wide-metrics
type overviewStats struct {
ObjectTotals struct {
Consumers int64 `json:"consumers" stm:"consumers"`
Queues int64 `json:"queues" stm:"queues"`
Exchanges int64 `json:"exchanges" stm:"exchanges"`
Connections int64 `json:"connections" stm:"connections"`
Channels int64 `json:"channels" stm:"channels"`
} `json:"object_totals" stm:"object_totals"`
ChurnRates struct {
ChannelClosed int64 `json:"channel_closed" stm:"channel_closed"`
ChannelCreated int64 `json:"channel_created" stm:"channel_created"`
ConnectionClosed int64 `json:"connection_closed" stm:"connection_closed"`
ConnectionCreated int64 `json:"connection_created" stm:"connection_created"`
QueueCreated int64 `json:"queue_created" stm:"queue_created"`
QueueDeclared int64 `json:"queue_declared" stm:"queue_declared"`
QueueDeleted int64 `json:"queue_deleted" stm:"queue_deleted"`
} `json:"churn_rates" stm:"churn_rates"`
QueueTotals struct {
Messages int64 `json:"messages" stm:"messages"`
MessagesReady int64 `json:"messages_ready" stm:"messages_ready"`
MessagesUnacknowledged int64 `json:"messages_unacknowledged" stm:"messages_unacknowledged"`
} `json:"queue_totals" stm:"queue_totals"`
MessageStats messageStats `json:"message_stats" stm:"message_stats"`
Node string
}
// https://www.rabbitmq.com/monitoring.html#node-metrics
type nodeStats struct {
FDTotal int64 `json:"fd_total" stm:"fd_total"`
FDUsed int64 `json:"fd_used" stm:"fd_used"`
MemLimit int64 `json:"mem_limit" stm:"mem_limit"`
MemUsed int64 `json:"mem_used" stm:"mem_used"`
SocketsTotal int64 `json:"sockets_total" stm:"sockets_total"`
SocketsUsed int64 `json:"sockets_used" stm:"sockets_used"`
ProcTotal int64 `json:"proc_total" stm:"proc_total"`
ProcUsed int64 `json:"proc_used" stm:"proc_used"`
DiskFree int64 `json:"disk_free" stm:"disk_free"`
RunQueue int64 `json:"run_queue" stm:"run_queue"`
}
type vhostStats struct {
Name string `json:"name"`
Messages int64 `json:"messages" stm:"messages"`
MessagesReady int64 `json:"messages_ready" stm:"messages_ready"`
MessagesUnacknowledged int64 `json:"messages_unacknowledged" stm:"messages_unacknowledged"`
MessageStats messageStats `json:"message_stats" stm:"message_stats"`
}
// https://www.rabbitmq.com/monitoring.html#queue-metrics
type queueStats struct {
Name string `json:"name"`
Vhost string `json:"vhost"`
State string `json:"state"`
Type string `json:"type"`
Messages int64 `json:"messages" stm:"messages"`
MessagesReady int64 `json:"messages_ready" stm:"messages_ready"`
MessagesUnacknowledged int64 `json:"messages_unacknowledged" stm:"messages_unacknowledged"`
MessagesPagedOut int64 `json:"messages_paged_out" stm:"messages_paged_out"`
MessagesPersistent int64 `json:"messages_persistent" stm:"messages_persistent"`
MessageStats messageStats `json:"message_stats" stm:"message_stats"`
}
// https://rawcdn.githack.com/rabbitmq/rabbitmq-server/v3.11.5/deps/rabbitmq_management/priv/www/api/index.html
type messageStats struct {
Ack int64 `json:"ack" stm:"ack"`
Publish int64 `json:"publish" stm:"publish"`
PublishIn int64 `json:"publish_in" stm:"publish_in"`
PublishOut int64 `json:"publish_out" stm:"publish_out"`
Confirm int64 `json:"confirm" stm:"confirm"`
Deliver int64 `json:"deliver" stm:"deliver"`
DeliverNoAck int64 `json:"deliver_no_ack" stm:"deliver_no_ack"`
Get int64 `json:"get" stm:"get"`
GetNoAck int64 `json:"get_no_ack" stm:"get_no_ack"`
DeliverGet int64 `json:"deliver_get" stm:"deliver_get"`
Redeliver int64 `json:"redeliver" stm:"redeliver"`
ReturnUnroutable int64 `json:"return_unroutable" stm:"return_unroutable"`
}
|
