forked from signalfx/microservices-demo
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathtracing.js
29 lines (23 loc) · 931 Bytes
/
tracing.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
const api = require("@opentelemetry/api");
const { NodeTracerProvider } = require('@opentelemetry/node');
const { B3Propagator } = require("@opentelemetry/core");
const { ZipkinExporter } = require('@opentelemetry/exporter-zipkin');
const { BatchSpanProcessor, ConsoleSpanExporter } = require('@opentelemetry/tracing');
api.propagation.setGlobalPropagator(new B3Propagator());
const provider = new NodeTracerProvider();
provider.register({
propagator: new B3Propagator(),
});
const exporter = new ZipkinExporter({
serviceName: 'paymentservice',
url: process.env.SIGNALFX_ENDPOINT_URL,
});
const tracer = provider.getTracer('paymentservice')
provider.addSpanProcessor(new BatchSpanProcessor(exporter));
const CONSOLE_SPAN = process.env['CONSOLE_SPAN'];
if (CONSOLE_SPAN === 'true') {
provider.addSpanProcessor(new BatchSpanProcessor(new ConsoleSpanExporter(), { bufferTimeout: 1000 }));
}
module.exports = {
tracer
}