MonqueEventMap

Defined in: packages/core/src/events/types.ts:6

Event payloads for Monque lifecycle events.

Properties

changestream:closed

changestream:closed: undefined;

Defined in: packages/core/src/events/types.ts:61

Emitted when the change stream is closed.

---

changestream:connected

changestream:connected: undefined;

Defined in: packages/core/src/events/types.ts:49

Emitted when the change stream is successfully connected.

---

changestream:error

changestream:error: object;

Defined in: packages/core/src/events/types.ts:54

Emitted when a change stream error occurs.

error

error: Error;

---

changestream:fallback

changestream:fallback: object;

Defined in: packages/core/src/events/types.ts:66

Emitted when falling back from change streams to polling-only mode.

reason

reason: string;

---

job:cancelled

job:cancelled: object;

Defined in: packages/core/src/events/types.ts:72

Emitted when a job is manually cancelled.

job

job: Job;

---

job:complete

job:complete: object;

Defined in: packages/core/src/events/types.ts:15

Emitted when a job finishes successfully.

duration

duration: number;

Processing duration in milliseconds

job

job: Job;

---

job:deleted

job:deleted: object;

Defined in: packages/core/src/events/types.ts:87

Emitted when a job is manually deleted.

jobId

jobId: string;

---

job:error

job:error: object;

Defined in: packages/core/src/events/types.ts:34

Emitted for unexpected errors during processing.

error

error: Error;

job?

optional job: Job<unknown>;

---

job:fail

job:fail: object;

Defined in: packages/core/src/events/types.ts:24

Emitted when a job fails (may retry).

error

error: Error;

job

job: Job;

willRetry

willRetry: boolean;

Whether the job will be retried

---

job:retried

job:retried: object;

Defined in: packages/core/src/events/types.ts:79

Emitted when a job is manually retried.

job

job: Job;

previousStatus

previousStatus: "failed" | "cancelled";

---

job:start

job:start: Job;

Defined in: packages/core/src/events/types.ts:10

Emitted when a job begins processing.

---

jobs:cancelled

jobs:cancelled: object;

Defined in: packages/core/src/events/types.ts:94

Emitted when multiple jobs are cancelled in bulk.

count

count: number;

jobIds

jobIds: string[];

---

jobs:deleted

jobs:deleted: object;

Defined in: packages/core/src/events/types.ts:110

Emitted when multiple jobs are deleted in bulk.

count

count: number;

---

jobs:retried

jobs:retried: object;

Defined in: packages/core/src/events/types.ts:102

Emitted when multiple jobs are retried in bulk.

count

count: number;

jobIds

jobIds: string[];

---

stale:recovered

stale:recovered: object;

Defined in: packages/core/src/events/types.ts:42

Emitted when stale jobs are recovered on startup.

count

count: number;