cap-nodejs

CAP Node.js API

CAP Node.js API / cap-storage-mikro-orm/src / MikroReceivedStorage

Class: MikroReceivedStorage

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:15

Implements

Constructors

Constructor

new MikroReceivedStorage(em, orm?, logger?): MikroReceivedStorage

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:18

Parameters

em

EntityManager

orm?

MikroORM<IDatabaseDriver<Connection>, EntityManager<IDatabaseDriver<Connection>>>

logger?

CapLogger

Returns

MikroReceivedStorage

Methods

findReceivedById()

findReceivedById(id): Promise<CapReceivedEvent<JsonValue> | undefined>

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:153

Parameters

id

string

Returns

Promise<CapReceivedEvent<JsonValue> | undefined>

Implementation of

ReceivedStoragePort.findReceivedById

getCapabilities()

getCapabilities(): CapStorageCapabilities

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:103

Returns

CapStorageCapabilities

Implementation of

CapabilityAwareStoragePort.getCapabilities

getRetryDue()

getRetryDue(limit, now?): Promise<CapReceivedEvent<JsonValue>[]>

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:134

Parameters

limit

number

now?

Date = ...

Returns

Promise<CapReceivedEvent<JsonValue>[]>

Implementation of

ReceivedStoragePort.getRetryDue

initialize()?

optional initialize(options?): Promise<void>

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:24

Parameters

options?
autoInit?

boolean

createSchema?

boolean

Returns

Promise<void>

Implementation of

ReceivedStoragePort.initialize

listReceived()

listReceived(opts): Promise<{ items: CapReceivedEvent<JsonValue>[]; total: number; }>

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:160

Parameters

opts
due?

boolean

limit?

number

offset?

number

topic?

string

Returns

Promise<{ items: CapReceivedEvent<JsonValue>[]; total: number; }>

Implementation of

ReceivedStoragePort.listReceived

markProcessed()

markProcessed(id, processedAt?): Promise<void>

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:107

Parameters

id

string

processedAt?

Date = ...

Returns

Promise<void>

Implementation of

ReceivedStoragePort.markProcessed

markReceivedFailed()

markReceivedFailed(id, error, options): Promise<void>

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:117

Parameters

id

string

error

unknown

options

MarkReceivedFailedOptions

Returns

Promise<void>

Implementation of

ReceivedStoragePort.markReceivedFailed

trySaveReceived()

trySaveReceived<T>(event): Promise<TrySaveReceivedResult<T>>

Defined in: cap-storage-mikro-orm/src/storage/mikro-received-storage.ts:50

Type Parameters

T

T extends JsonValue = JsonValue

Parameters

event

CapReceivedEvent<T>

Returns

Promise<TrySaveReceivedResult<T>>

Implementation of

ReceivedStoragePort.trySaveReceived

This site is open source. Improve this page.