firehol/netdata

// 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"`
}