Skip to content

DeliveryStore

Defined in: packages/webhook/src/registry/delivery.store.ts:19

  • EventEmitter

new DeliveryStore(config?): DeliveryStore

Defined in: packages/webhook/src/registry/delivery.store.ts:34

Partial<StorageConfig> = {}

DeliveryStore

EventEmitter.constructor

addListener(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:16

string

Listener

this

EventEmitter.addListener


cleanupOldDeliveries(): Promise<number>

Defined in: packages/webhook/src/registry/delivery.store.ts:281

오래된 전달 기록 정리

Promise<number>


emit(eventName, …args): boolean

Defined in: packages/webhook/src/shared/event-emitter.ts:44

string

unknown[]

boolean

EventEmitter.emit


getDeliveriesByEndpoint(endpointId, limit?): Promise<WebhookDelivery[]>

Defined in: packages/webhook/src/registry/delivery.store.ts:175

엔드포인트별 전달 기록 조회

string

number = 100

Promise<WebhookDelivery[]>


getDelivery(deliveryId): Promise<WebhookDelivery | null>

Defined in: packages/webhook/src/registry/delivery.store.ts:82

전달 기록 조회

string

Promise<WebhookDelivery | null>


getDeliveryStats(endpointId?, timeRange?): Promise<{ averageLatency: number; errorBreakdown: Record<string, number>; exhaustedDeliveries: number; failedDeliveries: number; pendingDeliveries: number; successfulDeliveries: number; successRate: number; totalDeliveries: number; }>

Defined in: packages/webhook/src/registry/delivery.store.ts:209

전달 통계 조회

string

Date

Date

Promise<{ averageLatency: number; errorBreakdown: Record<string, number>; exhaustedDeliveries: number; failedDeliveries: number; pendingDeliveries: number; successfulDeliveries: number; successRate: number; totalDeliveries: number; }>


getFailedDeliveries(endpointId?, limit?): Promise<WebhookDelivery[]>

Defined in: packages/webhook/src/registry/delivery.store.ts:193

실패한 전달 기록 조회

string

number = 100

Promise<WebhookDelivery[]>


getStorageStats(): object

Defined in: packages/webhook/src/registry/delivery.store.ts:316

저장소 통계 조회

object

indexSizes: object

byDate: number

byEndpoint: number

byStatus: number

memoryUsage: number

totalDeliveries: number


off(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:20

string

Listener

this

EventEmitter.off


on(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:9

string

Listener

this

EventEmitter.on


once(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:35

string

Listener

this

EventEmitter.once


removeAllListeners(eventName?): this

Defined in: packages/webhook/src/shared/event-emitter.ts:57

string

this

EventEmitter.removeAllListeners


removeListener(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:31

string

Listener

this

EventEmitter.removeListener


saveDelivery(delivery): Promise<void>

Defined in: packages/webhook/src/registry/delivery.store.ts:51

전달 기록 저장

WebhookDelivery

Promise<void>


searchDeliveries(filter?, pagination?): Promise<SearchResult<WebhookDelivery>>

Defined in: packages/webhook/src/registry/delivery.store.ts:89

필터 조건에 맞는 전달 기록 검색

DeliveryFilter = {}

PaginationOptions = ...

Promise<SearchResult<WebhookDelivery>>


shutdown(): Promise<void>

Defined in: packages/webhook/src/registry/delivery.store.ts:643

전달 저장소 종료

Promise<void>