basalt / subscriptions/src / RedisWebhookStore

Class: RedisWebhookStore

Defined in: subscriptions/src/drivers/redis-webhook.ts:30

Durable webhook dedupe via Redis SET key value NX EX — the atomic claim returns 'OK' only for the first caller, so idempotency holds across process restarts and multiple instances.

Implements

• WebhookStore

Constructors

Constructor

> new RedisWebhookStore(redis, options?): RedisWebhookStore

Defined in: subscriptions/src/drivers/redis-webhook.ts:34

Parameters

redis

RedisWebhookClient

options?

RedisWebhookStoreOptions = {}

Returns

RedisWebhookStore

Methods

markProcessed()

> markProcessed(id): Promise<boolean>

Defined in: subscriptions/src/drivers/redis-webhook.ts:46

Parameters

id

string

Returns

Promise<boolean>

Implementation of

WebhookStore.markProcessed

---

release()

> release(id): Promise<void>

Defined in: subscriptions/src/drivers/redis-webhook.ts:51

Parameters

id

string

Returns

Promise<void>

Implementation of

WebhookStore.release