feat(log-agent): add datadog-log-agent crate and wire into serverless-compat#95

Open

litianningdatadog wants to merge 41 commits intomainfrom

tianning.li/SVLS-8573-datadog-log-agent

Commits on Mar 12, 2026

feat(log-agent): scaffold datadog-log-agent crate with constants and errors

litianningdatadog
and
claude
committed
- use serde flatten with Map instead of Option<Map> to avoid deser quirk
litianningdatadog
committed
feat(log-agent): add LogAggregator with size/count-bounded batch collection

litianningdatadog
and
claude
committed
refactor(log-agent): clean up get_batch loop to include comma bytes in tally

litianningdatadog
and
claude
committed
feat(log-agent): add AggregatorService + AggregatorHandle with channel pattern

litianningdatadog
and
claude
committed
feat(log-agent): add LogFlusher with zstd compression, retry logic, and OPW mode

litianningdatadog
and
claude
committed
fix(log-agent): align flusher tests with spec requirements

litianningdatadog
and
claude
committed
fix(log-agent): code quality improvements in flusher and config

litianningdatadog
and
claude
committed
feat(log-agent): integrate datadog-log-agent into serverless-compat binary

litianningdatadog
and
claude
committed
fix(log-agent): improve main.rs wiring — early return on missing API key, use crate re-exports

litianningdatadog
and
claude
committed
test(log-agent): add integration test suite covering full pipeline, batching, retries, and OPW mode
litianningdatadog
committed
feat(log-agent): derive Clone on LogFlusher
litianningdatadog
committed
- add CLAUDE.md to .gitignore
litianningdatadog
committed
chore(log-agent): add hyper/http-body-util/hyper-util deps for log server
litianningdatadog
committed
feat(log-agent): add LogServer HTTP intake skeleton
litianningdatadog
committed
test(log-agent): add LogServer HTTP intake integration tests
litianningdatadog
committed
feat(serverless-compat): start LogServer HTTP intake on DD_LOGS_PORT (default 8080)
litianningdatadog
committed
chore: remove stale TODO comment — LogServer wires the log-ingestion endpoint
litianningdatadog
committed
test(log-agent): add unit and integration tests for LogServer network intake
litianningdatadog
committed
test(log-agent): add network intake integration tests for LogServer

litianningdatadog
and
claude
committed
fix(log-agent): treat 408/425/429 as retryable instead of permanent 4xx

litianningdatadog
and
claude
committed
fix(serverless-compat): warn when log agent flush fails

litianningdatadog
and
claude
committed
fix(log-server): accept chunked requests by checking Content-Length header instead of size_hint
litianningdatadog
committed
chore(log-agent): change default log intake port to 10517 and document bind-failure gap
litianningdatadog
committed
feat(log-agent): send additional endpoints concurrently in flush()
litianningdatadog
committed
perf(log-agent): dispatch all log batches concurrently in flush()
litianningdatadog
committed
fix(log-agent): drain response body after each HTTP send
litianningdatadog
committed
feat(log-agent): per-endpoint API key for additional_endpoints
litianningdatadog
committed
fix(log-agent): fall back to uncompressed on zstd compression failure
litianningdatadog
committed
feat(log-agent): implement cross-invocation retry via RequestBuilder passback
litianningdatadog
committed
fix(log-agent): account for JSON framing bytes in batch size checks
litianningdatadog
committed
test(log-agent): replace tautological OPW URL test with real behavior check
litianningdatadog
committed
test(log-agent): remove no-op compile-time size_of test
litianningdatadog
committed
refactor(log-agent): rename LogEntry::new to from_message; drop compression_level range from docs
litianningdatadog
committed
refactor(log-agent): rename LogEntry → IntakeEntry and log_entry → intake_entry
litianningdatadog
committed
refactor(log-agent): drop Log prefix from Aggregator and AggregatorCommand
litianningdatadog
committed
refactor(log-agent): rename FlusherMode → Destination; add #[must_use] to from_env
litianningdatadog
committed
chore: fix all clippy and fmt warnings across workspace
litianningdatadog
committed
feat(datadog-log-agent): add LogEntry and FlusherMode type aliases
litianningdatadog
committed
revert(datadog-log-agent): remove LogEntry/FlusherMode type aliases
litianningdatadog
committed
refactor(log-agent): rename crate datadog-log-agent → datadog-logs-agent
litianningdatadog
committed