Skip to main content

Interface: IDurableInbox<T>

Defined in: packages/agentos/src/io/channels/meetings/DurableInbox.ts:8

Deliveries a receiver has accepted and not yet acted on. A payload stays pending until the receiver acknowledges it, so work interrupted by a restart is found again; an acknowledged entry keeps only its id, so a replay of it is refused.

Type Parameters​

T​

T

Methods​

accept()​

accept(entry): Promise<boolean>

Defined in: packages/agentos/src/io/channels/meetings/DurableInbox.ts:10

Stores a new entry; false, and nothing changes, when an entry with its id was accepted before (acknowledged or not).

Parameters​

entry​

InboxEntry<T>

Returns​

Promise<boolean>

acknowledge()​

acknowledge(id): Promise<void>

Defined in: packages/agentos/src/io/channels/meetings/DurableInbox.ts:14

Drops the entry's payload once the receiver has acted on it; its id stays, so a replay is still refused.

Parameters​

id​

string

Returns​

Promise<void>

pending()​

pending(): Promise<InboxEntry<T>[]>

Defined in: packages/agentos/src/io/channels/meetings/DurableInbox.ts:12

The entries accepted and not yet acknowledged, oldest first.

Returns​

Promise<InboxEntry<T>[]>