Skip to content

Commit c88ddd1

Browse files
glasstigerglasstiger
authored
TCP keepalive for ILP socket (#17)
* adding TCP keepalive * adding TCP keepalive * version bump
1 parent 83c7b19 commit c88ddd1

10 files changed

+29
-21
lines changed

‎docs/Sender.html

+12-12
Original file line numberDiff line numberDiff line change
@@ -327,7 +327,7 @@ <h5>Parameters:</h5>
327327

328328
<dt class="tag-source">Source:</dt>
329329
<dd class="tag-source"><ul class="dummy"><li>
330-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line355">line 355</a>
330+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line356">line 356</a>
331331
</li></ul></dd>
332332

333333

@@ -416,7 +416,7 @@ <h4 class="name" id="atNow"><span class="type-signature"></span>atNow<span class
416416

417417
<dt class="tag-source">Source:</dt>
418418
<dd class="tag-source"><ul class="dummy"><li>
419-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line374">line 374</a>
419+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line375">line 375</a>
420420
</li></ul></dd>
421421

422422

@@ -576,7 +576,7 @@ <h5>Parameters:</h5>
576576

577577
<dt class="tag-source">Source:</dt>
578578
<dd class="tag-source"><ul class="dummy"><li>
579-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line286">line 286</a>
579+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line287">line 287</a>
580580
</li></ul></dd>
581581

582582

@@ -687,7 +687,7 @@ <h4 class="name" id="close"><span class="type-signature">(async) </span>close<sp
687687

688688
<dt class="tag-source">Source:</dt>
689689
<dd class="tag-source"><ul class="dummy"><li>
690-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line166">line 166</a>
690+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line167">line 167</a>
691691
</li></ul></dd>
692692

693693

@@ -1064,7 +1064,7 @@ <h5>Parameters:</h5>
10641064

10651065
<dt class="tag-source">Source:</dt>
10661066
<dd class="tag-source"><ul class="dummy"><li>
1067-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line301">line 301</a>
1067+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line302">line 302</a>
10681068
</li></ul></dd>
10691069

10701070

@@ -1175,7 +1175,7 @@ <h4 class="name" id="flush"><span class="type-signature">(async) </span>flush<sp
11751175

11761176
<dt class="tag-source">Source:</dt>
11771177
<dd class="tag-source"><ul class="dummy"><li>
1178-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line179">line 179</a>
1178+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line180">line 180</a>
11791179
</li></ul></dd>
11801180

11811181

@@ -1357,7 +1357,7 @@ <h5>Parameters:</h5>
13571357

13581358
<dt class="tag-source">Source:</dt>
13591359
<dd class="tag-source"><ul class="dummy"><li>
1360-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line317">line 317</a>
1360+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line318">line 318</a>
13611361
</li></ul></dd>
13621362

13631363

@@ -1789,7 +1789,7 @@ <h5>Parameters:</h5>
17891789

17901790
<dt class="tag-source">Source:</dt>
17911791
<dd class="tag-source"><ul class="dummy"><li>
1792-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line269">line 269</a>
1792+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line270">line 270</a>
17931793
</li></ul></dd>
17941794

17951795

@@ -1971,7 +1971,7 @@ <h5>Parameters:</h5>
19711971

19721972
<dt class="tag-source">Source:</dt>
19731973
<dd class="tag-source"><ul class="dummy"><li>
1974-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line244">line 244</a>
1974+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line245">line 245</a>
19751975
</li></ul></dd>
19761976

19771977

@@ -2130,7 +2130,7 @@ <h5>Parameters:</h5>
21302130

21312131
<dt class="tag-source">Source:</dt>
21322132
<dd class="tag-source"><ul class="dummy"><li>
2133-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line223">line 223</a>
2133+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line224">line 224</a>
21342134
</li></ul></dd>
21352135

21362136

@@ -2312,7 +2312,7 @@ <h5>Parameters:</h5>
23122312

23132313
<dt class="tag-source">Source:</dt>
23142314
<dd class="tag-source"><ul class="dummy"><li>
2315-
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line337">line 337</a>
2315+
<a href="src_sender.js.html">src/sender.js</a>, <a href="src_sender.js.html#line338">line 338</a>
23162316
</li></ul></dd>
23172317

23182318

@@ -2386,7 +2386,7 @@ <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-@q
23862386
<br class="clear">
23872387

23882388
<footer>
2389-
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed Jan 04 2023 19:03:57 GMT+0000 (Greenwich Mean Time)
2389+
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed May 17 2023 18:51:54 GMT+0100 (British Summer Time)
23902390
</footer>
23912391

23922392
<script> prettyPrint(); </script>

‎docs/index.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-@q
176176
<br class="clear">
177177

178178
<footer>
179-
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed Jan 04 2023 19:03:57 GMT+0000 (Greenwich Mean Time)
179+
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed May 17 2023 18:51:54 GMT+0100 (British Summer Time)
180180
</footer>
181181

182182
<script> prettyPrint(); </script>

‎docs/index.js.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-@q
5353
<br class="clear">
5454

5555
<footer>
56-
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed Jan 04 2023 19:03:57 GMT+0000 (Greenwich Mean Time)
56+
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed May 17 2023 18:51:54 GMT+0100 (British Summer Time)
5757
</footer>
5858

5959
<script> prettyPrint(); </script>

‎docs/module-@questdb_nodejs-client.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-@q
156156
<br class="clear">
157157

158158
<footer>
159-
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed Jan 04 2023 19:03:57 GMT+0000 (Greenwich Mean Time)
159+
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed May 17 2023 18:51:54 GMT+0100 (British Summer Time)
160160
</footer>
161161

162162
<script> prettyPrint(); </script>

‎docs/src_sender.js.html

+2-1
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,7 @@ <h1 class="page-title">Source: src/sender.js</h1>
154154
await self.close();
155155
}
156156
});
157+
this.socket.setKeepAlive(true);
157158

158159
this.socket.on("data", async raw => {
159160
data = !data ? raw : Buffer.concat([data, raw]);
@@ -539,7 +540,7 @@ <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-@q
539540
<br class="clear">
540541

541542
<footer>
542-
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed Jan 04 2023 19:03:57 GMT+0000 (Greenwich Mean Time)
543+
Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.11</a> on Wed May 17 2023 18:51:54 GMT+0100 (British Summer Time)
543544
</footer>
544545

545546
<script> prettyPrint(); </script>

‎package-lock.json

+2-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@questdb/nodejs-client",
3-
"version": "1.0.2",
3+
"version": "1.0.3",
44
"description": "QuestDB Node.js Client",
55
"main": "index.js",
66
"types": "types/index.d.ts",

‎src/sender.js

+1
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,7 @@ class Sender {
126126
await self.close();
127127
}
128128
});
129+
this.socket.setKeepAlive(true);
129130

130131
this.socket.on("data", async raw => {
131132
data = !data ? raw : Buffer.concat([data, raw]);

‎test/sender.test.js

+7-1
Original file line numberDiff line numberDiff line change
@@ -553,6 +553,12 @@ describe("Sender tests with containerized QuestDB instance", () => {
553553
container = await new GenericContainer("questdb/questdb")
554554
.withExposedPorts(QUESTDB_HTTP_PORT, QUESTDB_ILP_PORT)
555555
.start();
556+
557+
const stream = await container.logs();
558+
stream
559+
.on("data", line => console.log(line))
560+
.on("err", line => console.error(line))
561+
.on("end", () => console.log("Stream closed"));
556562
});
557563

558564
afterAll(async () => {
@@ -572,7 +578,7 @@ describe("Sender tests with containerized QuestDB instance", () => {
572578

573579
// create table
574580
let createTableResult = await query(container,
575-
`CREATE TABLE ${tableName}(${getFieldsString(schema)}) TIMESTAMP (timestamp) PARTITION BY DAY`
581+
`CREATE TABLE ${tableName}(${getFieldsString(schema)}) TIMESTAMP (timestamp) PARTITION BY DAY BYPASS WAL`
576582
);
577583
expect(createTableResult.ddl).toBe("OK");
578584

‎types/src/sender.d.ts.map

+1-1
Original file line numberDiff line numberDiff line change

0 commit comments

Comments
 (0)