feat: queryTimeout

InfluxCommunity · Nov 10, 2023 · 41f1b8e · 41f1b8e
1 parent c4bef5f
commit 41f1b8e
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 3 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,4 +1,12 @@
-## 0.5.0 [unreleased]
+## 0.4.1 [unreleased]
+
+### Feature
+
+1. Query timeout
+
+### Bugfix
+
+1. [#164](https://github.com/InfluxCommunity/influxdb3-js/issues/164): Default query timeout
 
 ## 0.4.0 [2023-11-03]
 

diff --git a/packages/client/src/impl/QueryApiImpl.ts b/packages/client/src/impl/QueryApiImpl.ts
@@ -41,8 +41,8 @@ export default class QueryApiImpl implements QueryApi {
 
     const token = this._options.token
     if (token) meta['authorization'] = `Bearer ${token}`
-
-    const options: RpcOptions = {meta}
+    const timeout = this._options.queryTimeout
+    const options: RpcOptions = {meta, timeout}
 
     const flightDataStream = client.doGet(ticket, options)
 

diff --git a/packages/client/src/options.ts b/packages/client/src/options.ts
@@ -13,6 +13,11 @@ export interface ConnectionOptions {
    * @defaultValue 10000
    */
   timeout?: number
+  /**
+   * stream timeout for query (grpc timeout)
+   * @defaultValue 60000
+   */
+  queryTimeout?: number
   /**
    * default database for write query if not present as argument.
    */
@@ -43,6 +48,7 @@ export interface ConnectionOptions {
 /** default connection options */
 export const DEFAULT_ConnectionOptions: Partial<ConnectionOptions> = {
   timeout: 10000,
+  queryTimeout: 60000,
 }
 
 /**