fluentd-node - npm Package Compare versions

Comparing version 0.0.17 to 0.0.18

build/src/socket.d.ts

@@ -60,4 +60,2 @@ /// <reference types="node" />
      * Defaults to 3000 (3 seconds)
-     *
-     * Set to -1 for no timeout
      */
@@ -64,0 +62,0 @@ timeout?: number;

build/src/socket.js

@@ -272,4 +272,3 @@ "use strict";
             this.reconnectTimeoutId = null;
-            // Ignore errors if there are any
-            this.connect().catch(() => { });
+            this.connect();
         }, reconnectInterval);
@@ -289,7 +288,3 @@ }
     createTcpSocket() {
-        let opts = this.socketParams;
-        if (this.timeout >= 0) {
-            opts = { ...opts, timeout: this.timeout };
-        }
-        return net.createConnection(opts);
+        return net.createConnection({ ...this.socketParams, timeout: this.timeout });
     }
@@ -558,4 +553,3 @@ /**
             if (this.state === SocketState.IDLE) {
-                // Ignore errors if there are any
-                this.connect().catch(() => { });
+                this.connect();
             }
@@ -562,0 +556,0 @@ return false;

package.json

 {
   "name": "fluentd-node",
-  "version": "0.0.17",
+  "version": "0.0.18",
   "description": "A fluent protocol implementation in node",
@@ -5,0 +5,0 @@ "main": "./build/src/index.js",

README.md

@@ -11,2 +11,4 @@ # fluentd-node
 
+# This project is deprecated, and has moved to [@fluent-org/logger](https://github.com/fluent/fluent-logger-bulk-node). Follow releases there.
+
 ## Install
@@ -13,0 +15,0 @@

src/socket.ts

@@ -71,4 +71,2 @@ import * as net from "net";
    * Defaults to 3000 (3 seconds)
-   *
-   * Set to -1 for no timeout
    */
@@ -393,4 +391,3 @@ timeout?: number;
       this.reconnectTimeoutId = null;
-      // Ignore errors if there are any
-      this.connect().catch(() => {});
+      this.connect();
     }, reconnectInterval);
@@ -412,7 +409,3 @@ }
   private createTcpSocket(): net.Socket {
-    let opts: net.NetConnectOpts = this.socketParams;
-    if (this.timeout >= 0) {
-      opts = {...opts, timeout: this.timeout};
-    }
-    return net.createConnection(opts);
+    return net.createConnection({...this.socketParams, timeout: this.timeout});
   }
@@ -716,4 +709,3 @@
       if (this.state === SocketState.IDLE) {
-        // Ignore errors if there are any
-        this.connect().catch(() => {});
+        this.connect();
       }
@@ -720,0 +712,0 @@ return false;

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Number of lines in readme file

321

increased by0.63%

Worsened metrics

Total package byte prevSize

324007

decreased by-0.18%

Lines of code

7588

decreased by-0.21%

No dependency changes