Skip to content

Commit 3ede0c0

Browse files
committed
feat(data-pipeline): port dd-trace-rs trace buffer implementation
# Motivation As we implement native spans in ruby in python, we have opportuinities to replace more components of the span pipeline with native code. One of them i the span buffer which we is before the trace exporter. # Changes Add a TraceBuffer implementation. The TraceBuffer is split in two part, a Sender which allows putting trace chunks in the queue and a background task, spawned on the shared runtime which periodically pulls data from the chunk and submit them using the TraceExporter.
1 parent b9fe72e commit 3ede0c0

4 files changed

Lines changed: 833 additions & 2 deletions

File tree

libdd-data-pipeline/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ sha2 = "0.10"
2626
either = "1.13.0"
2727
tokio = { version = "1.23", features = [
2828
"rt",
29+
"sync",
2930
"test-util",
3031
"time",
3132
], default-features = false }

libdd-data-pipeline/src/lib.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,3 +18,4 @@ pub mod stats_exporter;
1818
pub(crate) mod telemetry;
1919
#[allow(missing_docs)]
2020
pub mod trace_exporter;
21+
pub mod trace_buffer;

0 commit comments

Comments
 (0)