NATS JetStreamRedisingestd (gRPC :9090)Internal serviceNATS JetStreamRedisingestd (gRPC :9090)Internal servicealt[first][dup]opt[rate-limited]loop​open bidi stream (metadata: authorization=Bearer <api_key>)1verify API key, attach source_id2Alert{company_id, source_id, severity, ...}3schema validate4SET dedupe:{key} 1 NX EX 605OK6publish alerts.<company_id>7Ack{alert_id, dedupe_count=1}8nil9INCR → n10publish alerts.<company_id> {dedupe_count=n}11Ack{alert_id, dedupe_count=n}12Ack{error: RATE_LIMITED, retry_after_ms=1000}13half-close (writes done)14EOF15