Skip to content

TelemetrySettingsProvider

faststream.opentelemetry.TelemetrySettingsProvider #

Bases: Protocol[MsgType, PublishCommandType_contra]

messaging_system instance-attribute #

messaging_system: str

get_consume_attrs_from_message #

get_consume_attrs_from_message(
    msg: StreamMessage[MsgType],
) -> dict[str, Any]
Source code in faststream/opentelemetry/provider.py 
23
24
25
26
def get_consume_attrs_from_message(
    self,
    msg: "StreamMessage[MsgType]",
) -> dict[str, Any]: ...

get_consume_destination_name #

get_consume_destination_name(
    msg: StreamMessage[MsgType],
) -> str
Source code in faststream/opentelemetry/provider.py 
28
29
30
31
def get_consume_destination_name(
    self,
    msg: "StreamMessage[MsgType]",
) -> str: ...

get_publish_attrs_from_cmd #

get_publish_attrs_from_cmd(
    cmd: PublishCommandType_contra,
) -> dict[str, Any]
Source code in faststream/opentelemetry/provider.py 
33
34
35
36
def get_publish_attrs_from_cmd(
    self,
    cmd: PublishCommandType_contra,
) -> dict[str, Any]: ...

get_publish_destination_name #

get_publish_destination_name(
    cmd: PublishCommandType_contra,
) -> str
Source code in faststream/opentelemetry/provider.py 
38
39
40
41
def get_publish_destination_name(
    self,
    cmd: PublishCommandType_contra,
) -> str: ...