Skip to content

feat: qualify dedup IDs and bound the exporter queue - #248

Open
savme wants to merge 1 commit into
feat/federated-events-exporterfrom
feat/federated-events-dedup-id
Open

savme wants to merge 1 commit into
feat/federated-events-exporterfrom
feat/federated-events-dedup-id

Conversation

@savme

@savme savme commented Sep 15, 2026 •

Copy link
Copy Markdown
Contributor

The exporter's informer callback called NATS publish directly, so a slow or unreachable NATS connection blocked the callback outright. Adds a bounded queue between the two: the callback enqueues without blocking, one goroutine drains it into NATS, and a full queue drops the newest event and counts it rather than blocking.

This also introduces qualifiedMsgID, so that messages are deduped cross-cluster correctly.

Test plan

  • go test
  • Covers drop-newest-on-full-queue behavior directly, including that an already-queued event is kept over the incoming one

Depends on #246

Stack:

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants