A collection of propagation utils for opentelemetry.
npm install --save @opentelemetry/propagation-utilsTo make sure each message handled by pubsub creates a new process span, and propagates to any internal operation, do as follow:
import { pubsubPropagation } from '@opentelemetry/propagation-utils';
import { Span, propagation, trace, Context } from '@opentelemetry/api';
const patch = (message: Message[], rootSpan: Span) => {
const tracer = trace.getTracer('my-tracer');
pubsubPropagation.patchArrayForProcessSpans(messages, tracer);
pubsubPropagation.patchMessagesArrayToStartProcessSpans<Message>({
messages,
tracer,
parentSpan: rootSpan,
messageToSpanDetails: (message) => ({
attributes: { ... },
name: 'some-name',
parentContext: propagation.extract(....) as Context
}),
});
}- For more information on OpenTelemetry, visit: https://opentelemetry.io/
- For more about OpenTelemetry JavaScript: https://github.com/open-telemetry/opentelemetry-js
- For help or feedback on this project, join us in GitHub Discussions
Apache 2.0 - See LICENSE for more information.