Skip to content

Commit 05ce87e

Browse files
himanshu219himanshu219
authored
Merge pull request #75 from SumoLogic/update-errorlog
log error update
2 parents 3c0510c + f613fa8 commit 05ce87e

File tree

9 files changed

+21
-21
lines changed

9 files changed

+21
-21
lines changed

‎EventHubs/src/index.js‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ module.exports = function (context, eventHubMessages) {
3030

3131

3232
function failureHandler(msgArray,ctx) {
33-
ctx.log("Failed to send to Sumo, backup to storageaccount now" + ' messagesAttempted: ' + this.messagesAttempted + ' messagesReceived: ' + this.
33+
ctx.log.error("Failed to send to Sumo, backup to storageaccount now" + ' messagesAttempted: ' + this.messagesAttempted + ' messagesReceived: ' + this.
3434
messagesReceived);
3535
if (this.messagesAttempted === this.messagesReceived) {
3636
context.bindings.outputBlob = messageArray.map(function(x) { return JSON.stringify(x);}).join("\n");

‎EventHubs/src/index_metrics.js‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ module.exports = function (context, eventHubMessages) {
6161

6262
// handlers for success and failures
6363
function failureHandler(msgArray,ctx) {
64-
ctx.log("Failed to send metrics to Sumo");
64+
ctx.log.error("Failed to send metrics to Sumo");
6565
if (this.messagesAttempted === this.messagesReceived) {
6666
context.bindings.outputBlob = messageArray.map(function(x) { return JSON.stringify(x);}).join("\n");
6767
context.done();

‎EventHubs/target/logs_build/EventHubs_Logs/index.js‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ module.exports = function (context, eventHubMessages) {
3030

3131

3232
function failureHandler(msgArray,ctx) {
33-
ctx.log("Failed to send to Sumo, backup to storageaccount now" + ' messagesAttempted: ' + this.messagesAttempted + ' messagesReceived: ' + this.
33+
ctx.log.error("Failed to send to Sumo, backup to storageaccount now" + ' messagesAttempted: ' + this.messagesAttempted + ' messagesReceived: ' + this.
3434
messagesReceived);
3535
if (this.messagesAttempted === this.messagesReceived) {
3636
context.bindings.outputBlob = messageArray.map(function(x) { return JSON.stringify(x);}).join("\n");

‎EventHubs/target/logs_build/EventHubs_Logs/sumoclient.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -184,13 +184,13 @@ SumoClient.prototype.flushBucketToSumo = function(metaKey) {
184184
.catch((err) => {
185185
self.messagesFailed += msgArray.length;
186186
self.messagesAttempted += msgArray.length;
187-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
187+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
188188
self.failure_callback(msgArray,self.context);
189189
});
190190
} else {
191191
self.messagesFailed += msgArray.length;
192192
self.messagesAttempted += msgArray.length;
193-
self.context.log("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
193+
self.context.log.error("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
194194
self.failure_callback(msgArray,self.context);
195195
}
196196
});
@@ -201,7 +201,7 @@ SumoClient.prototype.flushBucketToSumo = function(metaKey) {
201201
.catch((err) => {
202202
self.messagesFailed += msgArray.length;
203203
self.messagesAttempted += msgArray.length;
204-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
204+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
205205
self.failure_callback(msgArray,self.context);
206206
});
207207
}

‎EventHubs/target/logs_build/EventHubs_Logs/sumometricclient.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -179,13 +179,13 @@ SumoMetricClient.prototype.flushBucketToSumo = function(metaKey) {
179179
.catch((err) => {
180180
self.messagesFailed += msgArray.length;
181181
self.messagesAttempted += msgArray.length;
182-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
182+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
183183
self.failure_callback(msgArray,self.context);
184184
});
185185
} else {
186186
self.messagesFailed += msgArray.length;
187187
self.messagesAttempted += msgArray.length;
188-
self.context.log("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
188+
self.context.log.error("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
189189
self.failure_callback(msgArray,self.context);
190190
}
191191
});
@@ -196,7 +196,7 @@ SumoMetricClient.prototype.flushBucketToSumo = function(metaKey) {
196196
.catch((err) => {
197197
self.messagesFailed += msgArray.length;
198198
self.messagesAttempted += msgArray.length;
199-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
199+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
200200
self.failure_callback(msgArray,self.context);
201201
});
202202
}

‎EventHubs/target/metrics_build/EventHubs_Metrics/sumoclient.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -184,13 +184,13 @@ SumoClient.prototype.flushBucketToSumo = function(metaKey) {
184184
.catch((err) => {
185185
self.messagesFailed += msgArray.length;
186186
self.messagesAttempted += msgArray.length;
187-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
187+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
188188
self.failure_callback(msgArray,self.context);
189189
});
190190
} else {
191191
self.messagesFailed += msgArray.length;
192192
self.messagesAttempted += msgArray.length;
193-
self.context.log("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
193+
self.context.log.error("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
194194
self.failure_callback(msgArray,self.context);
195195
}
196196
});
@@ -201,7 +201,7 @@ SumoClient.prototype.flushBucketToSumo = function(metaKey) {
201201
.catch((err) => {
202202
self.messagesFailed += msgArray.length;
203203
self.messagesAttempted += msgArray.length;
204-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
204+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
205205
self.failure_callback(msgArray,self.context);
206206
});
207207
}

‎EventHubs/target/metrics_build/EventHubs_Metrics/sumometricclient.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -179,13 +179,13 @@ SumoMetricClient.prototype.flushBucketToSumo = function(metaKey) {
179179
.catch((err) => {
180180
self.messagesFailed += msgArray.length;
181181
self.messagesAttempted += msgArray.length;
182-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
182+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
183183
self.failure_callback(msgArray,self.context);
184184
});
185185
} else {
186186
self.messagesFailed += msgArray.length;
187187
self.messagesAttempted += msgArray.length;
188-
self.context.log("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
188+
self.context.log.error("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
189189
self.failure_callback(msgArray,self.context);
190190
}
191191
});
@@ -196,7 +196,7 @@ SumoMetricClient.prototype.flushBucketToSumo = function(metaKey) {
196196
.catch((err) => {
197197
self.messagesFailed += msgArray.length;
198198
self.messagesAttempted += msgArray.length;
199-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
199+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
200200
self.failure_callback(msgArray,self.context);
201201
});
202202
}

‎sumo-function-utils/lib/sumoclient.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -184,13 +184,13 @@ SumoClient.prototype.flushBucketToSumo = function(metaKey) {
184184
.catch((err) => {
185185
self.messagesFailed += msgArray.length;
186186
self.messagesAttempted += msgArray.length;
187-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
187+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
188188
self.failure_callback(msgArray,self.context);
189189
});
190190
} else {
191191
self.messagesFailed += msgArray.length;
192192
self.messagesAttempted += msgArray.length;
193-
self.context.log("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
193+
self.context.log.error("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
194194
self.failure_callback(msgArray,self.context);
195195
}
196196
});
@@ -201,7 +201,7 @@ SumoClient.prototype.flushBucketToSumo = function(metaKey) {
201201
.catch((err) => {
202202
self.messagesFailed += msgArray.length;
203203
self.messagesAttempted += msgArray.length;
204-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
204+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
205205
self.failure_callback(msgArray,self.context);
206206
});
207207
}

‎sumo-function-utils/lib/sumometricclient.js‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -179,13 +179,13 @@ SumoMetricClient.prototype.flushBucketToSumo = function(metaKey) {
179179
.catch((err) => {
180180
self.messagesFailed += msgArray.length;
181181
self.messagesAttempted += msgArray.length;
182-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
182+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
183183
self.failure_callback(msgArray,self.context);
184184
});
185185
} else {
186186
self.messagesFailed += msgArray.length;
187187
self.messagesAttempted += msgArray.length;
188-
self.context.log("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
188+
self.context.log.error("Failed to gzip: " + JSON.stringify(e) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
189189
self.failure_callback(msgArray,self.context);
190190
}
191191
});
@@ -196,7 +196,7 @@ SumoMetricClient.prototype.flushBucketToSumo = function(metaKey) {
196196
.catch((err) => {
197197
self.messagesFailed += msgArray.length;
198198
self.messagesAttempted += msgArray.length;
199-
self.context.log("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
199+
self.context.log.error("Failed to send after retries: " + self.MaxAttempts + " " + JSON.stringify(err) + ' messagesAttempted: ' + self.messagesAttempted + ' messagesReceived: ' + self.messagesReceived);
200200
self.failure_callback(msgArray,self.context);
201201
});
202202
}

0 commit comments

Comments
 (0)