Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
32 commits
Select commit Hold shift + click to select a range
f5c0208
Add datadog-mock-intake crate for APM payload-level integration tests
lucaspimentel Sep 25, 2026
a21468b
Serve trace-agent integration tests with datadog-mock-intake
lucaspimentel Sep 25, 2026
11fe447
Rename the standalone binary and env vars to mock-intake in crate docs
lucaspimentel Sep 25, 2026
a893f8b
Cap decompressed body size and skip unused dump serialization in mock…
lucaspimentel Sep 25, 2026
35e1043
Abort accepted connections when mock intake is dropped
lucaspimentel Sep 29, 2026
4c2ee5c
Assert no raw stats requests in no-stats integration test
lucaspimentel Sep 29, 2026
c89bc92
Keep mock intake serving after accept errors
lucaspimentel Sep 29, 2026
b311294
Record raw and typed intake captures atomically
lucaspimentel Sep 29, 2026
0a66d33
Decode intake requests off the async runtime
lucaspimentel Sep 29, 2026
2d9882a
Keep non-UTF-8 header values in captured requests
lucaspimentel Sep 29, 2026
04ac689
Name the single capture mutex in panic messages
lucaspimentel Sep 29, 2026
40f7c1a
Describe only this crate's API in mock-intake docs
lucaspimentel Sep 29, 2026
9c24dd0
Apply rustfmt to mock-intake
lucaspimentel Sep 29, 2026
664fb6c
Abort connections racing with MockIntake shutdown
lucaspimentel Sep 29, 2026
f4441d7
fix(mock-intake): reject unsupported content-encoding with 415
lucaspimentel Sep 29, 2026
a7191dd
fix(mock-intake): assign request ids at arrival time
lucaspimentel Sep 29, 2026
eff6ff4
fix(mock-intake): count pipeline stats points in summaries
lucaspimentel Sep 29, 2026
c92ba9b
test(mock-intake): pin AgentPayload JSON dump fields
lucaspimentel Sep 29, 2026
c9a0ebd
test(trace-agent): readable failures for empty decoded captures
lucaspimentel Sep 29, 2026
af94d98
test(trace-agent): import PipelineStats helper types
lucaspimentel Sep 29, 2026
d84a05e
fix(mock-intake): capture concurrent requests in arrival order
lucaspimentel Sep 29, 2026
d8fd441
fix(mock-intake): don't stall on client disconnect
lucaspimentel Sep 30, 2026
b882fe5
fix(mock-intake): log connection errors
lucaspimentel Sep 30, 2026
e70d1ac
test(mock-intake): accept closed socket after Drop
lucaspimentel Sep 30, 2026
a4d92b9
fix(mock-intake): order captures by request start
lucaspimentel Sep 30, 2026
daf34d4
refactor(mock-intake): simplify payload handler plumbing
lucaspimentel Sep 30, 2026
108eda4
refactor: clean up mock intake and test duplication
lucaspimentel Sep 30, 2026
54d0c8e
Show mock intake captures once responded
lucaspimentel Sep 30, 2026
695d446
Wait for stats captures in trace-agent tests
lucaspimentel Sep 30, 2026
098d30d
Fail fast when the mock intake rejects a payload
lucaspimentel Sep 30, 2026
45afb6c
Reject non-UTF-8 Content-Encoding in mock intake
lucaspimentel Sep 30, 2026
d107012
Assert decoded services in dual-transport test
lucaspimentel Sep 30, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 22 additions & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

30 changes: 30 additions & 0 deletions crates/datadog-mock-intake/Cargo.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
# Copyright 2025-Present Datadog, Inc. https://www.datadoghq.com/
# SPDX-License-Identifier: Apache-2.0

[package]
name = "datadog-mock-intake"
version = "0.1.0"
license.workspace = true
edition.workspace = true

[lib]
bench = false

[dependencies]
bytes = "1.10.1"
flate2 = { version = "1", default-features = false, features = ["rust_backend"] }
http-body-util = "0.1"
hyper = { version = "1.6", features = ["http1", "server"] }
hyper-util = { version = "0.1", features = ["tokio"] }
libdd-trace-protobuf = "4.0.1"
prost = "0.14.1"
rmp-serde = { version = "1.3.1", default-features = false }
serde = { version = "1.0.145", features = ["derive"] }
serde_json = "1.0"
thiserror = { version = "1.0.58", default-features = false }
tokio = { version = "1", features = ["io-util", "macros", "net", "rt-multi-thread", "sync", "time"] }
zstd = { version = "0.13.3", default-features = false }

[dev-dependencies]
reqwest = { version = "0.12.23", default-features = false }
tempfile = "3.3.0"
Loading
Loading