MonqueEventMap

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

Event payloads for Monque lifecycle events.

Properties

changestream:closed

changestream:closed: undefined;

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

Emitted when the change stream is closed.

---

changestream:connected

changestream:connected: undefined;

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

Emitted when the change stream is successfully connected.

---

changestream:error

changestream:error: object;

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

Emitted when a change stream error occurs.

error

error: Error;

---

changestream:fallback

changestream:fallback: object;

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

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:63

Emitted when a job is manually cancelled.

job

job: Job;

---

job:complete

job:complete: object;

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

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:76

Emitted when a job is manually deleted.

jobId

jobId: string;

---

job:error

job:error: object;

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

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:21

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:69

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:9

Emitted when a job begins processing.

---

jobs:cancelled

jobs:cancelled: object;

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

Emitted when multiple jobs are cancelled in bulk. Contains only the count of affected jobs (no individual IDs for O(1) performance).

count

count: number;

---

jobs:deleted

jobs:deleted: object;

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

Emitted when multiple jobs are deleted in bulk.

count

count: number;

---

jobs:retried

jobs:retried: object;

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

Emitted when multiple jobs are retried in bulk. Contains only the count of affected jobs (no individual IDs for O(1) performance).

count

count: number;

---

stale:recovered

stale:recovered: object;

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

Emitted when stale jobs are recovered on startup.

count

count: number;