Merge branch 'binary_protocol_arrays' into arrays_support

glasstiger · glasstiger · commit 7ce8469f3340 · 2025-08-06T02:58:20.000+01:00
diff --git a/src/buffer/base.ts b/src/buffer/base.ts
@@ -81,11 +81,7 @@ abstract class SenderBufferBase implements SenderBuffer {
       );
     }
     this.bufferSize = bufferSize;
-    // Allocating an extra byte because Buffer.write() does not fail if the length of the data to be written is
-    // longer than the size of the buffer. It simply just writes whatever it can, and returns.
-    // If we can write into the extra byte, that indicates buffer overflow.
-    // See the check in the write() function.
-    const newBuffer = Buffer.alloc(this.bufferSize + 1, 0);
+    const newBuffer = Buffer.alloc(this.bufferSize, 0);
     if (this.buffer) {
       this.buffer.copy(newBuffer);
     }
@@ -136,7 +132,7 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Write the table name into the buffer.
+   * Writes the table name into the buffer.
    *
    * @param {string} table - Table name.
    * @return {Sender} Returns with a reference to this sender.
@@ -156,7 +152,7 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Write a symbol name and value into the buffer.
+   * Writes a symbol name and value into the buffer.
    *
    * @param {string} name - Symbol name.
    * @param {unknown} value - Symbol value, toString() is called to extract the actual symbol value from the parameter.
@@ -183,7 +179,7 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Write a string column with its value into the buffer.
+   * Writes a string column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {string} value - Column value, accepts only string values.
@@ -205,7 +201,7 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Write a boolean column with its value into the buffer.
+   * Writes a boolean column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {boolean} value - Column value, accepts only boolean values.
@@ -225,18 +221,25 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Write a float column with its value into the buffer.
+   * Writes a float column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
    * @return {Sender} Returns with a reference to this sender.
    */
   abstract floatColumn(name: string, value: number): SenderBuffer;
 
+  /**
+   * Writes an array column with its values into the buffer.
+   *
+   * @param {string} name - Column name.
+   * @param {unknown[]} value - Column value, accepts only arrays.
+   * @return {Sender} Returns with a reference to this sender.
+   */
   abstract arrayColumn(name: string, value: unknown[]): SenderBuffer;
 
   /**
-   * Write an integer column with its value into the buffer.
+   * Writes an integer column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
@@ -257,7 +260,7 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Write a timestamp column with its value into the buffer.
+   * Writes a timestamp column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {number | bigint} value - Epoch timestamp, accepts numbers or BigInts.
@@ -283,7 +286,7 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Closing the row after writing the designated timestamp into the buffer.
+   * Closes the row after writing the designated timestamp into the buffer.
    *
    * @param {number | bigint} timestamp - Designated epoch timestamp, accepts numbers or BigInts.
    * @param {string} [unit=us] - Timestamp unit. Supported values: 'ns' - nanoseconds, 'us' - microseconds, 'ms' - milliseconds. Defaults to 'us'.
@@ -309,7 +312,7 @@ abstract class SenderBufferBase implements SenderBuffer {
   }
 
   /**
-   * Closing the row without writing designated timestamp into the buffer. <br>
+   * Closes the row without writing designated timestamp into the buffer. <br>
    * Designated timestamp will be populated by the server on this record.
    */
   atNow() {
@@ -376,7 +379,6 @@ abstract class SenderBufferBase implements SenderBuffer {
     this.writeEscaped(name);
     this.write("=");
     writeValue();
-    this.assertBufferOverflow();
     this.hasColumns = true;
   }
 
@@ -488,15 +490,6 @@ abstract class SenderBufferBase implements SenderBuffer {
         throw new Error(`Unsupported array type [type=${type}]`);
     }
   }
-
-  private assertBufferOverflow() {
-    if (this.position > this.bufferSize) {
-      // should never happen, if checkCapacity() is correctly used
-      throw new Error(
-        `Buffer overflow [position=${this.position}, bufferSize=${this.bufferSize}]`,
-      );
-    }
-  }
 }
 
 export { SenderBufferBase };
diff --git a/src/buffer/bufferv1.ts b/src/buffer/bufferv1.ts
@@ -13,7 +13,7 @@ class SenderBufferV1 extends SenderBufferBase {
   }
 
   /**
-   * Write a float column with its value into the buffer using v1 serialization (text format).
+   * Writes a float column with its value into the buffer using v1 serialization (text format).
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
diff --git a/src/buffer/bufferv2.ts b/src/buffer/bufferv2.ts
@@ -22,7 +22,7 @@ class SenderBufferV2 extends SenderBufferBase {
   }
 
   /**
-   * Write a float column with its value into the buffer using v2 serialization (binary format).
+   * Writes a float column with its value into the buffer using v2 serialization (binary format).
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
diff --git a/src/buffer/index.ts b/src/buffer/index.ts
@@ -61,15 +61,15 @@ interface SenderBuffer {
   toBufferNew(pos?: number): Buffer | null;
 
   /**
-   * Write the table name into the buffer.
+   * Writes the table name into the buffer.
    *
    * @param {string} table - Table name.
    * @return {Sender} Returns with a reference to this sender.
    */
   table(table: string): SenderBuffer;
 
   /**
-   * Write a symbol name and value into the buffer.
+   * Writes a symbol name and value into the buffer.
    *
    * @param {string} name - Symbol name.
    * @param {unknown} value - Symbol value, toString() is called to extract the actual symbol value from the parameter.
@@ -78,7 +78,7 @@ interface SenderBuffer {
   symbol(name: string, value: unknown): SenderBuffer;
 
   /**
-   * Write a string column with its value into the buffer.
+   * Writes a string column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {string} value - Column value, accepts only string values.
@@ -87,7 +87,7 @@ interface SenderBuffer {
   stringColumn(name: string, value: string): SenderBuffer;
 
   /**
-   * Write a boolean column with its value into the buffer.
+   * Writes a boolean column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {boolean} value - Column value, accepts only boolean values.
@@ -96,7 +96,7 @@ interface SenderBuffer {
   booleanColumn(name: string, value: boolean): SenderBuffer;
 
   /**
-   * Write a float column with its value into the buffer.
+   * Writes a float column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
@@ -107,7 +107,7 @@ interface SenderBuffer {
   arrayColumn(name: string, value: unknown[]): SenderBuffer;
 
   /**
-   * Write an integer column with its value into the buffer.
+   * Writes an integer column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
@@ -117,7 +117,7 @@ interface SenderBuffer {
   intColumn(name: string, value: number): SenderBuffer;
 
   /**
-   * Write a timestamp column with its value into the buffer.
+   * Writes a timestamp column with its value into the buffer.
    *
    * @param {string} name - Column name.
    * @param {number | bigint} value - Epoch timestamp, accepts numbers or BigInts.
@@ -131,15 +131,15 @@ interface SenderBuffer {
   ): SenderBuffer;
 
   /**
-   * Closing the row after writing the designated timestamp into the buffer.
+   * Closes the row after writing the designated timestamp into the buffer.
    *
    * @param {number | bigint} timestamp - Designated epoch timestamp, accepts numbers or BigInts.
    * @param {string} [unit=us] - Timestamp unit. Supported values: 'ns' - nanoseconds, 'us' - microseconds, 'ms' - milliseconds. Defaults to 'us'.
    */
   at(timestamp: number | bigint, unit: TimestampUnit): void;
 
   /**
-   * Closing the row without writing designated timestamp into the buffer. <br>
+   * Closes the row without writing designated timestamp into the buffer. <br>
    * Designated timestamp will be populated by the server on this record.
    */
   atNow(): void;
diff --git a/src/options.ts b/src/options.ts
@@ -1,10 +1,12 @@
+import { readFileSync } from "node:fs";
 import { PathOrFileDescriptor } from "fs";
 import { Agent } from "undici";
 import http from "http";
 import https from "https";
 
 import { Logger } from "./logging";
-import { fetchJson } from "./utils";
+import { fetchJson, isBoolean, isInteger } from "./utils";
+import { DEFAULT_REQUEST_TIMEOUT } from "./transport/http/base";
 
 const HTTP_PORT = 9000;
 const TCP_PORT = 9009;
@@ -234,8 +236,21 @@ class SenderOptions {
 
     const url = `${options.protocol}://${options.host}:${options.port}/settings`;
     const settings: {
-      config: { LINE_PROTO_SUPPORT_VERSION: number[] };
-    } = await fetchJson(url);
+      config: { [LINE_PROTO_SUPPORT_VERSION]: number[] };
+    } = await fetchJson(
+      url,
+      isInteger(options.request_timeout, 1)
+        ? options.request_timeout
+        : DEFAULT_REQUEST_TIMEOUT,
+      new Agent({
+        connect: {
+          ca: options.tls_ca ? readFileSync(options.tls_ca) : undefined,
+          rejectUnauthorized: isBoolean(options.tls_verify)
+            ? options.tls_verify
+            : true,
+        },
+      }),
+    );
     const supportedVersions: string[] = (
       settings.config[LINE_PROTO_SUPPORT_VERSION] ?? []
     ).map((version: unknown) => String(version));
diff --git a/src/sender.ts b/src/sender.ts
@@ -183,7 +183,7 @@ class Sender {
   }
 
   /**
-   * Write the table name into the buffer of the sender.
+   * Writes the table name into the buffer of the sender.
    *
    * @param {string} table - Table name.
    * @return {Sender} Returns with a reference to this sender.
@@ -194,7 +194,7 @@ class Sender {
   }
 
   /**
-   * Write a symbol name and value into the buffer of the sender.
+   * Writes a symbol name and value into the buffer of the sender.
    *
    * @param {string} name - Symbol name.
    * @param {unknown} value - Symbol value, toString() is called to extract the actual symbol value from the parameter.
@@ -206,7 +206,7 @@ class Sender {
   }
 
   /**
-   * Write a string column with its value into the buffer of the sender.
+   * Writes a string column with its value into the buffer of the sender.
    *
    * @param {string} name - Column name.
    * @param {string} value - Column value, accepts only string values.
@@ -218,7 +218,7 @@ class Sender {
   }
 
   /**
-   * Write a boolean column with its value into the buffer of the sender.
+   * Writes a boolean column with its value into the buffer of the sender.
    *
    * @param {string} name - Column name.
    * @param {boolean} value - Column value, accepts only boolean values.
@@ -230,7 +230,7 @@ class Sender {
   }
 
   /**
-   * Write a float column with its value into the buffer of the sender.
+   * Writes a float column with its value into the buffer of the sender.
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
@@ -247,7 +247,7 @@ class Sender {
   }
 
   /**
-   * Write an integer column with its value into the buffer of the sender.
+   * Writes an integer column with its value into the buffer of the sender.
    *
    * @param {string} name - Column name.
    * @param {number} value - Column value, accepts only number values.
@@ -259,7 +259,7 @@ class Sender {
   }
 
   /**
-   * Write a timestamp column with its value into the buffer of the sender.
+   * Writes a timestamp column with its value into the buffer of the sender.
    *
    * @param {string} name - Column name.
    * @param {number | bigint} value - Epoch timestamp, accepts numbers or BigInts.
@@ -276,7 +276,7 @@ class Sender {
   }
 
   /**
-   * Closing the row after writing the designated timestamp into the buffer of the sender.
+   * Closes the row after writing the designated timestamp into the buffer of the sender.
    *
    * @param {number | bigint} timestamp - Designated epoch timestamp, accepts numbers or BigInts.
    * @param {string} [unit=us] - Timestamp unit. Supported values: 'ns' - nanoseconds, 'us' - microseconds, 'ms' - milliseconds. Defaults to 'us'.
@@ -289,7 +289,7 @@ class Sender {
   }
 
   /**
-   * Closing the row without writing designated timestamp into the buffer of the sender. <br>
+   * Closes the row without writing designated timestamp into the buffer of the sender. <br>
    * Designated timestamp will be populated by the server on this record.
    */
   async atNow() {
diff --git a/src/transport/http/base.ts b/src/transport/http/base.ts
@@ -135,4 +135,9 @@ abstract class HttpTransportBase implements SenderTransport {
   abstract send(data: Buffer): Promise<boolean>;
 }
 
-export { HttpTransportBase, RETRIABLE_STATUS_CODES, HTTP_NO_CONTENT };
+export {
+  HttpTransportBase,
+  RETRIABLE_STATUS_CODES,
+  HTTP_NO_CONTENT,
+  DEFAULT_REQUEST_TIMEOUT,
+};
diff --git a/src/utils.ts b/src/utils.ts
@@ -1,3 +1,5 @@
+import { Agent } from "undici";
+
 type ArrayPrimitive = "number" | "boolean" | "string" | null;
 
 type TimestampUnit = "ns" | "us" | "ms";
@@ -109,13 +111,26 @@ function validateArray(data: unknown[], dimensions: number[]): ArrayPrimitive {
  * Fetches JSON data from a URL.
  * @template T - The expected type of the JSON response
  * @param url - The URL to fetch from
+ * @param agent - HTTP agent to be used for the request
+ * @param timeout - Request timeout, query will be aborted if not finished in time
  * @returns Promise resolving to the parsed JSON data
  * @throws Error if the request fails or returns a non-OK status
  */
-async function fetchJson<T>(url: string): Promise<T> {
+async function fetchJson<T>(
+  url: string,
+  timeout: number,
+  agent: Agent,
+): Promise<T> {
+  const controller = new AbortController();
+  const { signal } = controller;
+  setTimeout(() => controller.abort(), timeout);
+
   let response: globalThis.Response;
   try {
-    response = await fetch(url);
+    response = await fetch(url, {
+      dispatcher: agent,
+      signal,
+    });
   } catch (error) {
     throw new Error(`Failed to load ${url} [error=${error}]`);
   }
diff --git a/test/options.test.ts b/test/options.test.ts
diff --git a/test/sender.buffer.test.ts b/test/sender.buffer.test.ts

Original file line number	Diff line number	Diff line change
`@@ -81,11 +81,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`81`	`81`	`);`
`82`	`82`	`}`
`83`	`83`	`this.bufferSize = bufferSize;`
`84`		`- // Allocating an extra byte because Buffer.write() does not fail if the length of the data to be written is`
`85`		`- // longer than the size of the buffer. It simply just writes whatever it can, and returns.`
`86`		`- // If we can write into the extra byte, that indicates buffer overflow.`
`87`		`- // See the check in the write() function.`
`88`		`- const newBuffer = Buffer.alloc(this.bufferSize + 1, 0);`
	`84`	`+ const newBuffer = Buffer.alloc(this.bufferSize, 0);`
`89`	`85`	`if (this.buffer) {`
`90`	`86`	`this.buffer.copy(newBuffer);`
`91`	`87`	`}`
`@@ -136,7 +132,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`136`	`132`	`}`
`137`	`133`
`138`	`134`	`/**`
`139`		`- * Write the table name into the buffer.`
	`135`	`+ * Writes the table name into the buffer.`
`140`	`136`	`*`
`141`	`137`	`* @param {string} table - Table name.`
`142`	`138`	`* @return {Sender} Returns with a reference to this sender.`
`@@ -156,7 +152,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`156`	`152`	`}`
`157`	`153`
`158`	`154`	`/**`
`159`		`- * Write a symbol name and value into the buffer.`
	`155`	`+ * Writes a symbol name and value into the buffer.`
`160`	`156`	`*`
`161`	`157`	`* @param {string} name - Symbol name.`
`162`	`158`	`* @param {unknown} value - Symbol value, toString() is called to extract the actual symbol value from the parameter.`
`@@ -183,7 +179,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`183`	`179`	`}`
`184`	`180`
`185`	`181`	`/**`
`186`		`- * Write a string column with its value into the buffer.`
	`182`	`+ * Writes a string column with its value into the buffer.`
`187`	`183`	`*`
`188`	`184`	`* @param {string} name - Column name.`
`189`	`185`	`* @param {string} value - Column value, accepts only string values.`
`@@ -205,7 +201,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`205`	`201`	`}`
`206`	`202`
`207`	`203`	`/**`
`208`		`- * Write a boolean column with its value into the buffer.`
	`204`	`+ * Writes a boolean column with its value into the buffer.`
`209`	`205`	`*`
`210`	`206`	`* @param {string} name - Column name.`
`211`	`207`	`* @param {boolean} value - Column value, accepts only boolean values.`
`@@ -225,18 +221,25 @@ abstract class SenderBufferBase implements SenderBuffer {`
`225`	`221`	`}`
`226`	`222`
`227`	`223`	`/**`
`228`		`- * Write a float column with its value into the buffer.`
	`224`	`+ * Writes a float column with its value into the buffer.`
`229`	`225`	`*`
`230`	`226`	`* @param {string} name - Column name.`
`231`	`227`	`* @param {number} value - Column value, accepts only number values.`
`232`	`228`	`* @return {Sender} Returns with a reference to this sender.`
`233`	`229`	`*/`
`234`	`230`	`abstract floatColumn(name: string, value: number): SenderBuffer;`
`235`	`231`
	`232`	`+ /**`
	`233`	`+ * Writes an array column with its values into the buffer.`
	`234`	`+ *`
	`235`	`+ * @param {string} name - Column name.`
	`236`	`+ * @param {unknown[]} value - Column value, accepts only arrays.`
	`237`	`+ * @return {Sender} Returns with a reference to this sender.`
	`238`	`+ */`
`236`	`239`	`abstract arrayColumn(name: string, value: unknown[]): SenderBuffer;`
`237`	`240`
`238`	`241`	`/**`
`239`		`- * Write an integer column with its value into the buffer.`
	`242`	`+ * Writes an integer column with its value into the buffer.`
`240`	`243`	`*`
`241`	`244`	`* @param {string} name - Column name.`
`242`	`245`	`* @param {number} value - Column value, accepts only number values.`
`@@ -257,7 +260,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`257`	`260`	`}`
`258`	`261`
`259`	`262`	`/**`
`260`		`- * Write a timestamp column with its value into the buffer.`
	`263`	`+ * Writes a timestamp column with its value into the buffer.`
`261`	`264`	`*`
`262`	`265`	`* @param {string} name - Column name.`
`263`	`266`	`* @param {number \| bigint} value - Epoch timestamp, accepts numbers or BigInts.`
`@@ -283,7 +286,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`283`	`286`	`}`
`284`	`287`
`285`	`288`	`/**`
`286`		`- * Closing the row after writing the designated timestamp into the buffer.`
	`289`	`+ * Closes the row after writing the designated timestamp into the buffer.`
`287`	`290`	`*`
`288`	`291`	`* @param {number \| bigint} timestamp - Designated epoch timestamp, accepts numbers or BigInts.`
`289`	`292`	`* @param {string} [unit=us] - Timestamp unit. Supported values: 'ns' - nanoseconds, 'us' - microseconds, 'ms' - milliseconds. Defaults to 'us'.`
`@@ -309,7 +312,7 @@ abstract class SenderBufferBase implements SenderBuffer {`
`309`	`312`	`}`
`310`	`313`
`311`	`314`	`/**`
`312`		`- * Closing the row without writing designated timestamp into the buffer. <br>`
	`315`	`+ * Closes the row without writing designated timestamp into the buffer. <br>`
`313`	`316`	`* Designated timestamp will be populated by the server on this record.`
`314`	`317`	`*/`
`315`	`318`	`atNow() {`
`@@ -376,7 +379,6 @@ abstract class SenderBufferBase implements SenderBuffer {`
`376`	`379`	`this.writeEscaped(name);`
`377`	`380`	`this.write("=");`
`378`	`381`	`writeValue();`
`379`		`- this.assertBufferOverflow();`
`380`	`382`	`this.hasColumns = true;`
`381`	`383`	`}`
`382`	`384`
`@@ -488,15 +490,6 @@ abstract class SenderBufferBase implements SenderBuffer {`
`488`	`490`	throw new Error(`Unsupported array type [type=${type}]`);
`489`	`491`	`}`
`490`	`492`	`}`
`491`		`-`
`492`		`- private assertBufferOverflow() {`
`493`		`- if (this.position > this.bufferSize) {`
`494`		`- // should never happen, if checkCapacity() is correctly used`
`495`		`- throw new Error(`
`496`		- `Buffer overflow [position=${this.position}, bufferSize=${this.bufferSize}]`,
`497`		`- );`
`498`		`- }`
`499`		`- }`
`500`	`493`	`}`
`501`	`494`
`502`	`495`	`export { SenderBufferBase };`
Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@ class SenderBufferV1 extends SenderBufferBase {`
`13`	`13`	`}`
`14`	`14`
`15`	`15`	`/**`
`16`		`- * Write a float column with its value into the buffer using v1 serialization (text format).`
	`16`	`+ * Writes a float column with its value into the buffer using v1 serialization (text format).`
`17`	`17`	`*`
`18`	`18`	`* @param {string} name - Column name.`
`19`	`19`	`* @param {number} value - Column value, accepts only number values.`
Original file line number	Diff line number	Diff line change
`@@ -22,7 +22,7 @@ class SenderBufferV2 extends SenderBufferBase {`
`22`	`22`	`}`
`23`	`23`
`24`	`24`	`/**`
`25`		`- * Write a float column with its value into the buffer using v2 serialization (binary format).`
	`25`	`+ * Writes a float column with its value into the buffer using v2 serialization (binary format).`
`26`	`26`	`*`
`27`	`27`	`* @param {string} name - Column name.`
`28`	`28`	`* @param {number} value - Column value, accepts only number values.`
Original file line number	Diff line number	Diff line change
`@@ -183,7 +183,7 @@ class Sender {`
`183`	`183`	`}`
`184`	`184`
`185`	`185`	`/**`
`186`		`- * Write the table name into the buffer of the sender.`
	`186`	`+ * Writes the table name into the buffer of the sender.`
`187`	`187`	`*`
`188`	`188`	`* @param {string} table - Table name.`
`189`	`189`	`* @return {Sender} Returns with a reference to this sender.`
`@@ -194,7 +194,7 @@ class Sender {`
`194`	`194`	`}`
`195`	`195`
`196`	`196`	`/**`
`197`		`- * Write a symbol name and value into the buffer of the sender.`
	`197`	`+ * Writes a symbol name and value into the buffer of the sender.`
`198`	`198`	`*`
`199`	`199`	`* @param {string} name - Symbol name.`
`200`	`200`	`* @param {unknown} value - Symbol value, toString() is called to extract the actual symbol value from the parameter.`
`@@ -206,7 +206,7 @@ class Sender {`
`206`	`206`	`}`
`207`	`207`
`208`	`208`	`/**`
`209`		`- * Write a string column with its value into the buffer of the sender.`
	`209`	`+ * Writes a string column with its value into the buffer of the sender.`
`210`	`210`	`*`
`211`	`211`	`* @param {string} name - Column name.`
`212`	`212`	`* @param {string} value - Column value, accepts only string values.`
`@@ -218,7 +218,7 @@ class Sender {`
`218`	`218`	`}`
`219`	`219`
`220`	`220`	`/**`
`221`		`- * Write a boolean column with its value into the buffer of the sender.`
	`221`	`+ * Writes a boolean column with its value into the buffer of the sender.`
`222`	`222`	`*`
`223`	`223`	`* @param {string} name - Column name.`
`224`	`224`	`* @param {boolean} value - Column value, accepts only boolean values.`
`@@ -230,7 +230,7 @@ class Sender {`
`230`	`230`	`}`
`231`	`231`
`232`	`232`	`/**`
`233`		`- * Write a float column with its value into the buffer of the sender.`
	`233`	`+ * Writes a float column with its value into the buffer of the sender.`
`234`	`234`	`*`
`235`	`235`	`* @param {string} name - Column name.`
`236`	`236`	`* @param {number} value - Column value, accepts only number values.`
`@@ -247,7 +247,7 @@ class Sender {`
`247`	`247`	`}`
`248`	`248`
`249`	`249`	`/**`
`250`		`- * Write an integer column with its value into the buffer of the sender.`
	`250`	`+ * Writes an integer column with its value into the buffer of the sender.`
`251`	`251`	`*`
`252`	`252`	`* @param {string} name - Column name.`
`253`	`253`	`* @param {number} value - Column value, accepts only number values.`
`@@ -259,7 +259,7 @@ class Sender {`
`259`	`259`	`}`
`260`	`260`
`261`	`261`	`/**`
`262`		`- * Write a timestamp column with its value into the buffer of the sender.`
	`262`	`+ * Writes a timestamp column with its value into the buffer of the sender.`
`263`	`263`	`*`
`264`	`264`	`* @param {string} name - Column name.`
`265`	`265`	`* @param {number \| bigint} value - Epoch timestamp, accepts numbers or BigInts.`
`@@ -276,7 +276,7 @@ class Sender {`
`276`	`276`	`}`
`277`	`277`
`278`	`278`	`/**`
`279`		`- * Closing the row after writing the designated timestamp into the buffer of the sender.`
	`279`	`+ * Closes the row after writing the designated timestamp into the buffer of the sender.`
`280`	`280`	`*`
`281`	`281`	`* @param {number \| bigint} timestamp - Designated epoch timestamp, accepts numbers or BigInts.`
`282`	`282`	`* @param {string} [unit=us] - Timestamp unit. Supported values: 'ns' - nanoseconds, 'us' - microseconds, 'ms' - milliseconds. Defaults to 'us'.`
`@@ -289,7 +289,7 @@ class Sender {`
`289`	`289`	`}`
`290`	`290`
`291`	`291`	`/**`
`292`		`- * Closing the row without writing designated timestamp into the buffer of the sender. <br>`
	`292`	`+ * Closes the row without writing designated timestamp into the buffer of the sender. <br>`
`293`	`293`	`* Designated timestamp will be populated by the server on this record.`
`294`	`294`	`*/`
`295`	`295`	`async atNow() {`