How to make the lateral/horizontal/producer-consumer/message-passing/link span relation:
Producer Side:
Requires an inter-thread/process/service payload dict (carrier)
And one in-line call inject_links_carrier() which will add the necessary info to the carrier
Consumer Side:
Requires the carrier argument in the @spanned() decorator with (1) the name of the inter-thread/process/service payload dict (carrier) variable and (2) an argument indicating that a link is wanted (carrier_relation=CarrierRelation.LINK)
NOTE:
There's also support for multiple links in inject_links_carrier(). I am not sure how these will be useful, but they're included.
I included a RabbitMQ message-passing example, other examples for different setups can be included if there's interest.
This is the complementary PR for https://github.com/WIPACrepo/wipac-telemetry-prototype/pull/18 and completes the initial support for distributed tracing.
How to make the lateral/horizontal/producer-consumer/message-passing/link span relation:
Producer Side:
carrier)inject_links_carrier()which will add the necessary info to the carrierConsumer Side:
@spanned()decorator with (1) the name of the inter-thread/process/service payload dict (carrier) variable and (2) an argument indicating that a link is wanted (carrier_relation=CarrierRelation.LINK)NOTE: There's also support for multiple links in
inject_links_carrier(). I am not sure how these will be useful, but they're included.I included a RabbitMQ message-passing example, other examples for different setups can be included if there's interest.