59 lines
1.3 KiB
JavaScript
59 lines
1.3 KiB
JavaScript
'use strict';
|
|
|
|
const http = require('http');
|
|
const opentracing = require('opentracing');
|
|
const utils = require('./utils');
|
|
const shim = require('./shim').shim('http_server_opentracing');
|
|
|
|
opentracing.initGlobalTracer(shim);
|
|
const tracer = opentracing.globalTracer();
|
|
|
|
startServer(3000);
|
|
|
|
function startServer(port) {
|
|
const server = http.createServer(handleRequest);
|
|
|
|
server.listen(port, (err) => {
|
|
if (err) throw err;
|
|
|
|
console.log(`Server is listening on ${port}`);
|
|
});
|
|
}
|
|
|
|
async function handleRequest(req, res) {
|
|
const parentSpan = tracer.extract(
|
|
opentracing.FORMAT_HTTP_HEADERS,
|
|
req.headers,
|
|
);
|
|
|
|
const span = tracer.startSpan('handle_request', {
|
|
childOf: parentSpan,
|
|
});
|
|
|
|
span.setTag('custom', 'tag value');
|
|
span.setTag('alpha', '1000');
|
|
|
|
await doSomething(span);
|
|
|
|
res.writeHead(200, { 'Content-Type': 'application/json' });
|
|
res.write(
|
|
JSON.stringify({ status: 'OK', traceId: span.context().toTraceId() }),
|
|
);
|
|
|
|
res.end();
|
|
span.finish();
|
|
}
|
|
|
|
async function doSomething(parentSpan) {
|
|
const span = tracer.startSpan('do_something', { childOf: parentSpan });
|
|
|
|
span.setTag('alpha', '200');
|
|
span.setTag('beta', '50');
|
|
span.log({ state: 'waiting' });
|
|
|
|
// deliberately sleeping to mock some action.
|
|
await utils.sleep(1000);
|
|
|
|
span.finish();
|
|
}
|