clickhouse-cargo - npm Package Compare versions

Comparing version 2.0.0 to 2.0.1

lib/leader_election.js

@@ -45,2 +45,3 @@ // Generated by CoffeeScript 2.5.1
       RemoteClientPortByCargoId[cargoId] = portCollection;
+//debuglog "[UDPEchoSrv > on msg] cargoId:#{cargoId}, portCollection:", portCollection
 // echo back
@@ -50,3 +51,3 @@ for (port in portCollection) {
         if (port !== SERVICE_PORT) {
-          UDPEchoSrv.send(msg, 0, msg.length, port, SERVICE_HOST);
+          UDPEchoSrv.send(msg, 0, msg.length, port, SERVICE_HOST, SERVICE_HOST);
         }
@@ -56,3 +57,3 @@ }
     UDPEchoSrv.on("error", function(err) {
-      debuglog("[static] UDPEchoSrv error:", err);
+      debuglog("[static] UDP_ERR UDPEchoSrv error:", err);
     });
@@ -103,2 +104,5 @@ try {
     });
+    udpClient.on("error", function(err) {
+      debuglog("[static] UDP_ERR udpClient error:", err);
+    });
     procSend = function() {
@@ -110,8 +114,3 @@ ++countSend;
       } else {
-        //if cargoLeaderId is workerId
-        //debuglog "[electSelfToALeader@#{workerId}] is leader for #{cargoId}"
-        //else
-        //debuglog "[electSelfToALeader@#{workerId}] is follower for #{cargoId}"
         udpClient.send(msg, 0, msg.length, SERVICE_PORT, SERVICE_HOST);
-        //setTimeout(procSend, Math.random() * 1000 >>> 0)
         setTimeout(procSend, 200);
@@ -118,0 +117,0 @@ }

package.json

 {
   "name": "clickhouse-cargo",
-  "version": "2.0.0",
+  "version": "2.0.1",
   "description": "Accumulates insert queries and commit them to clickhouse in batch jobs with retries on failure. 这个模块将向 Clickhouse 数据库的高频写入改为低频的批量插入。",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

No alert changes

Worsened metrics

Total package byte prevSize

72618

decreased by-0.15%

Lines of code

908

decreased by-0.11%

No dependency changes