Kaizen
Browse modulesChatchat/serverFunctions

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

ParameterType
optionsChatOutboxRunnerOptions

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>

On this page