fluentd-node - npm Package Compare versions

Comparing version 0.0.12 to 0.0.13

build/src/client.d.ts

@@ -341,2 +341,14 @@ import EventTime from "./event_time";
     private clearAcks;
+    /**
+     * Returns the number of queued events that haven't been sent yet
+     *
+     * Useful to react if we're queuing up too many events within a single tick
+     */
+    get queueLength(): number;
+    /**
+     * Returns whether or not the socket is writable
+     *
+     * Useful to react if we're disconnected for any reason
+     */
+    get writable(): boolean;
 }

build/src/client.js

@@ -498,4 +498,20 @@ "use strict";
     }
+    /**
+     * Returns the number of queued events that haven't been sent yet
+     *
+     * Useful to react if we're queuing up too many events within a single tick
+     */
+    get queueLength() {
+        return this.sendQueue.queueLength;
+    }
+    /**
+     * Returns whether or not the socket is writable
+     *
+     * Useful to react if we're disconnected for any reason
+     */
+    get writable() {
+        return this.socket.writable();
+    }
 }
 exports.FluentClient = FluentClient;
 //# sourceMappingURL=client.js.map

package.json

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

src/client.ts

@@ -804,2 +804,20 @@ import {
   }
+
+  /**
+   * Returns the number of queued events that haven't been sent yet
+   *
+   * Useful to react if we're queuing up too many events within a single tick
+   */
+  get queueLength(): number {
+    return this.sendQueue.queueLength;
+  }
+
+  /**
+   * Returns whether or not the socket is writable
+   *
+   * Useful to react if we're disconnected for any reason
+   */
+  get writable(): boolean {
+    return this.socket.writable();
+  }
 }

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

Total package byte prevSize

308400

increased by0.46%

Lines of code

7225

increased by0.61%

No dependency changes