Function: createChatOutboxRunner()
function createChatOutboxRunner(options: ChatOutboxRunnerOptions): {
getStatus: () => {
claimed: number;
drains: number;
errors: number;
lastDrainDurationMs: number;
leaseLost: number;
maxEventAgeMs: number;
published: number;
retried: number;
running: boolean;
};
wake: () => void;
close: Promise<void>;
};Defined in: server/chat/outbox-runner.ts:21
Notifications are hints: every wake claims durable rows, and polling repairs missed hints.
Parameters
| Parameter | Type |
|---|---|
options | ChatOutboxRunnerOptions |
Returns
{
getStatus: () => {
claimed: number;
drains: number;
errors: number;
lastDrainDurationMs: number;
leaseLost: number;
maxEventAgeMs: number;
published: number;
retried: number;
running: boolean;
};
wake: () => void;
close: Promise<void>;
}getStatus
getStatus: () => {
claimed: number;
drains: number;
errors: number;
lastDrainDurationMs: number;
leaseLost: number;
maxEventAgeMs: number;
published: number;
retried: number;
running: boolean;
};Returns
{
claimed: number;
drains: number;
errors: number;
lastDrainDurationMs: number;
leaseLost: number;
maxEventAgeMs: number;
published: number;
retried: number;
running: boolean;
}claimed
claimed: number = 0;drains
drains: number = 0;errors
errors: number = 0;lastDrainDurationMs
lastDrainDurationMs: number = 0;leaseLost
leaseLost: number = 0;maxEventAgeMs
maxEventAgeMs: number = 0;published
published: number = 0;retried
retried: number = 0;running
running: boolean;wake
wake: () => void;Returns
void
close()
close(): Promise<void>;Returns
Promise<void>