Skip to content

basalt / events-prisma/src / prismaOutboxStore

Function: prismaOutboxStore() ​

> prismaOutboxStore(client, options?): PrismaEventsStores

Defined in: events-prisma/src/index.ts:305

Wire the outbox store to your Prisma client, named to drop straight into outboxPlugin:

ts
const outbox = prismaOutboxStore(prisma, { claim: true }) // claim: safe with N replicas
// on MySQL add columnLimits: 'mysql' (see schema.mysql.prisma)
outboxPlugin({ store: outbox.store, dispatch, captureEvents: ['order.*'], intervalMs: 1000 })

Parameters ​

client ​

PrismaEventsClient

options? ​

PrismaOutboxStoreOptions = {}

Returns ​

PrismaEventsStores

Released under the MIT License.