OpenFactory Asset Forwarder Metrics#

Prometheus metrics for the Asset Forwarder service.

Exported metrics#

Build and service information:

  • BUILD_INFO - Build information for the running service.

Kafka metrics:

  • KAFKA_MESSAGES_CONSUMED - Total number of messages consumed from Kafka.

  • KAFKA_ERRORS - Total number of Kafka consumer errors.

  • INVALID_MESSAGES - Total number of invalid Kafka messages consumed.

NATS metrics:

  • NATS_MESSAGES_PUBLISHED - Total number of messages successfully published to NATS.

  • NATS_PUBLISH_FAILURES - Total number of failed publish attempts to NATS.

Queue metrics:

  • QUEUE_TIME_SECONDS - Time messages spend waiting in the forwarder queue before processing.

  • MESSAGE_PROCESSING_LATENCY - End-to-end worker processing latency.

  • QUEUE_SIZE - Current number of messages waiting in the queue.

  • QUEUE_SIZE_HISTOGRAM - Distribution of queue backlog size.

The metrics_endpoint() function exposes all registered metrics in Prometheus text exposition format.

openfactory.fanoutlayer.asset_forwarder.src.asset_forwarder_metrics.metrics_endpoint()[source]#

Return Prometheus metrics in the text exposition format.

Return type:

Response

Returns:

Response – Prometheus metrics response.