chore: add jaeger example

open-telemetry · Jul 14, 2020 · a6959ae · a6959ae
1 parent d5b70c6
commit a6959ae
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 10 deletions.
diff --git a/examples/koa/jaeger.jpg → examples/koa/images/jaeger.jpg b/examples/koa/jaeger.jpg → examples/koa/images/jaeger.jpg
diff --git a/zipkin.jpg → examples/koa/images/zipkin.jpg b/zipkin.jpg → examples/koa/images/zipkin.jpg
diff --git a/examples/koa/jaeger.png b/examples/koa/jaeger.png
diff --git a/examples/koa/server.js b/examples/koa/server.js
@@ -28,7 +28,7 @@ async function setUp () {
 */
 const posts = ["post 0", "post 1", "post 2"];
 
-async function addPost(ctx) {
+async function addPost(ctx, next) {
     posts.push("post " + posts.length);
     console.log("addPost");
     const currentSpan = tracer.getCurrentSpan();
@@ -38,8 +38,8 @@ async function addPost(ctx) {
     const viewNewPost = ctx.redirect(`/post/3`);
 }
 
-async function showNewPost(ctx) {
-    console.log("showPost");
+async function showNewPost(ctx, next) {
+    console.log("showNewPost");
     const id = ctx.params.id;
     const post = posts[id];
     if (!post) ctx.throw(404, 'Invalid post id');
@@ -48,8 +48,13 @@ async function showNewPost(ctx) {
 
 async function runTest (ctx, next) {
     console.log("runTest");
+    const currentSpan = tracer.getCurrentSpan();
+    const { traceId } = currentSpan.context();
+    console.log(`traceid: ${traceId}`);
+    console.log(`Jaeger URL: http://localhost:16686/trace/${traceId}`);
+    console.log(`Zipkin URL: http://localhost:9411/zipkin/traces/${traceId}`);
     ctx.body = "All posts: " + posts;
-    const addNewPost = ctx.redirect(`/post/new`);
+    const addNewPost = await ctx.redirect(`/post/new`);
 }
 
 function no_op (ctx, next) {

diff --git a/examples/koa/tracer.js b/examples/koa/tracer.js
@@ -21,12 +21,12 @@ module.exports = (serviceName) => {
     },
   });
 
-  provider.addSpanProcessor(new SimpleSpanProcessor(new ZipkinExporter({
-    serviceName,
-  })));
-  provider.addSpanProcessor(new SimpleSpanProcessor(new JaegerExporter({
-    serviceName,
-  })));
+
+if (process.env.EXPORTER == 'jaeger') {
+  provider.addSpanProcessor(new SimpleSpanProcessor(new JaegerExporter({serviceName})));
+} else {
+  provider.addSpanProcessor(new SimpleSpanProcessor(new ZipkinExporter({serviceName})));
+}
 
   // Initialize the OpenTelemetry APIs to use the NodeTracerProvider bindings
   provider.register();