Class HttpTransport

HTTP transport implementation using Node.js built-in http/https modules.
Supports both HTTP and HTTPS protocols with configurable authentication.

Hierarchy

HttpTransportBase
- HttpTransport

Index

Constructors

Properties

secure host port username password token tlsVerify tlsCA requestMinThroughput requestTimeout retryTimeout log

Methods

connect close getDefaultAutoFlushRows send

Constructors

constructor

new HttpTransport(options: SenderOptions): HttpTransport
Creates a new HttpTransport instance using Node.js HTTP modules.
Parameters
- options: SenderOptions
  Sender configuration object containing connection details
Returns HttpTransport
Throws
Error if the protocol is not 'http' or 'https'
Overrides HttpTransportBase.constructor
- Defined in transport/http/stdlib.ts:40

Properties

`Protected` `Readonly`secure

secure: boolean

`Protected` `Readonly`host

host: string

`Protected` `Readonly`port

port: number

`Protected` `Readonly`username

username: string

`Protected` `Readonly`password

password: string

`Protected` `Readonly`token

token: string

`Protected` `Readonly`tlsVerify

tlsVerify: boolean

`Protected` `Readonly`tlsCA

tlsCA: Buffer

`Protected` `Readonly`requestMinThroughput

requestMinThroughput: number

`Protected` `Readonly`requestTimeout

requestTimeout: number

`Protected` `Readonly`retryTimeout

retryTimeout: number

`Protected` `Readonly`log

Methods

connect

connect(): Promise<boolean>
HTTP transport does not require explicit connection establishment.

Returns Promise<boolean>
Throws
Error indicating connect is not required for HTTP transport
Inherited from HttpTransportBase.connect
- Defined in transport/http/base.ts:107

close

close(): Promise<void>
HTTP transport does not require explicit connection closure.

Returns Promise<void>
Promise that resolves immediately
Inherited from HttpTransportBase.close
- Defined in transport/http/base.ts:115

getDefaultAutoFlushRows

getDefaultAutoFlushRows(): number
Gets the default auto-flush row count for HTTP transport.

Returns number
Default number of rows that trigger auto-flush
Inherited from HttpTransportBase.getDefaultAutoFlushRows
- Defined in transport/http/base.ts:121

send

send(
    data: Buffer,
    retryBegin?: number,
    retryInterval?: number,
): Promise<boolean>
Sends data to QuestDB using HTTP POST.
Parameters
- data: Buffer
  Buffer containing the data to send
- retryBegin: number = -1
  Internal parameter for tracking retry start time
- retryInterval: number = -1
  Internal parameter for tracking retry intervals
Returns Promise<boolean>
Promise resolving to true if data was sent successfully

Throws
Error if request fails after all retries or times out
Overrides HttpTransportBase.send
- Defined in transport/http/stdlib.ts:72