cap-nodejs

CAP Node.js API

---

CAP Node.js API / cap-core/src / CapEngine

Class: CapEngine

Defined in: cap-core/src/engine/cap-engine.ts:81

Constructors

Constructor

new CapEngine(options): CapEngine

Defined in: cap-core/src/engine/cap-engine.ts:94

Parameters

options

CapEngineOptions

Returns

CapEngine

Methods

close()

close(): Promise<void>

Defined in: cap-core/src/engine/cap-engine.ts:250

Returns

Promise<void>

---

dispatchOutboxBatch()

dispatchOutboxBatch(): Promise<number>

Defined in: cap-core/src/engine/cap-engine.ts:201

Returns

Promise<number>

---

publish()

publish<T>(topic, payload, options?): Promise<void>

Defined in: cap-core/src/engine/cap-engine.ts:107

Type Parameters

T

T = JsonValue

Parameters

topic

string

payload

T

options?

CapPublishOptions = {}

Returns

Promise<void>

---

retryInboxBatch()

retryInboxBatch(): Promise<number>

Defined in: cap-core/src/engine/cap-engine.ts:232

Returns

Promise<number>

---

retryReceived()

retryReceived(rec): Promise<void>

Defined in: cap-core/src/engine/cap-engine.ts:190

Parameters

rec

CapReceivedEvent

Returns

Promise<void>

---

subscribe()

subscribe<T>(topic, group, handler): void

Defined in: cap-core/src/engine/cap-engine.ts:154

Type Parameters

T

T = unknown

Parameters

topic

string

group

string

handler

Handler<T>

Returns

void

---

transaction()

transaction<T>(fn, options?): Promise<T>

Defined in: cap-core/src/engine/cap-engine.ts:143

Type Parameters

T

T

Parameters

fn

(ctx) => Promise<T>

options?

CapTransactionOptions = {}

Returns

Promise<T>

This site is open source. Improve this page.