telemetry_attributes_provider_factory
faststream.nats.opentelemetry.provider.telemetry_attributes_provider_factory #
telemetry_attributes_provider_factory(msg: Optional[Msg]) -> NatsTelemetrySettingsProvider
telemetry_attributes_provider_factory(msg: Sequence[Msg]) -> NatsBatchTelemetrySettingsProvider
telemetry_attributes_provider_factory(msg: Union[Msg, Sequence[Msg], None]) -> Union[NatsTelemetrySettingsProvider, NatsBatchTelemetrySettingsProvider]