zipkin-instrumentation-hapi

import * as Hapi from '@hapi/hapi'; import { Tracer, BatchRecorder, ConsoleRecorder } from 'zipkin'; import { HttpLogger } from 'zipkin-transport-http'; import { hapiInstrumentation } from 'zipkin-instrumentation-hapi'; const ZIPKIN_URL = process.env.ZIPKIN_URL ?? 'http://localhost:9411'; const recorder = process.env.NODE_ENV === 'production' ? new BatchRecorder({ logger: new HttpLogger({ endpoint: `${ZIPKIN_URL}/api/v2/spans`, headers: { 'Content-Type': 'application/json' } }) }) : new ConsoleRecorder(); const tracer = new Tracer({ recorder, serviceName: 'my-hapi-service' }); const init = async () => { const server = Hapi.server({ port: 3000, host: 'localhost' }); await server.register({ plugin: hapiInstrumentation, options: { tracer, serviceName: 'my-hapi-service' } }); server.route({ method: 'GET', path: '/hello', handler: (request, h) => { // Example of custom span creation const childSpan = tracer.startSpan('greet-user'); tracer.scoped(() => { tracer.recordServiceName('my-hapi-service'); tracer.recordRpc('GET'); tracer.recordAnnotation(new tracer.Annotation.ServerRecv()); // ... do some work ... tracer.recordAnnotation(new tracer.Annotation.ServerSend()); }, childSpan); return 'Hello, Zipkin!'; } }); await server.start(); console.log(`Server running on ${server.info.uri}`); }; process.on('unhandledRejection', (err) => { console.log(err); process.exit(1); }); init();