Class QwpEgressQuery

constructor

• new QwpEgressQuery(
      requestId: bigint,
      control: QwpEgressQueryControl,
      creditEnabled: boolean,
      autoCredit: boolean,
      bufferPoolSize: number,
      viewHandler?: QwpResultBatchViewHandler,
  ): QwpEgressQuery

  Parameters

  • requestId: bigint
  • control: QwpEgressQueryControl
  • creditEnabled: boolean
  • autoCredit: boolean
  • bufferPoolSize: number
  • OptionalviewHandler: QwpResultBatchViewHandler

  Returns QwpEgressQuery

Readonlycompletion

ReadonlyrequestId

retired

• get retired(): boolean
  Internal

  Whether the consumer has retired while the wire still drains.

  Returns boolean

usesViews

• get usesViews(): boolean
  Internal

  Returns boolean

[asyncIterator]

• "[asyncIterator]"(): AsyncIterator<QwpResultBatch>

  Returns AsyncIterator<QwpResultBatch>

armTimeout

• armTimeout(timeoutMs: number): void
  Internal

  Starts the deadline after QUERY_REQUEST reaches the transport.

  Parameters

  • timeoutMs: number

  Returns void

awaitCompletion

• awaitCompletion(timeoutMs: number): Promise<boolean>

  Waits for completion without changing the query lifecycle. A finite wait returns false on expiry; the query remains active until it completes, is cancelled explicitly, or its configured query deadline expires.

  Parameters

  • timeoutMs: number

  Returns Promise<boolean>

cancel

• cancel(): Promise<void>

  Returns Promise<void>

fail

• fail(error: unknown): void
  Internal

  Parameters

  • error: unknown

  Returns void

finish

• finish(completion: QwpQueryCompletion): Promise<void>
  Internal

  Parameters

  • completion: QwpQueryCompletion

  Returns Promise<void>

finishError

• finishError(error: Error): Promise<void>
  Internal

  Preserves batch/callback order before a wire query error.

  Parameters

  • error: Error

  Returns Promise<void>

grantCredit

• grantCredit(additionalBytes: number | bigint): Promise<void>

  Parameters

  • additionalBytes: number | bigint

  Returns Promise<void>

isDone

• isDone(): boolean

  Whether the query has reached any terminal outcome.

  Returns boolean

lateBatchCredit

• lateBatchCredit(creditBytes: number): number
  Internal

  Credit needed to discard a late batch while cancellation drains.

  Parameters

  • creditBytes: number

  Returns number

pushReserved

• pushReserved(batch: QwpResultBatch, creditBytes: number): void
  Internal

  Publishes a batch after reserveMaterializedBatch().

  Parameters

  • batch: QwpResultBatch
  • creditBytes: number

  Returns void

pushReservedView

• pushReservedView(
      batch: QwpResultBatchView,
      creditBytes: number,
      slot: number,
  ): void
  Internal

  Queues a decoded view after reserveViewBatch().

  Parameters

  • batch: QwpResultBatchView
  • creditBytes: number
  • slot: number

  Returns void

releaseMaterializedBatch

• releaseMaterializedBatch(): void
  Internal

  Releases a reservation when decoding fails.

  Returns void

releaseViewBatch

• releaseViewBatch(slot: number): void
  Internal

  Releases a reservation when zero-copy decoding fails.

  Parameters

  • slot: number

  Returns void

reserveMaterializedBatch

• reserveMaterializedBatch(): Promise<QwpBatchReservation>
  Internal

  Waits for one decoded materialized-batch slot.

  Returns Promise<QwpBatchReservation>

reserveViewBatch

• reserveViewBatch(): Promise<QwpViewBatchReservation>
  Internal

  Waits for one reusable zero-copy view slot.

  Returns Promise<QwpViewBatchReservation>

resetForReplay

• resetForReplay(): Promise<void>
  Internal

  Returns Promise<void>

retire

• retire(error: Error): number
  Internal

  Discards queued results and retires the consumer immediately.

  Parameters

  • error: Error

  Returns number

waitForViewDrain

• waitForViewDrain(): Promise<void>
  Internal

  Waits until all callback-scoped views have been released.

  Returns Promise<void>