# DD Data Streams v0.3.0 - API Reference

## Modules

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