Modules
Data Streams Monitoring for Broadway pipelines.
Aggregates checkpoints into ten-second buckets and flushes them to the agent.
Runs the aggregator for the lifetime of the application.
The seam where checkpoints are recorded.
The default backend: the library's enabled flag and its shared aggregator.
Broker-specific carriers for the pathway header.
The flat carrier: a Pub/Sub attribute map or a Kafka/RabbitMQ header list.
The SQS carrier: a BroadwaySQS message_attributes map whose _datadog
attribute carries a JSON object mapping header keys to their values.
The consume and produce checkpoints of a message, without knowing the broker.
The settings that configure the library.
The pathway the current process is producing from.
The behaviour that tells the library what a Broadway message is.
The extractor for BroadwayCloudPubSub v2.
The extractor for BroadwayKafka 0.7.1.
The extractor for BroadwayRabbitMQ (tested against 0.8.2, over amqp).
The extractor for BroadwaySQS 1.0.
A pathway is the chain of nodes a payload passes through: the producer, the broker edge, the consumer, and so on.
The MsgPack body the Datadog Agent forwards to the pipeline stats intake.
The pathway header codec.
The behaviour that names the service a checkpoint is reported under.
A DDSketch distribution: values are counted in logarithmically sized bins so that a whole distribution serialises into a compact protobuf message.
The canonical tag vocabulary, encoded as key:value strings.
Testing support for a host application.
An owner-scoped backend that records checkpoints per test, with
NimbleOwnership.
How a payload reaches the Datadog Agent.
A transport that reports each flush on telemetry instead of posting it.
The default agent transport, backed by Req.