API Reference Data Streams Ex v1.1.2
This is a port of the data-streams-go library to Elixir.
GenServer instance responsible for aggregating many points of data
together into 10 second buckets, and then sending them to the Datadog
agent. It holds many structs in its memory, looking something like this
Responsible for parsing application configuration to usable chunks in the application.
Logic for linking current running container id to data stream traces.
This module deals with storing a
in process, so it can be propagated later on. In Golang, this is handled
Context which is a grab bag that is
passed down the whole calling stack. We don't have an equivalent in Elixir,
so we instead piggy back off of
essentially lets us do the same thing without needing to manually pass
data down the calling stack.
Functions for integrating Kafka tracing with DataStreams.
A pathway is used to monitor how payloads are sent across different services.
Encoding logic for a payload. This is the top level struct we send to Datadog. It wraps all other information. These are primarily sent via MessagePack, although uses Protobuf encoded binary for latency records.
Datadog.DataStreams.Pathway via encoding and adding
to message headers.
A helper module to enumerate and filter over data stream tags.
An HTTP client for Datadog data streams reporting. It uses the
library for requests.
A minimal implementation of the distributed quantile sketch (DDSketch)
algorithm as implemented in the
sketches-go library. For more
information, please read the
Basic module for handling various index mapping algorithms. All functions in this module proxy to the respective index mapping implementation module.
LogarithmicMapping is an IndexMapping that is memory-optimal, that is to say that given a targeted relative accuracy, it requires the least number of indices to cover a given range of values. This is done by logarithmically mapping floating-point values to integers.
Different stores use different data structures and techniques to store data. Each with unique trade offs and memory usage. All functions in this module proxy to the respective index mapping implementation module.
The Dense store is a dynamically growing contiguous (non-sparse) store. The
number of bins are bound only by the size of the
:array that can be allocated.