cap-nodejs

CAP Node.js API

---

CAP Node.js API / cap-storage-knex/src / KnexReceivedStorage

Class: KnexReceivedStorage

Defined in: cap-storage-knex/src/knex-received-storage.ts:47

Implements

• ReceivedStoragePort
• CapabilityAwareStoragePort

Constructors

Constructor

new KnexReceivedStorage(knex, options?): KnexReceivedStorage

Defined in: cap-storage-knex/src/knex-received-storage.ts:52

Parameters

knex

Knex

options?

KnexStorageTableOptions = {}

Returns

KnexReceivedStorage

Methods

findReceivedById()

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

Defined in: cap-storage-knex/src/knex-received-storage.ts:141

Parameters

id

string

Returns

Promise<CapReceivedEvent<JsonValue> | undefined>

Implementation of

ReceivedStoragePort.findReceivedById

---

getCapabilities()

getCapabilities(): CapStorageCapabilities

Defined in: cap-storage-knex/src/knex-received-storage.ts:86

Returns

CapStorageCapabilities

Implementation of

CapabilityAwareStoragePort.getCapabilities

---

getRetryDue()

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

Defined in: cap-storage-knex/src/knex-received-storage.ts:128

Parameters

limit

number

now?

Date = ...

Returns

Promise<CapReceivedEvent<JsonValue>[]>

Implementation of

ReceivedStoragePort.getRetryDue

---

initialize()

initialize(options?): Promise<void>

Defined in: cap-storage-knex/src/knex-received-storage.ts:59

Parameters

options?

InitOptions

Returns

Promise<void>

Implementation of

ReceivedStoragePort.initialize

---

listReceived()

listReceived(options?): Promise<DashboardListResult<CapReceivedEvent<JsonValue>>>

Defined in: cap-storage-knex/src/knex-received-storage.ts:150

Parameters

options?

DashboardListOptions = {}

Returns

Promise<DashboardListResult<CapReceivedEvent<JsonValue>>>

Implementation of

ReceivedStoragePort.listReceived

---

markProcessed()

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

Defined in: cap-storage-knex/src/knex-received-storage.ts:90

Parameters

id

string

processedAt?

Date = ...

Returns

Promise<void>

Implementation of

ReceivedStoragePort.markProcessed

---

markReceivedFailed()

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

Defined in: cap-storage-knex/src/knex-received-storage.ts:102

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-knex/src/knex-received-storage.ts:64

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.