ContainerID attempts to return the container ID from /proc/self/cgroup or empty on failure.

ContextWithPathway returns a copy of the given context which includes the pathway p.

Decode decodes a pathway.

DecodeStr decodes a pathway context from a string using base64 encoding.

Flush triggers a flush and waits for it to complete.

Merge merges multiple pathways into one.

contained in all contexts.

NewPathway creates a new pathway.

PathwayFromContext returns the pathway contained in the given context, and whether a pathway is found in ctx.

SetCheckpoint sets a checkpoint on the pathway found in ctx.

Start starts the data streams stats aggregator that will record pipeline stats and send them to the agent.

Stop stops the data streams stats aggregator.

WithAgentAddr sets the address where the agent is located.

WithAgentless starts the data streams stats aggregator in a mode where stats are sent directly to the datadog backend instead of going through the agent.

WithDogstatsdAddress specifies the address to connect to for sending metrics to the Datadog Agent.

WithEnv sets the environment to which all traces started by the tracer will be submitted.

WithHTTPClient specifies the HTTP client to use when communicating with the agent.

WithService sets the default service name for the program.

WithSite starts the data streams stats aggregator with a given site to send data to.

PropagationKey is the key to use to propagate the pathway between services.

TimestampTypeCurrent is for when the recorded timestamp is based on the timestamp of the current StatsPoint.

TimestampTypeOrigin is for when the recorded timestamp is based on the time that the first StatsPoint in the pathway is sent out.

Backlog represents the size of a queue that hasn't been yet read by the consumer.

Pathway is used to monitor how payloads are sent across different services.

StatsBucket specifies a set of stats computed over a duration.

StatsPayload stores client computed stats.

StatsPoint contains a set of statistics grouped under various aggregation keys.

StartOption represents a function that can be provided as a parameter to Start.

TimestampType can be either current or origin.