Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
'use strict';
var atMostOnce = require('@instana/core').util.atMostOnce;
var exec = require('child_process').exec;
var http = require('@instana/core').uninstrumentedHttp.http;
var agentOpts = require('../agent/opts');
var logger;
logger = require('../logger').getLogger('announceCycle/agentHostLookup', function(newLogger) {
logger = newLogger;
});
// Depending on the environment in which the agent and node collector are running,
// the agent may be available under different hosts. For instance,
// when the agent and collector are running on the same host outside any container,
// the host will probably be 127.0.0.1.
//
// A custom host can be set via agent options
'use strict';
var serializeError = require('serialize-error');
var logger;
logger = require('../logger').getLogger('util/uncaughtExceptionHandler', function(newLogger) {
logger = newLogger;
});
var instanaNodeJsCore = require('@instana/core');
var tracing = instanaNodeJsCore.tracing;
var spanBuffer = tracing.spanBuffer;
var stackTraceUtil = instanaNodeJsCore.util.stackTrace;
var downstreamConnection = null;
var processIdentityProvider = null;
var uncaughtExceptionEventName = 'uncaughtException';
var unhandledRejectionEventName = 'unhandledRejection';
var unhandledRejectionDeprecationWarningHasBeenEmitted = false;
var stackTraceLength = 10;
var config;
// see
// https://nodejs.org/api/cli.html#cli_unhandled_rejections_mode /
// https://github.com/nodejs/node/pull/26599
var unhandledRejectionsMode = 'warn/default';
for (var i = 0; i < process.execArgv.length; i++) {
if (process.execArgv[i] === '--unhandled-rejections=none') {
unhandledRejectionsMode = 'none';
'use strict';
var serializeError = require('serialize-error');
var logger;
logger = require('../logger').getLogger('util/uncaughtExceptionHandler', function(newLogger) {
logger = newLogger;
});
var instanaNodeJsCore = require('@instana/core');
var tracing = instanaNodeJsCore.tracing;
var spanBuffer = tracing.spanBuffer;
var stackTraceUtil = instanaNodeJsCore.util.stackTrace;
var downstreamConnection = null;
var processIdentityProvider = null;
var uncaughtExceptionEventName = 'uncaughtException';
var unhandledRejectionEventName = 'unhandledRejection';
var unhandledRejectionDeprecationWarningHasBeenEmitted = false;
var stackTraceLength = 10;
var config;
// see
// https://nodejs.org/api/cli.html#cli_unhandled_rejections_mode /
// https://github.com/nodejs/node/pull/26599
var unhandledRejectionsMode = 'warn/default';
for (var i = 0; i < process.execArgv.length; i++) {
if (process.execArgv[i] === '--unhandled-rejections=none') {
unhandledRejectionsMode = 'none';
'use strict';
var clone = require('@instana/core').util.clone;
var compression = require('@instana/core').util.compression;
var tracing = require('@instana/core').tracing;
var metrics = require('../metrics');
var uncaught = require('../uncaught');
var logger;
logger = require('../logger').getLogger('announceCycle/agentready', function(newLogger) {
logger = newLogger;
});
var requestHandler = require('../agent/requestHandler');
var agentConnection = require('../agentConnection');
var ctx;
var resendFullDataEveryXTransmissions = 300; /* about every 5 minutes */
'use strict';
var logger;
logger = require('../logger').getLogger('metrics/gc', function(newLogger) {
logger = newLogger;
});
var slidingWindow = require('@instana/core').util.slidingWindow;
var windowOpts = { duration: 1000 };
var minorGcWindow = slidingWindow.create(windowOpts);
var majorGcWindow = slidingWindow.create(windowOpts);
var incrementalMarkingsWindow = slidingWindow.create(windowOpts);
var processWeakCallbacksWindow = slidingWindow.create(windowOpts);
var gcPauseWindow = slidingWindow.create(windowOpts);
exports.payloadPrefix = 'gc';
exports.currentPayload = {
minorGcs: 0,
majorGcs: 0,
incrementalMarkings: 0,
weakCallbackProcessing: 0,
gcPause: 0,
statsSupported: true
'use strict';
var applicationUnderMonitoring = require('@instana/core').util.applicationUnderMonitoring;
var logger;
logger = require('../logger').getLogger('metrics/version', function(newLogger) {
logger = newLogger;
});
exports.payloadPrefix = 'version';
exports.currentPayload = undefined;
exports.activate = function() {
applicationUnderMonitoring.getMainPackageJson(function(err, pckg) {
if (err) {
logger.warn('Failed to determine main package json. Reason: ', err.message, err.stack);
}
if (!err && pckg) {
exports.currentPayload = pckg.version;
'use strict';
var requireHook = require('@instana/core').util.requireHook;
var logger;
logger = require('../logger').getLogger('metrics/healthchecks', function(newLogger) {
logger = newLogger;
});
var timeBetweenHealthcheckCalls;
var healthy = 1;
var unhealthy = 0;
var adminPluginHealthcheck;
var timeoutHandle;
exports.payloadPrefix = 'healthchecks';
exports.currentPayload = {};
requireHook.onModuleLoad('admin-plugin-healthcheck', function onAdminPluginHealthcheckLoaded(_adminPluginHealthcheck) {
'use strict';
var atMostOnce = require('@instana/core').util.atMostOnce;
var buffer = require('@instana/core').util.buffer;
var fs = require('fs');
var http = require('@instana/core').uninstrumentedHttp.http;
var pathUtil = require('path');
var propertySizes = require('@instana/core').util.propertySizes;
var logger;
logger = require('./logger').getLogger('agentConnection', function(newLogger) {
logger = newLogger;
});
var circularReferenceRemover = require('./util/removeCircular');
var agentOpts = require('./agent/opts');
var pidStore = require('./pidStore');
var cmdline = require('./cmdline');
'use strict';
var path = require('path');
var fs = require('fs');
var applicationUnderMonitoring = require('@instana/core').util.applicationUnderMonitoring;
var logger;
logger = require('../logger').getLogger('metrics/dependencies', function(newLogger) {
logger = newLogger;
});
exports.payloadPrefix = 'dependencies';
exports.currentPayload = {};
exports.activate = function() {
applicationUnderMonitoring.getMainPackageJsonPath(function(err, packageJsonPath) {
if (err) {
return logger.warn('Failed to determine main package.json. Reason: %s %s ', err.message, err.stack);
} else if (!packageJsonPath) {
return logger.warn('Main package.json could not be found. Stopping dependency analysis.');
}
'use strict';
var applicationUnderMonitoring = require('@instana/core').util.applicationUnderMonitoring;
var logger;
logger = require('../logger').getLogger('metrics/description', function(newLogger) {
logger = newLogger;
});
exports.payloadPrefix = 'description';
exports.currentPayload = undefined;
exports.activate = function() {
applicationUnderMonitoring.getMainPackageJson(function(err, pckg) {
if (err) {
logger.warn('Failed to determine main package json. Reason: ', err.message, err.stack);
}
if (!err && pckg) {
exports.currentPayload = pckg.description;