FluxMQ
ReferenceAdmin API

Admin

Broker statistics, cluster topology, and combined overview

Broker statistics

GET
/api/v1/stats

Response Body

application/json

application/json

application/json

curl -X GET "http://localhost:8082/api/v1/stats"
{
  "uptime_seconds": 86400.5,
  "connections": {
    "current": 342,
    "total": 15000,
    "disconnections": 14658
  },
  "messages": {
    "received": 1250000,
    "sent": 980000
  },
  "bytes": {
    "received": 524288000,
    "sent": 412000000
  },
  "errors": {
    "protocol": 12
  },
  "by_protocol": {
    "mqtt": {
      "connections": {
        "current": 342,
        "total": 15000,
        "disconnections": 14658
      },
      "messages": {
        "received": 1100000,
        "sent": 850000,
        "publish_received": 1000000,
        "publish_sent": 800000
      },
      "bytes": {
        "received": 524288000,
        "sent": 412000000
      },
      "subscriptions": {
        "active": 1200,
        "retained_messages": 45
      },
      "errors": {
        "protocol": 12,
        "auth": 5,
        "authz": 3,
        "packet": 8
      }
    },
    "amqp": {
      "connections": {
        "current": 342,
        "total": 15000,
        "disconnections": 14658
      },
      "messages": {
        "received": 1250000,
        "sent": 980000
      },
      "bytes": {
        "received": 524288000,
        "sent": 412000000
      },
      "channels": 42,
      "consumers": 15,
      "errors": {
        "protocol": 12
      }
    }
  }
}
{
  "error": "broker not available"
}
{
  "error": "broker not available"
}

Cluster topology

GET
/api/v1/cluster

Response Body

application/json

application/json

application/json

curl -X GET "http://localhost:8082/api/v1/cluster"
{
  "node_id": "node-1",
  "cluster_mode": true,
  "is_leader": true,
  "nodes": [
    {
      "id": "node-1",
      "address": "10.0.0.1:7946",
      "healthy": true,
      "leader": true,
      "uptime_seconds": 86400.5
    }
  ]
}
{
  "error": "broker not available"
}
{
  "error": "broker not available"
}

Dashboard overview

GET
/api/v1/overview

Response Body

application/json

application/json

application/json

curl -X GET "http://localhost:8082/api/v1/overview"
{
  "node_id": "node-1",
  "cluster_mode": true,
  "is_leader": true,
  "uptime_seconds": 86400.5,
  "sessions": {
    "connected": 342,
    "total": 500
  },
  "stats": {
    "uptime_seconds": 86400.5,
    "connections": {
      "current": 342,
      "total": 15000,
      "disconnections": 14658
    },
    "messages": {
      "received": 1250000,
      "sent": 980000
    },
    "bytes": {
      "received": 524288000,
      "sent": 412000000
    },
    "errors": {
      "protocol": 12
    },
    "by_protocol": {
      "mqtt": {
        "connections": {
          "current": 342,
          "total": 15000,
          "disconnections": 14658
        },
        "messages": {
          "received": 1100000,
          "sent": 850000,
          "publish_received": 1000000,
          "publish_sent": 800000
        },
        "bytes": {
          "received": 524288000,
          "sent": 412000000
        },
        "subscriptions": {
          "active": 1200,
          "retained_messages": 45
        },
        "errors": {
          "protocol": 12,
          "auth": 5,
          "authz": 3,
          "packet": 8
        }
      },
      "amqp": {
        "connections": {
          "current": 342,
          "total": 15000,
          "disconnections": 14658
        },
        "messages": {
          "received": 1250000,
          "sent": 980000
        },
        "bytes": {
          "received": 524288000,
          "sent": 412000000
        },
        "channels": 42,
        "consumers": 15,
        "errors": {
          "protocol": 12
        }
      }
    }
  },
  "cluster": {
    "nodes": [
      {
        "id": "node-1",
        "address": "10.0.0.1:7946",
        "healthy": true,
        "leader": true,
        "uptime_seconds": 86400.5
      }
    ]
  }
}
{
  "error": "broker not available"
}
{
  "error": "broker not available"
}