KvInbox

Class exported by @botmesh/core/spi.

Defined in: durability/journal.ts:88

InboxJournal over a DurableKv.

Implements

• InboxJournal

Constructors

Constructor

new KvInbox(kv, table?): KvInbox;

Defined in: durability/journal.ts:90

Parameters

Parameter	Type	Default value	Description
kv	DurableKv	undefined	-
table?	string	'inbox'	The KV table ('inbox', or 'inbox:<scope>' for a scoped view).

Returns

KvInbox

Methods

append()

append(
   input, 
   now, 
   lease?
): Promise<{
  status: "appended" | "duplicate";
  record: InboxRecord;
}>;

Defined in: durability/journal.ts:96

Insert-if-absent by id. 'duplicate' means the id is already known (any state); the existing record is returned unchanged. With lease, a new record is created already claimed (processing, token 1, 1 attempt), so no other claimer can take it between the append and the claim.

Parameters

Parameter	Type
input	InboxAppend
now	number
lease?	LeaseOptions

Returns

Promise<{ status: "appended" | "duplicate"; record: InboxRecord; }>

Implementation of

InboxJournal.append

---

claim()

claim(o): Promise<InboxRecord[]>;

Defined in: durability/journal.ts:115

Lease due records: pending/failed whose nextAttemptAt <= now, plus processing records whose lease expired. Oldest receivedAt first. Each claimed record comes back processing with a fresh fencingToken and attempts + 1.

Parameters

Parameter	Type
o	ClaimOptions

Returns

Promise<InboxRecord[]>

Implementation of

InboxJournal.claim

---

claimOne()

claimOne(id, o): Promise<InboxRecord | null>;

Defined in: durability/journal.ts:138

Lease one specific record when it is claimable (as claim); null when it is not.

Parameters

Parameter	Type
id	string
o	LeaseOptions

Returns

Promise<InboxRecord | null>

Implementation of

InboxJournal.claimOne

---

ack()

ack(
   id, 
   token, 
   now
): Promise<void>;

Defined in: durability/journal.ts:154

processing → done.

Parameters

Parameter	Type
id	string
token	number
now	number

Returns

Promise<void>

Throws

when token is not the current claim.

Implementation of

InboxJournal.ack

---

fail()

fail(
   id, 
   token, 
   error, 
   o
): Promise<void>;

Defined in: durability/journal.ts:158

processing → failed (due at retryAt, default now) or dead (dead: true).

Parameters

Parameter	Type
id	string
token	number
error	string
o	{ now: number; retryAt?: number; dead?: boolean; }
o.now	number
o.retryAt?	number
o.dead?	boolean

Returns

Promise<void>

Throws

Implementation of

InboxJournal.fail

---

release()

release(
   id, 
   token, 
   now
): Promise<void>;

Defined in: durability/journal.ts:164

processing → pending, due now; the claim’s attempt is not charged.

Parameters

Parameter	Type
id	string
token	number
now	number

Returns

Promise<void>

Throws

Implementation of

InboxJournal.release

---

extend()

extend(
   id, 
   token, 
   leaseUntil
): Promise<void>;

Defined in: durability/journal.ts:168

Extend the current lease (heartbeat).

Parameters

Parameter	Type
id	string
token	number
leaseUntil	number

Returns

Promise<void>

Throws

Implementation of

InboxJournal.extend

---

replay()

replay(id, now): Promise<void>;

Defined in: durability/journal.ts:172

Operator replay: any record → pending, due now, attempts reset. No-op for an unknown id.

Parameters

Parameter	Type
id	string
now	number

Returns

Promise<void>

Implementation of

InboxJournal.replay

---

get()

get(id): Promise<InboxRecord | undefined>;

Defined in: durability/journal.ts:178

Parameters

Parameter	Type
id	string

Returns

Promise<InboxRecord | undefined>

Implementation of

InboxJournal.get

---

list()

list(filter?): Promise<InboxRecord[]>;

Defined in: durability/journal.ts:183

Records, optionally by state, oldest receivedAt first.

Parameters

Parameter	Type
filter?	{ state?: InboxState; limit?: number; }
filter.state?	InboxState
filter.limit?	number

Returns

Promise<InboxRecord[]>

Implementation of

InboxJournal.list

---

purge()

purge(o): Promise<number>;

Defined in: durability/journal.ts:189

Delete done records completed before doneBefore (and dead ones when includeDead). Returns the count.

Parameters

Parameter	Type
o	{ doneBefore: number; includeDead?: boolean; }
o.doneBefore	number
o.includeDead?	boolean

Returns

Promise<number>

Implementation of

InboxJournal.purge