टिकाऊ जेटस्ट्रीम उपभोक्ता, निष्पादक अलगाव, समयबद्ध हस्ताक्षर

शिप

15 मई 2026 को 8:48 pm बजे UTC

लेखक

Kamo

Commit

e8ff33f

तीन बदलाव बंडल क्योंकि वे सभी WebhookDeliveryWorker में रहते हैं और एक साथ समझो: 1. कोर से स्विच NATS प्रेषक एक जेटस्ट्रीम टिकाऊ धक्का उपभोक्ता के लिए ("lo-pipeline-webhook-worker", AckPolicy। स्पष्ट). फिर से खेलना शुरू करें unacked event; प्रयास गिनती msg.metaData().deliveredCount() से आती है। इसलिए वेबहुकडिलिवरी ऑडिट लॉग किसी के बजाय रिडीलिवरी को दर्शाता है इन-प्रोसेस लूप। अधिकतम डिलिवर कैप्स रिलीवर। 2. प्रत्येक संदेश को एक छोटे से अनुसूचित EXecutor Service में डिस्पैच करें ताकि एक धीमी गति से (10s-timeout) ग्राहक NATS प्रेषक धागे को वापस नहीं कर सकते। 3. साइन 't.body' (Stripe/GitHub शैली) और हेडर का उत्सर्जन करते हैं X-Kamo-Timestamp + X-Kamo-Signature: t=<ts>, v1=<hex> तो एक eavesdrop अनुरोध को अनिश्चित काल तक फिर से नहीं खेला जा सकता है। LettoOrg अब @transactional है: एक असफल HTTP प्रयास फिर से फेंको इसलिए JetStream redelivers, और हम चाहते हैं कि लेखा परीक्षा पंक्ति अपने आप में बने रहें बाहरी दायरे के साथ वापस रोलिंग के बजाय लघु लेनदेन।.