SqlInboundLedger

Implements

• InboundLedger

Constructors

Constructor

new SqlInboundLedger(sql, options?): SqlInboundLedger;

Parameters

Parameter	Type
sql	SqlExecutor
options	{ inProgressTtlMs?: number; }
options.inProgressTtlMs?	number

Returns

SqlInboundLedger

Methods

append()

append(key, event): Promise<{
  seq: number;
}>;

Parameters

Parameter	Type
key	ConversationKey
event	InboundEvent

Returns

Promise<{ seq: number; }>

Implementation of

InboundLedger.append

---

claim()

claim(key, eventId): Promise<ClaimResult>;

Parameters

Parameter	Type
key	ConversationKey
eventId	string

Returns

Promise<ClaimResult>

Implementation of

InboundLedger.claim

---

commitCursor()

commitCursor(
   key,
   throughSeq,
expect): Promise<boolean>;

Parameters

Parameter	Type
key	ConversationKey
throughSeq	number
expect	number

Returns

Promise<boolean>

Implementation of

InboundLedger.commitCursor

---

complete()

complete(key, eventId): Promise<void>;

Parameters

Parameter	Type
key	ConversationKey
eventId	string

Returns

Promise<void>

Implementation of

InboundLedger.complete

---

cursor()

cursor(key): number;

Parameters

Parameter	Type
key	ConversationKey

Returns

number

---

prune()

prune(key, ttlMs): Promise<number>;

Parameters

Parameter	Type
key	ConversationKey
ttlMs	number

Returns

Promise<number>

Implementation of

InboundLedger.prune

---

readUnprocessed()

readUnprocessed(key): Promise<InboundEvent[]>;

Parameters

Parameter	Type
key	ConversationKey

Returns

Promise<InboundEvent[]>

Implementation of

InboundLedger.readUnprocessed