parent
211c2369aa
commit
242714224b
|
|
@ -105,7 +105,6 @@ For additional details reference the [RabbitMQ Management HTTP Stats][management
|
|||
- sockets_used (int, sockets)
|
||||
- running (int, node up)
|
||||
- uptime (int, milliseconds)
|
||||
- health_check_status (int, 1 or 0)
|
||||
- mnesia_disk_tx_count (int, number of disk transaction)
|
||||
- mnesia_ram_tx_count (int, number of ram transaction)
|
||||
- mnesia_disk_tx_count_rate (float, number of disk transaction per second)
|
||||
|
|
|
|||
|
|
@ -508,19 +508,6 @@ func gatherNodes(r *RabbitMQ, acc telegraf.Accumulator) {
|
|||
"running": boolToInt(node.Running),
|
||||
}
|
||||
|
||||
var health HealthCheck
|
||||
err := r.requestJSON("/api/healthchecks/node/"+node.Name, &health)
|
||||
if err != nil {
|
||||
acc.AddError(err)
|
||||
return
|
||||
}
|
||||
|
||||
if health.Status == "ok" {
|
||||
fields["health_check_status"] = int64(1)
|
||||
} else {
|
||||
fields["health_check_status"] = int64(0)
|
||||
}
|
||||
|
||||
var memory MemoryResponse
|
||||
err = r.requestJSON("/api/nodes/"+node.Name+"/memory", &memory)
|
||||
if err != nil {
|
||||
|
|
|
|||
|
|
@ -26,8 +26,6 @@ func TestRabbitMQGeneratesMetrics(t *testing.T) {
|
|||
jsonFilePath = "testdata/queues.json"
|
||||
case "/api/exchanges":
|
||||
jsonFilePath = "testdata/exchanges.json"
|
||||
case "/api/healthchecks/node/rabbit@vagrant-ubuntu-trusty-64":
|
||||
jsonFilePath = "testdata/healthchecks.json"
|
||||
case "/api/federation-links":
|
||||
jsonFilePath = "testdata/federation-links.json"
|
||||
case "/api/nodes/rabbit@vagrant-ubuntu-trusty-64/memory":
|
||||
|
|
@ -119,7 +117,6 @@ func TestRabbitMQGeneratesMetrics(t *testing.T) {
|
|||
"sockets_used": 45,
|
||||
"uptime": 7464827,
|
||||
"running": 1,
|
||||
"health_check_status": 1,
|
||||
"mnesia_disk_tx_count": 16,
|
||||
"mnesia_ram_tx_count": 296,
|
||||
"mnesia_disk_tx_count_rate": 1.1,
|
||||
|
|
|
|||
|
|
@ -1 +0,0 @@
|
|||
{"status":"ok"}
|
||||
Loading…
Reference in New Issue