QuestDB JavaScript Client - v5.0.0
    Preparing search index...

    Interface QwpNodeOrphanDrainerOptions

    interface QwpNodeOrphanDrainerOptions {
        durableAckPollIntervalMs?: number;
        errorInboxCapacity?: number;
        eventInboxCapacity?: number;
        excludeSlot?: (slotName: string) => boolean;
        maxConcurrent?: number;
        onEvent?: (event: QwpNodeOrphanDrainEvent) => void;
        onSenderError?: (error: QwpSenderError) => void;
        releaseSlot?: (directory: string) => void;
        rootDirectory: string;
        scanIntervalMs?: number;
        tryReserveSlot?: (directory: string) => boolean;
        createSession(
            directory: string,
            onReconnectEvent?: (event: QwpReconnectEvent) => void,
        ): Promise<QwpNodeOrphanDrainSession>;
    }
    Index

    Properties

    durableAckPollIntervalMs? errorInboxCapacity? eventInboxCapacity? excludeSlot? maxConcurrent? onEvent? onSenderError? releaseSlot? rootDirectory scanIntervalMs? tryReserveSlot?

    Methods

    createSession

    Properties

    durableAckPollIntervalMs?: number

    Durable-ACK prompt cadence for adopted sessions. Zero disables it. Not capped at the host timer ceiling: compared against elapsed time only.

    errorInboxCapacity?: number

    Bounded data-loss inbox. Defaults to 256.

    eventInboxCapacity?: number

    Bounded lifecycle-event inbox. Defaults to 64.

    excludeSlot?: (slotName: string) => boolean

    Slot names owned by the foreground producer/pool and never adoptable.

    maxConcurrent?: number

    Maximum slots drained concurrently. Defaults to 4.

    onEvent?: (event: QwpNodeOrphanDrainEvent) => void
    onSenderError?: (error: QwpSenderError) => void

    Java-parity data-loss notification for an abandoned orphan slot.

    releaseSlot?: (directory: string) => void

    Releases a reservation previously granted by tryReserveSlot.

    rootDirectory: string

    Directory whose child directories are independent replay slots.

    scanIntervalMs?: number

    Periodic rescan cadence; zero disables the timer. Explicit scanNow() requests remain available. Defaults to 30s. Capped at 2,147,483,647ms (the host timer ceiling); a larger value throws a RangeError.

    tryReserveSlot?: (directory: string) => boolean

    Atomically reserves a candidate against a foreground pool owner.

    Methods

    Settings

    Member Visibility

    On This Page

    Properties
    Methods