Class QwpNodeUdpSession

ReadonlymaxBatchSizeBytes

acknowledgedFrameSequence

• get acknowledgedFrameSequence(): bigint

  Returns bigint

publishedFrameSequence

• get publishedFrameSequence(): bigint

  Returns bigint

udpMetrics

• get udpMetrics(): QwpNodeUdpMetrics

  Returns QwpNodeUdpMetrics

close

• close(): Promise<void>

  Returns Promise<void>

publishTables

• publishTables(
      tables: readonly QwpTableBuffer[],
      options?: QwpIngressEncodeOptions,
  ): Promise<void>

  Parameters

  • tables: readonly QwpTableBuffer[]
  • options: QwpIngressEncodeOptions = {}

  Returns Promise<void>

sendTables

• sendTables(
      tables: readonly QwpTableBuffer[],
      options?: QwpIngressEncodeOptions,
  ): Promise<QwpIngressResponse>

  Parameters

  • tables: readonly QwpTableBuffer[]
  • options: QwpIngressEncodeOptions = {}

  Returns Promise<QwpIngressResponse>

waitForAcknowledged

• waitForAcknowledged(targetSequence: bigint): Promise<void>

  Parameters

  • targetSequence: bigint

  Returns Promise<void>

waitForDurable

• waitForDurable(): Promise<void>

  Returns Promise<void>

Staticconnect

• connect(options: QwpNodeUdpOptions): Promise<QwpNodeUdpSession>

  Parameters

  • options: QwpNodeUdpOptions

  Returns Promise<QwpNodeUdpSession>