@opentelemetry/instrumentation-amqplib
Advanced tools
Comparing version 0.38.0 to 0.39.0
@@ -26,2 +26,3 @@ "use strict"; | ||
const version_1 = require("./version"); | ||
const supportedVersions = ['>=0.5.5 <1']; | ||
class AmqplibInstrumentation extends instrumentation_1.InstrumentationBase { | ||
@@ -35,6 +36,6 @@ constructor(config = {}) { | ||
init() { | ||
const channelModelModuleFile = new instrumentation_1.InstrumentationNodeModuleFile('amqplib/lib/channel_model.js', ['>=0.5.5'], this.patchChannelModel.bind(this), this.unpatchChannelModel.bind(this)); | ||
const callbackModelModuleFile = new instrumentation_1.InstrumentationNodeModuleFile('amqplib/lib/callback_model.js', ['>=0.5.5'], this.patchChannelModel.bind(this), this.unpatchChannelModel.bind(this)); | ||
const connectModuleFile = new instrumentation_1.InstrumentationNodeModuleFile('amqplib/lib/connect.js', ['>=0.5.5'], this.patchConnect.bind(this), this.unpatchConnect.bind(this)); | ||
const module = new instrumentation_1.InstrumentationNodeModuleDefinition('amqplib', ['>=0.5.5'], undefined, undefined, [channelModelModuleFile, connectModuleFile, callbackModelModuleFile]); | ||
const channelModelModuleFile = new instrumentation_1.InstrumentationNodeModuleFile('amqplib/lib/channel_model.js', supportedVersions, this.patchChannelModel.bind(this), this.unpatchChannelModel.bind(this)); | ||
const callbackModelModuleFile = new instrumentation_1.InstrumentationNodeModuleFile('amqplib/lib/callback_model.js', supportedVersions, this.patchChannelModel.bind(this), this.unpatchChannelModel.bind(this)); | ||
const connectModuleFile = new instrumentation_1.InstrumentationNodeModuleFile('amqplib/lib/connect.js', supportedVersions, this.patchConnect.bind(this), this.unpatchConnect.bind(this)); | ||
const module = new instrumentation_1.InstrumentationNodeModuleDefinition('amqplib', supportedVersions, undefined, undefined, [channelModelModuleFile, connectModuleFile, callbackModelModuleFile]); | ||
return module; | ||
@@ -41,0 +42,0 @@ } |
@@ -1,3 +0,3 @@ | ||
export declare const PACKAGE_VERSION = "0.38.0"; | ||
export declare const PACKAGE_VERSION = "0.39.0"; | ||
export declare const PACKAGE_NAME = "@opentelemetry/instrumentation-amqplib"; | ||
//# sourceMappingURL=version.d.ts.map |
@@ -20,4 +20,4 @@ "use strict"; | ||
// this is autogenerated file, see scripts/version-update.js | ||
exports.PACKAGE_VERSION = '0.38.0'; | ||
exports.PACKAGE_VERSION = '0.39.0'; | ||
exports.PACKAGE_NAME = '@opentelemetry/instrumentation-amqplib'; | ||
//# sourceMappingURL=version.js.map |
{ | ||
"name": "@opentelemetry/instrumentation-amqplib", | ||
"version": "0.38.0", | ||
"version": "0.39.0", | ||
"description": "OpenTelemetry instrumentation for the `amqplib` messaging client for RabbitMQ", | ||
@@ -33,2 +33,3 @@ "keywords": [ | ||
"lint:fix": "eslint . --ext .ts --fix", | ||
"lint:readme": "node ../../../scripts/lint-readme.js", | ||
"precompile": "tsc --version && lerna run version:update --scope @opentelemetry/instrumentation-amqplib --include-dependencies", | ||
@@ -73,3 +74,3 @@ "prewatch": "npm run precompile", | ||
}, | ||
"gitHead": "0af1b70f7c3c9763c85ac51fa5e334c1e1512020" | ||
"gitHead": "ad8436d6a4174f2288cb939080cd4e74da94b0d7" | ||
} |
@@ -20,3 +20,3 @@ # OpenTelemetry Amqplib (RabbitMQ) Instrumentation for Node.js | ||
- `>=0.5.5` | ||
- [`amqplib`](https://www.npmjs.com/package/amqplib) versions `>=0.5.5 <1` | ||
@@ -73,14 +73,2 @@ ## Usage | ||
## Migration From opentelemetry-instrumentation-amqplib | ||
This instrumentation was originally published under the name `"opentelemetry-instrumentation-amqplib"` in [this repo](https://github.com/aspecto-io/opentelemetry-ext-js). Few breaking changes were made during porting to the contrib repo to align with conventions: | ||
### Hook Info | ||
The instrumentation's config `publishHook`, `publishConfirmHook`, `consumeHook` and `consumeEndHook` functions signature changed, so the second function parameter is info object, containing the relevant hook data. | ||
### `moduleVersionAttributeName` config option | ||
The `moduleVersionAttributeName` config option is removed. To add the amqplib package version to spans, use the `moduleVersion` attribute in hook info for `publishHook` and `consumeHook` functions. | ||
## Semantic Conventions | ||
@@ -87,0 +75,0 @@ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
778
118243
108