def __init__(
self,
registry: "CollectorRegistry",
*,
metrics_prefix: str = "faststream",
received_messages_size_buckets: Optional[Sequence[float]] = None,
):
self._registry = registry
self._metrics_prefix = metrics_prefix
self.received_messages_total = cast(
Counter,
self._get_registered_metric(f"{metrics_prefix}_received_messages_total"),
) or Counter(
name=f"{metrics_prefix}_received_messages_total",
documentation="Count of received messages by broker and handler",
labelnames=["app_name", "broker", "handler"],
registry=registry,
)
self.received_messages_size_bytes = cast(
Histogram,
self._get_registered_metric(
f"{metrics_prefix}_received_messages_size_bytes"
),
) or Histogram(
name=f"{metrics_prefix}_received_messages_size_bytes",
documentation="Histogram of received messages size in bytes by broker and handler",
labelnames=["app_name", "broker", "handler"],
registry=registry,
buckets=received_messages_size_buckets or self.DEFAULT_SIZE_BUCKETS,
)
self.received_messages_in_process = cast(
Gauge,
self._get_registered_metric(
f"{metrics_prefix}_received_messages_in_process"
),
) or Gauge(
name=f"{metrics_prefix}_received_messages_in_process",
documentation="Gauge of received messages in process by broker and handler",
labelnames=["app_name", "broker", "handler"],
registry=registry,
)
self.received_processed_messages_total = cast(
Counter,
self._get_registered_metric(
f"{metrics_prefix}_received_processed_messages_total"
),
) or Counter(
name=f"{metrics_prefix}_received_processed_messages_total",
documentation="Count of received processed messages by broker, handler and status",
labelnames=["app_name", "broker", "handler", "status"],
registry=registry,
)
self.received_processed_messages_duration_seconds = cast(
Histogram,
self._get_registered_metric(
f"{metrics_prefix}_received_processed_messages_duration_seconds"
),
) or Histogram(
name=f"{metrics_prefix}_received_processed_messages_duration_seconds",
documentation="Histogram of received processed messages duration in seconds by broker and handler",
labelnames=["app_name", "broker", "handler"],
registry=registry,
)
self.received_processed_messages_exceptions_total = cast(
Counter,
self._get_registered_metric(
f"{metrics_prefix}_received_processed_messages_exceptions_total"
),
) or Counter(
name=f"{metrics_prefix}_received_processed_messages_exceptions_total",
documentation="Count of received processed messages exceptions by broker, handler and exception_type",
labelnames=["app_name", "broker", "handler", "exception_type"],
registry=registry,
)
self.published_messages_total = cast(
Counter,
self._get_registered_metric(f"{metrics_prefix}_published_messages_total"),
) or Counter(
name=f"{metrics_prefix}_published_messages_total",
documentation="Count of published messages by destination and status",
labelnames=["app_name", "broker", "destination", "status"],
registry=registry,
)
self.published_messages_duration_seconds = cast(
Histogram,
self._get_registered_metric(
f"{metrics_prefix}_published_messages_duration_seconds"
),
) or Histogram(
name=f"{metrics_prefix}_published_messages_duration_seconds",
documentation="Histogram of published messages duration in seconds by broker and destination",
labelnames=["app_name", "broker", "destination"],
registry=registry,
)
self.published_messages_exceptions_total = cast(
Counter,
self._get_registered_metric(
f"{metrics_prefix}_published_messages_exceptions_total"
),
) or Counter(
name=f"{metrics_prefix}_published_messages_exceptions_total",
documentation="Count of published messages exceptions by broker, destination and exception_type",
labelnames=["app_name", "broker", "destination", "exception_type"],
registry=registry,
)