CAP Node.js API / cap-nest/src / IReceivedStorage
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:118
optionalfindReceivedById(id):Promise<CapReceivedEvent<JsonValue> |undefined>
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:147
Optional: find a received record by id (dashboard helpers)
string
Promise<CapReceivedEvent<JsonValue> | undefined>
getRetryDue(
limit):Promise<CapReceivedEvent<JsonValue>[]>
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:137
Return records that are not yet processed and whose nextRetry timestamp <= now. Scheduler uses this.
number
Promise<CapReceivedEvent<JsonValue>[]>
optionalinitialize(options?):Promise<void>
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:128
Optional one-time initialization: create schema/tables if needed
Promise<void>
optionallistReceived(opts):Promise<{items:CapReceivedEvent<JsonValue>[];total?:number; }>
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:150
Optional: paginated listing for dashboards and admin UIs
boolean
number
number
string
Promise<{ items: CapReceivedEvent<JsonValue>[]; total?: number; }>
markProcessed(
id):Promise<void>
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:131
Mark processed=true
string
Promise<void>
markReceivedFailed(
id,error,options):Promise<void>
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:140
Mark inbox processing failed, or dead-letter when retry limit is exceeded.
string
unknown
Promise<void>
trySaveReceived<
T>(evt):Promise<TrySaveReceivedResult<T>>
Defined in: cap-nest/src/cap/abstractions/storage.interface.ts:123
Persist a delivery if its dedupe identity has not been seen. Duplicate deliveries return inserted=false and must not re-run handlers.
T extends JsonValue = JsonValue
Promise<TrySaveReceivedResult<T>>