vnvo / deltaforge

45%

Build Type

push

github

Committed by web-flow

Commit Message

HTTP/Webhook sink (#68)

* feat: HTTP/Webhook sink

Delivers CDC events via HTTP POST/PUT to any URL.

Features:
- URL templates for per-table routing (${source.table})
- Custom headers with ${ENV_VAR} expansion (Bearer, Basic, API key)
- Batch mode: JSON array in one request, or per-event requests
- Retry on 5xx, 408, 429, connection errors, timeouts
- Auth errors (401/403) fail immediately
- DLQ-eligible routing errors (URL template failures)
- Connection pooling via reqwest

Integration tests (8): single event, batch per-event, batch mode array,
auth error (no retry), 5xx retries, URL template routing, custom headers,
connection refused retries. All use local axum test server.
 
* docs: add HTTP/Webhook sink to README and landing page

Run Details

166 of 234 new or added lines in 3 files covered. (70.94%)

2 existing lines in 1 file now uncovered.

10750 of 24127 relevant lines covered (44.56%)

154.57 hits per line