From e09c9c4456f0c0f1b8b593aed12a5be16da0d2a5 Mon Sep 17 00:00:00 2001 From: Siim Kallas Date: Thu, 1 Aug 2024 12:40:33 +0300 Subject: [PATCH] add node metric example --- example/metric.js | 38 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 example/metric.js diff --git a/example/metric.js b/example/metric.js new file mode 100644 index 0000000..a935245 --- /dev/null +++ b/example/metric.js @@ -0,0 +1,38 @@ +'use strict'; + +var signalflow = require('../'); + +var token = process.env['SPLUNK_ACCESS_TOKEN']; +var realm = process.env['SPLUNK_REALM'] || 'us0'; + +var sfxClient = new signalflow.SignalFlow(token, { + signalflowEndpoint: 'wss://stream.' + realm + '.signalfx.com', + apiEndpoint: 'https://api.' + realm + '.signalfx.com' +}); + +function receive() { + var program = "data('cpu.utilization').publish()"; + console.log('signalflow: ', program); + + var handle = sfxClient.execute({ + program: program, + start: Date.now() - 60000, + stop: Date.now() + 60000, + resolution: 10000, + immediate: false, + }); + + handle.stream(function (err, data) { + if (err) { + console.log(err); + return; + } + + if (data.type === 'data') { + data.data.forEach(function (dataPoint) { + console.log('value received: ', dataPoint); + }); + } + }); +} +receive();