Skip to content

Commit

Permalink
spaces for easy reading
Browse files Browse the repository at this point in the history
  • Loading branch information
roma-frolov committed Nov 18, 2024
1 parent c5ffc88 commit 880abab
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions faststream/prometheus/container.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,7 @@ def __init__(
labelnames=["app_name", "broker", "handler"],
registry=registry,
)

self.received_messages_size_bytes = cast(
Histogram,
self._get_registered_metric(
Expand All @@ -68,6 +69,7 @@ def __init__(
registry=registry,
buckets=received_messages_size_buckets or self.DEFAULT_SIZE_BUCKETS,
)

self.received_messages_in_process = cast(
Gauge,
self._get_registered_metric(
Expand All @@ -79,6 +81,7 @@ def __init__(
labelnames=["app_name", "broker", "handler"],
registry=registry,
)

self.received_processed_messages_total = cast(
Counter,
self._get_registered_metric(
Expand All @@ -90,6 +93,7 @@ def __init__(
labelnames=["app_name", "broker", "handler", "status"],
registry=registry,
)

self.received_processed_messages_duration_seconds = cast(
Histogram,
self._get_registered_metric(
Expand All @@ -101,6 +105,7 @@ def __init__(
labelnames=["app_name", "broker", "handler"],
registry=registry,
)

self.received_processed_messages_exceptions_total = cast(
Counter,
self._get_registered_metric(
Expand All @@ -112,6 +117,7 @@ def __init__(
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"),
Expand All @@ -121,6 +127,7 @@ def __init__(
labelnames=["app_name", "broker", "destination", "status"],
registry=registry,
)

self.published_messages_duration_seconds = cast(
Histogram,
self._get_registered_metric(
Expand Down

0 comments on commit 880abab

Please sign in to comment.