Consommateur durable JetStream, isolation de l'exécuteur, signatures à temps d'avion

Featurekamo-shared-library
Expédié
15 mai 2026 à 20:48 UTC
Auteur
Kamo
Commite
e8ff33f

Trois changements ont été groupés parce qu'ils vivent tous dans WebhookDeliveryWorker et ont un sens ensemble: 1. Passage du commutateur central NATS à un consommateur de poussée durable JetStream ("los-pipeline-webhook-worker", AckPolicy.Explicit). Relance replay Événements non ponnés; le nombre de tentatives provient de msg.metaData(). . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . boucle en cours de traitement. maxLivrons les caps rediffonnés. 2. Expédier chaque message à un petit programme d'administration Service donc un lent (10s-timeout) l'abonné ne peut pas soutenir le fil de répartition NATS. 3. Signer 't.body' (Stripe/GitHub style) et émet des en-têtes X-Kamo-Timestamp et X-Kamo-Signature: t-ts-,v1-hex donc une écoute la demande ne peut être rejouée indéfiniment. deliverForOrg n'est plus « Transactional: a failed HTTP tente re-tomise donc JetStream se réplique, et nous voulons que la ligne d'audit persiste dans sa propre une transaction courte plutôt que de reculer avec le champ d'application extérieur.

Tous les changements

Comme ce que tu vois expédier ?

Chacune de ces mises à jour atterrit automatiquement dans votre espace de travail. Commencez gratuitement et regardez-le grandir semaine après semaine.

Commencez gratuitement pour toujoursPrix de visualisation