Logos DX
    Preparing search index...

    Type Alias QueueEvents<S, E>

    type QueueEvents<
        S extends Record<string, any>,
        E extends Events<S> | RegExp = Events<S>,
    > = {
        added: QueueEventData<S, E>;
        cleanup: void;
        drain: { pending: number };
        drained: { drained?: number; pending?: number };
        empty: void;
        error: QueueEventData<S, E> & { error: Error; rateLimited: boolean };
        flush: { pending: number };
        flushed: { flushed: number };
        idle: void;
        paused: void;
        processing: QueueEventData<S, E> & {
            rateLimited: boolean;
            startedAt: number;
        };
        purged: { count: number };
        "rate-limited": QueueEventData<S, E> & { rateLimited: boolean };
        rejected: QueueEventData<S, E> & { reason: QueueRejectionReason };
        resumed: void;
        shutdown: { force: boolean; pending?: number };
        start: void;
        started: void;
        stopped: void;
        success: QueueEventData<S, E> & {
            elapsed: number;
            rateLimited: boolean;
            startedAt: number;
        };
        timeout: QueueEventData<S, E> & { error: Error; rateLimited: boolean };
    }

    Type Parameters

    Index

    Properties

    added: QueueEventData<S, E>
    cleanup: void
    drain: { pending: number }
    drained: { drained?: number; pending?: number }
    empty: void
    error: QueueEventData<S, E> & { error: Error; rateLimited: boolean }
    flush: { pending: number }
    flushed: { flushed: number }
    idle: void
    paused: void
    processing: QueueEventData<S, E> & { rateLimited: boolean; startedAt: number }
    purged: { count: number }
    "rate-limited": QueueEventData<S, E> & { rateLimited: boolean }
    rejected: QueueEventData<S, E> & { reason: QueueRejectionReason }
    resumed: void
    shutdown: { force: boolean; pending?: number }
    start: void
    started: void
    stopped: void
    success: QueueEventData<S, E> & {
        elapsed: number;
        rateLimited: boolean;
        startedAt: number;
    }
    timeout: QueueEventData<S, E> & { error: Error; rateLimited: boolean }