yotam-js-metrics-test - npm Package Compare versions

Comparing version 0.1.10 to 0.1.11

package.json

 {
   "name": "yotam-js-metrics-test",
-  "version": "0.1.10",
+  "version": "0.1.11",
   "description": "OpenTelemetry Collector Exporter allows user to send collected traces to the OpenTelemetry Collector",
@@ -5,0 +5,0 @@ "main": "src/index.js",

README.md

@@ -1,2 +0,2 @@
-This topic includes instructions on how to send custom metrics to Logz.io from your GO application.
+This topic includes instructions on how to send custom metrics to Logz.io from your Node.js application.
 
@@ -3,0 +3,0 @@ The included example uses the [OpenTelemetry JS SDK](https://github.com/open-telemetry/opentelemetry-js) and its based on [OpenTelemetry exporter collector proto](https://github.com/open-telemetry/opentelemetry-js/tree/main/packages/opentelemetry-exporter-collector-proto).

src/transformTs.js

 const wr = require('./remote_pb')
-
-
 function attachSample(s, samples, metric_type = 'reg'){
@@ -62,3 +60,3 @@ let sample = new wr.Sample();
     else {
-        //TODO
+        throw new Error('Metric type is not supported')
     }
@@ -122,3 +120,3 @@ samples.forEach((s) => {
     else {
-        //TODO
+        throw new Error('Metric type is not supported')
     }
@@ -125,0 +123,0 @@ labels.forEach((l) => {

src/util.js

@@ -21,5 +21,4 @@ "use strict";
 const SnappyJS = require('snappyjs');
-const https = require('https');
-const url = require('url');
 const transform = require('./transformTs');
+const retryCodes = [408, 500, 502, 503, 504, 522, 524];
 let lost = 0;
@@ -34,3 +33,3 @@
 const logger = createLogger({
-    defaultMeta: { exporter: 'logzio-exporter' },
+    defaultMeta: { exporter: 'logzio-nodejs-exporter' },
     format: combine(
@@ -56,10 +55,6 @@ timestamp(),
 function exporterRetryStrategy(err, response, body, options){
-    const retryCodes = [408, 500, 502, 503, 504, 522, 524];
     const shouldRetry = retryCodes.includes(response.statusCode);
     if (shouldRetry){
-        options.headers['logzio-shipper'] = `modejs-metrics/1.0.0/${response.attempts}`
-        logger.log({
-            level: "warn",
-            message: `Faild to export, attempt number: ${response.attempts}, retrying again in ${options.retryDelay/1000}s`,
-        })
+        options.headers['logzio-shipper'] = `modejs-metrics/1.0.0/${response.attempts}`;
+        logger.log({level: "warn", message: `Faild to export, attempt number: ${response.attempts}, retrying again in ${options.retryDelay/1000}s`,});
     }
@@ -72,11 +67,9 @@ return {
 
-function send(collector, objects, onSuccess, onError) {
+function send(collector, objects) {
     const serviceRequest = collector.convert(objects);
     const write_request = transform.toTimeSeries(serviceRequest)
     const bytes = write_request.serializeBinary();
-    const compr = SnappyJS.compress(bytes);
+    const payload = SnappyJS.compress(bytes);
     if (write_request.wrappers_["1"].length > 0) {
-
         //Send with htttp
-        // const parsedUrl = new url.URL(collector.url);
         const request = require('requestretry');
@@ -87,3 +80,3 @@ const options = {
             agent: collector.agent,
-            body: compr,
+            body: payload,
             headers: {
@@ -102,19 +95,10 @@ "Content-Encoding": "snappy",
 
-        logger.log({
-            level: 'info',
-            message: `Sending bulk of ${write_request.wrappers_["1"].length} timeseries`
-        });
+        logger.log({level: 'info', message: `Sending bulk of ${write_request.wrappers_["1"].length} timeseries`});
         request(options, function(err, response, body){
             // this callback will only be called when the request succeeded or after maxAttempts or on error
             if (response.statusCode != 200) {
-                logger.log({
-                    level: "warn",
-                    message:`Export failed after ${response.attempts} attempts. Status code: ${response.statusCode}`
-                })
+                logger.log({level: "warn", message:`Export failed after ${response.attempts} attempts. Status code: ${response.statusCode}`})
                 lost += write_request.wrappers_["1"].length;
             } else {
-                logger.log({
-                    level: "info",
-                    message:`Export Succeeded after ${response.attempts} attempts. Status code: ${response.statusCode}`
-                })
+                logger.log({level: "info", message:`Export Succeeded after ${response.attempts} attempts. Status code: ${response.statusCode}`})
                 lost = 0;
@@ -124,6 +108,3 @@ }
     } else {
-        logger.log({
-            level: "info",
-            message: "No timeseries to send"
-        })
+        logger.log({level: "info", message: "No timeseries to send"})
     }
@@ -130,0 +111,0 @@ }

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Improved metrics

Number of medium supply chain risk alerts

1

decreased by-50%

Worsened metrics

Total package byte prevSize

56499

decreased by-1.9%

Number of package files

11

decreased by-8.33%

Lines of code

1131

decreased by-3.25%

No dependency changes