-
Notifications
You must be signed in to change notification settings - Fork 1k
Expand file tree
/
Copy pathindex.js
More file actions
71 lines (60 loc) · 2.6 KB
/
index.js
File metadata and controls
71 lines (60 loc) · 2.6 KB
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
'use strict';
const opentelemetry = require('@opentelemetry/api');
const { resourceFromAttributes } = require('@opentelemetry/resources');
const { ATTR_SERVICE_NAME } = require('@opentelemetry/semantic-conventions');
const { BasicTracerProvider, ConsoleSpanExporter, SimpleSpanProcessor } = require('@opentelemetry/sdk-trace-base');
const { JaegerExporter } = require('@opentelemetry/exporter-jaeger');
const { AsyncLocalStorageContextManager } = require("@opentelemetry/context-async-hooks");
const {CompositePropagator, W3CTraceContextPropagator, W3CBaggagePropagator} = require("@opentelemetry/core");
// Configure span processor to send spans to the exporter
const exporter = new JaegerExporter({
endpoint: 'http://localhost:14268/api/traces',
});
/**
* Initialize the OpenTelemetry APIs to use the BasicTracerProvider bindings.
*
* This registers the tracer provider with the OpenTelemetry API as the global
* tracer provider. This means when you call API methods like
* `opentelemetry.trace.getTracer`, they will use this tracer provider. If you
* do not register a global tracer provider, instrumentation which calls these
* methods will receive no-op implementations.
*/
opentelemetry.trace.setGlobalTracerProvider(new BasicTracerProvider({
resource: resourceFromAttributes({
[ATTR_SERVICE_NAME]: 'basic-service',
}),
spanProcessors: [
new SimpleSpanProcessor(exporter),
new SimpleSpanProcessor(new ConsoleSpanExporter()),
]
}));
opentelemetry.context.setGlobalContextManager(new AsyncLocalStorageContextManager());
opentelemetry.propagation.setGlobalPropagator(new CompositePropagator({ propagators: [
new W3CTraceContextPropagator(),
new W3CBaggagePropagator()]
}));
const tracer = opentelemetry.trace.getTracer('example-basic-tracer-node');
// Create a span. A span must be closed.
const parentSpan = tracer.startSpan('main');
for (let i = 0; i < 10; i += 1) {
doWork(parentSpan);
}
// Be sure to end the span.
parentSpan.end();
// flush and close the connection.
exporter.shutdown();
function doWork(parent) {
// Start another span. In this example, the main method already started a
// span, so that'll be the parent span, and this will be a child span.
const ctx = opentelemetry.trace.setSpan(opentelemetry.context.active(), parent);
const span = tracer.startSpan('doWork', undefined, ctx);
// simulate some random work.
for (let i = 0; i <= Math.floor(Math.random() * 40000000); i += 1) {
// empty
}
// Set attributes to the span.
span.setAttribute('key', 'value');
// Annotate our span to capture metadata about our operation
span.addEvent('invoking doWork');
span.end();
}