MetricsContainer

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,
    )