Skip to content

Commit

Permalink
app_name EMPTY is default
Browse files Browse the repository at this point in the history
  • Loading branch information
roma-frolov committed Oct 20, 2024
1 parent a9a0156 commit 1de4f58
Show file tree
Hide file tree
Showing 6 changed files with 14 additions and 14 deletions.
4 changes: 2 additions & 2 deletions faststream/confluent/prometheus/middleware.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@ def __init__(
self,
*,
registry: "CollectorRegistry",
app_name: str = "faststream",
metrics_prefix: str = EMPTY,
app_name: str = EMPTY,
metrics_prefix: str = "faststream",
received_messages_size_buckets: Optional[Sequence[float]] = None,
) -> None:
super().__init__(
Expand Down
4 changes: 2 additions & 2 deletions faststream/kafka/prometheus/middleware.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@ def __init__(
self,
*,
registry: "CollectorRegistry",
app_name: str = "faststream",
metrics_prefix: str = EMPTY,
app_name: str = EMPTY,
metrics_prefix: str = "faststream",
received_messages_size_buckets: Optional[Sequence[float]] = None,
) -> None:
super().__init__(
Expand Down
4 changes: 2 additions & 2 deletions faststream/nats/prometheus/middleware.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@ def __init__(
self,
*,
registry: "CollectorRegistry",
app_name: str = "faststream",
metrics_prefix: str = EMPTY,
app_name: str = EMPTY,
metrics_prefix: str = "faststream",
received_messages_size_buckets: Optional[Sequence[float]] = None,
) -> None:
super().__init__(
Expand Down
8 changes: 4 additions & 4 deletions faststream/prometheus/middleware.py
Original file line number Diff line number Diff line change
Expand Up @@ -176,12 +176,12 @@ def __init__(
[Any], Optional[MetricsSettingsProvider[Any]]
],
registry: "CollectorRegistry",
app_name: str = "faststream",
metrics_prefix: str = EMPTY,
app_name: str = EMPTY,
metrics_prefix: str = "faststream",
received_messages_size_buckets: Optional[Sequence[float]] = None,
):
if metrics_prefix is EMPTY:
metrics_prefix = app_name
if app_name is EMPTY:
app_name = metrics_prefix

self._settings_provider_factory = settings_provider_factory
self._metrics_container = MetricsContainer(
Expand Down
4 changes: 2 additions & 2 deletions faststream/rabbit/prometheus/middleware.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@ def __init__(
self,
*,
registry: "CollectorRegistry",
app_name: str = "faststream",
metrics_prefix: str = EMPTY,
app_name: str = EMPTY,
metrics_prefix: str = "faststream",
received_messages_size_buckets: Optional[Sequence[float]] = None,
) -> None:
super().__init__(
Expand Down
4 changes: 2 additions & 2 deletions faststream/redis/prometheus/middleware.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@ def __init__(
self,
*,
registry: "CollectorRegistry",
app_name: str = "faststream",
metrics_prefix: str = EMPTY,
app_name: str = EMPTY,
metrics_prefix: str = "faststream",
received_messages_size_buckets: Optional[Sequence[float]] = None,
) -> None:
super().__init__(
Expand Down

0 comments on commit 1de4f58

Please sign in to comment.