summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2018-01-06 13:46:08 +0100
committerschneefux <schneefux+commit@schneefux.xyz>2018-01-06 13:46:08 +0100
commit2a62e540bcaddf755a61608bdeaedc62a59f6c18 (patch)
tree6f8259be5fe04b8e26ed643b1fb340b2714c5197
parent9820cad981750a9990e747e19dada1c42bebdd53 (diff)
downloadtelesucker-2a62e540bcaddf755a61608bdeaedc62a59f6c18.tar.gz
telesucker-2a62e540bcaddf755a61608bdeaedc62a59f6c18.zip
add datadog
-rw-r--r--package-lock.json5
-rw-r--r--package.json1
-rw-r--r--worker.js10
3 files changed, 15 insertions, 1 deletions
diff --git a/package-lock.json b/package-lock.json
index 2772aa7..0552450 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -564,6 +564,11 @@
}
}
},
+ "winston-datadog": {
+ "version": "1.1.0",
+ "resolved": "https://registry.npmjs.org/winston-datadog/-/winston-datadog-1.1.0.tgz",
+ "integrity": "sha512-f3r1dsqXrK9o5nBRKFWaROf5QkoqJHGY6k0RMuwm4L+Oaab0JnQPGPkVxvJi9E1ylffGOrGFF/d9YCv2IP+IVg=="
+ },
"winston-loggly-bulk": {
"version": "2.0.0",
"resolved": "https://registry.npmjs.org/winston-loggly-bulk/-/winston-loggly-bulk-2.0.0.tgz",
diff --git a/package.json b/package.json
index 6c5f3dd..b5b67b8 100644
--- a/package.json
+++ b/package.json
@@ -11,6 +11,7 @@
"request-promise": "^4.2.1",
"sleep-promise": "^2.0.0",
"winston": "^2.3.1",
+ "winston-datadog": "^1.1.0",
"winston-loggly-bulk": "^2.0.0"
},
"devDependencies": {},
diff --git a/worker.js b/worker.js
index f94c11b..5c0f753 100644
--- a/worker.js
+++ b/worker.js
@@ -7,13 +7,15 @@ const amqp = require("amqplib"),
Promise = require("bluebird"),
winston = require("winston"),
loggly = require("winston-loggly-bulk"),
+ datadog = require("winston-datadog"),
request = require("request-promise"),
moment = require("moment");
const RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost",
QUEUE = process.env.QUEUE || "telesuck",
SHRINK_QUEUE = process.env.SHRINK_QUEUE || "shrink",
- LOGGLY_TOKEN = process.env.LOGGLY_TOKEN;
+ LOGGLY_TOKEN = process.env.LOGGLY_TOKEN,
+ DATADOG_TOKEN = process.env.DATADOG_TOKEN;
const logger = new (winston.Logger)({
transports: [
@@ -33,6 +35,12 @@ if (LOGGLY_TOKEN)
json: true
});
+// datadog integration
+if (DATADOG_TOKEN)
+ logger.add(new datadog({
+ api_key: DATADOG_TOKEN
+ }), null, true);
+
amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
process.on("SIGINT", () => {
rabbit.close();