KubeMQ
ConnectorsAWS (SQS & SNS)Reference

Connections & Observability

The AWS connector's observability surface — the read-only management API, the Prometheus metrics, the dashboard page, and the audit events it emits.

This reference documents the AWS connector's observability surface: the read-only management API, the Prometheus metrics, the dashboard page, and the audit events. The management APIs live on the internal API port and are network-protected.

Management API

A read-only management API summarizes connector activity:

EndpointReturns
GET /api/aws/overviewaggregate counts (queues / topics / subscriptions / in-flight / active long polls) + waiting-message counts (fed by the 2 s stats cache)
GET /api/aws/operationsper-operation counters keyed {service}/{op} (e.g. sqs/send_message, sns/publish)
GET /api/aws/operations/:service/:opa single operation's counters (e.g. /api/aws/operations/sqs/send_message)

Use the overview to confirm the connector accepted traffic after an upgrade.

Prometheus metrics

Counters

MetricMeaning
kubemq_aws_operations_total{service,operation,status}operations, by service / op / status
kubemq_aws_sns_deliveries_total{result}SNS deliveries, by result
kubemq_aws_sns_delivery_dropped_totalSNS deliveries dropped (job-queue overflow / unrecoverable)

Histogram

MetricMeaning
kubemq_aws_operation_duration_secondsper-operation latency

Gauges

MetricMeaning
kubemq_aws_queuesregistered queues
kubemq_aws_topicsregistered topics
kubemq_aws_subscriptionsregistered subscriptions
kubemq_aws_inflightin-flight (received-but-not-deleted) messages
kubemq_aws_active_long_pollsparked long-poll slots in use

There is no CloudWatch metrics emulation — Prometheus is the metrics surface. See Capabilities.

Dashboard

The KubeMQ dashboard has an /aws page backed by the management API above.

Audit events

The connector emits audit events for control-plane operations (data-plane SQS sends/receives are not audited):

EventWhen
aws.auth.failurea SigV4 / authorization failure
aws.queue.*queue lifecycle (create / delete / tag / purge)
aws.topic.*topic lifecycle
aws.sub.*subscription lifecycle (subscribe / confirm / unsubscribe)
aws.registry.conflicta registry conflict (e.g. registry-sync conflict resolution)

Stats cache

The ApproximateNumberOfMessages attribute and the overview waiting counts are fed by a stats cache that wraps the broker queue stats with a 2 s TTL plus duplicate-call suppression.

Was this page helpful?

On this page