MetricsSettingsProvider faststream.prometheus.provider.MetricsSettingsProvider # Bases: Protocol[MsgType] messaging_system instance-attribute # messaging_system get_consume_attrs_from_message # get_consume_attrs_from_message(msg) Source code in faststream/prometheus/provider.py 14 15 16 17def get_consume_attrs_from_message( self, msg: "StreamMessage[MsgType]", ) -> "ConsumeAttrs": ... get_publish_destination_name_from_kwargs # get_publish_destination_name_from_kwargs(kwargs) Source code in faststream/prometheus/provider.py 19 20 21 22def get_publish_destination_name_from_kwargs( self, kwargs: "AnyDict", ) -> str: ...