Aaron D. Lee e6dc6fda14 feat(valkey_sink): ValkeyEventSink -- first Valkey consumer (deploy-C §5.6) ...

Implement a bounded-mpsc + background-task Valkey event sink:
- XADD lifecycle events to a capped stream (MAXLEN ~ 10000).
- Fire-and-forget emit(): one mpsc::try_send, count-and-drop on full.
- Arc<AtomicU64> drop counter surfaced in /metrics.
- main.rs selects ValkeyEventSink when RUTSTER_VALKEY_URL is set and
  falls back to TracingEventSink otherwise.
- config::valkey_url validates redis:// / rediss://.
- CI services:valkey: block on test and clippy jobs.

Signed-off-by: Aaron D. Lee <himself@adlee.work>

2026-07-06 03:04:10 -04:00

6.5 KiB

Raw Permalink Blame History

View Raw