faststream.prometheus.manager.MetricsManager #faststream/prometheus/manager.py
add_received_message #
observe_received_messages_size #
add_received_message_in_process #faststream/prometheus/manager.py
remove_received_message_in_process #faststream/prometheus/manager.py
add_received_processed_message #faststream/prometheus/manager.py
observe_received_processed_message_duration #faststream/prometheus/manager.py
add_received_processed_message_exception #faststream/prometheus/manager.py
add_published_message #faststream/prometheus/manager.py
observe_published_message_duration #faststream/prometheus/manager.py
add_published_message_exception #faststream/prometheus/manager.py