Dev/twegner/issue 18

samples/Exporters/TestApplicationInsights.cs

@@ -5,11 +5,13 @@
     using System.Threading;
     using Microsoft.ApplicationInsights.Extensibility;
     using OpenTelemetry.Exporter.ApplicationInsights;
+    using OpenTelemetry.Internal;
     using OpenTelemetry.Stats;
     using OpenTelemetry.Stats.Aggregations;
     using OpenTelemetry.Stats.Measures;
     using OpenTelemetry.Tags;
     using OpenTelemetry.Trace;
+    using OpenTelemetry.Trace.Export;
     using OpenTelemetry.Trace.Sampler;
 
     internal class TestApplicationInsights
@@ -34,8 +36,11 @@ internal class TestApplicationInsights
 
         internal static object Run()
         {
+            SimpleEventQueue eventQueue = new SimpleEventQueue();
+            ExportComponent exportComponent = ExportComponent.CreateWithInProcessStores(eventQueue);
+
             TelemetryConfiguration.Active.InstrumentationKey = "instrumentation-key";
-            var exporter = new ApplicationInsightsExporter(Tracing.ExportComponent, Stats.ViewManager, TelemetryConfiguration.Active);
+            var exporter = new ApplicationInsightsExporter(exportComponent, Stats.ViewManager, TelemetryConfiguration.Active);
             exporter.Start();
 
             var tagContextBuilder = tagger.CurrentBuilder.Put(FrontendKey, TagValue.Create("mobile-ios9.3.5"));
@@ -67,6 +72,8 @@ internal static object Run()
             Console.WriteLine("Done... wait for events to arrive to backend!");
             Console.ReadLine();
 
+            exportComponent.SpanExporter.Dispose();
+
             return null;
         }
     }

samples/Exporters/TestHttpClient.cs

@@ -5,7 +5,7 @@
     using OpenTelemetry.Collector.Dependencies;
     using OpenTelemetry.Exporter.Zipkin;
     using OpenTelemetry.Trace;
-    using OpenTelemetry.Context.Propagation;
+    using OpenTelemetry.Trace.Export;
     using OpenTelemetry.Trace.Sampler;
 
     internal class TestHttpClient
@@ -24,7 +24,7 @@ internal static object Run()
                     Endpoint = new Uri("https://zipkin.azurewebsites.net/api/v2/spans"),
                     ServiceName = typeof(Program).Assembly.GetName().Name,
                 },
-                Tracing.ExportComponent);
+                ExportComponent.NewNoopExportComponent);
             exporter.Start();
 
             var scope = tracer.SpanBuilder("incoming request").SetSampler(Samplers.AlwaysSample).StartScopedSpan();

samples/Exporters/TestRedis.cs

@@ -5,7 +5,9 @@
     using System.Threading;
     using OpenTelemetry.Collector.StackExchangeRedis;
     using OpenTelemetry.Exporter.Zipkin;
+    using OpenTelemetry.Internal;
     using OpenTelemetry.Trace;
+    using OpenTelemetry.Trace.Export;
     using OpenTelemetry.Trace.Config;
     using OpenTelemetry.Trace.Sampler;
     using StackExchange.Redis;
@@ -14,19 +16,23 @@ internal class TestRedis
     {
         internal static object Run(string zipkinUri)
         {
+            // 0. Initialization
+            SimpleEventQueue eventQueue = new SimpleEventQueue();
+            ExportComponent exportComponent = ExportComponent.CreateWithInProcessStores(eventQueue);
+
             // 1. Configure exporter to export traces to Zipkin
             var exporter = new ZipkinTraceExporter(
                 new ZipkinTraceExporterOptions()
                 {
                     Endpoint = new Uri(zipkinUri),
                     ServiceName = "tracing-to-zipkin-service",
                 },
-                Tracing.ExportComponent);
+                exportComponent);
             exporter.Start();
 
             // 2. Configure 100% sample rate for the purposes of the demo
-            var traceConfig = Tracing.TraceConfig;
-            var currentConfig = traceConfig.ActiveTraceParams;
+            ITraceConfig traceConfig = new TraceConfig();
+            ITraceParams currentConfig = traceConfig.ActiveTraceParams;
             var newConfig = currentConfig.ToBuilder()
                 .SetSampler(Samplers.AlwaysSample)
                 .Build();
@@ -36,44 +42,44 @@ internal static object Run(string zipkinUri)
             // but if not - you can use it as follows:
             var tracer = Tracing.Tracer;
 
-            var collector = new StackExchangeRedisCallsCollector(null, tracer, null, Tracing.ExportComponent);
+            var collector = new StackExchangeRedisCallsCollector(null, tracer, null, exportComponent);
 
             // connect to the server
-            var connection = ConnectionMultiplexer.Connect("localhost:6379");
+            ConnectionMultiplexer connection = ConnectionMultiplexer.Connect("localhost:6379");
             connection.RegisterProfiler(collector.GetProfilerSessionsFactory());
 
             // select a database (by default, DB = 0)
-            var db = connection.GetDatabase();
+            IDatabase db = connection.GetDatabase();
 
 
             // 4. Create a scoped span. It will end automatically when using statement ends
             using (var scope = tracer.SpanBuilder("Main").StartScopedSpan())
             {
                 Console.WriteLine("About to do a busy work");
-                for (var i = 0; i < 10; i++)
+                for (int i = 0; i < 10; i++)
                 {
                     DoWork(db, i);
                 }
             }
 
             // 5. Gracefully shutdown the exporter so it'll flush queued traces to Zipkin.
-            Tracing.ExportComponent.SpanExporter.Dispose();
+            exportComponent.SpanExporter.Dispose();
 
             return null;
         }
 
         private static void DoWork(IDatabase db, int i)
         {
             // 6. Get the global singleton Tracer object
-            var tracer = Tracing.Tracer;
+            ITracer tracer = Tracing.Tracer;
 
             // 7. Start another span. If another span was already started, it'll use that span as the parent 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.
-            using (var scope = tracer.SpanBuilder("DoWork").StartScopedSpan())
+            using (OpenTelemetry.Context.IScope scope = tracer.SpanBuilder("DoWork").StartScopedSpan())
             {
                 // Simulate some work.
-                var span = tracer.CurrentSpan;
+                ISpan span = tracer.CurrentSpan;
 
                 try
                 {
@@ -83,7 +89,7 @@ private static void DoWork(IDatabase db, int i)
                     Thread.Sleep(1000);
 
                     // run a command, in this case a GET
-                    var myVal = db.StringGet("key");
+                    RedisValue myVal = db.StringGet("key");
 
                     Console.WriteLine(myVal);
 

samples/Exporters/TestStackdriver.cs

@@ -9,6 +9,7 @@
     using OpenTelemetry.Stats.Measures;
     using OpenTelemetry.Tags;
     using OpenTelemetry.Trace;
+    using OpenTelemetry.Trace.Export;
     using OpenTelemetry.Trace.Sampler;
 
     internal class TestStackdriver
@@ -34,8 +35,8 @@ internal class TestStackdriver
         internal static object Run(string projectId)
         {
             var exporter = new StackdriverExporter(
-                projectId, 
-                Tracing.ExportComponent,
+                projectId,
+                ExportComponent.NewNoopExportComponent,
                 Stats.ViewManager);
             exporter.Start();
 

samples/Exporters/TestZipkin.cs

@@ -4,27 +4,33 @@
     using System.Collections.Generic;
     using System.Threading;
     using OpenTelemetry.Exporter.Zipkin;
+    using OpenTelemetry.Internal;
     using OpenTelemetry.Trace;
     using OpenTelemetry.Trace.Config;
+    using OpenTelemetry.Trace.Export;
     using OpenTelemetry.Trace.Sampler;
 
     internal class TestZipkin
     {
         internal static object Run(string zipkinUri)
         {
+            // 0. Initialization
+            SimpleEventQueue eventQueue = new SimpleEventQueue();
+            ExportComponent exportComponent = ExportComponent.CreateWithInProcessStores(eventQueue);
+
             // 1. Configure exporter to export traces to Zipkin
             var exporter = new ZipkinTraceExporter(
                 new ZipkinTraceExporterOptions()
                 {
                     Endpoint = new Uri(zipkinUri),
                     ServiceName = "tracing-to-zipkin-service",
                 },
-                Tracing.ExportComponent);
+                exportComponent);
             exporter.Start();
 
             // 2. Configure 100% sample rate for the purposes of the demo
-            var traceConfig = Tracing.TraceConfig;
-            var currentConfig = traceConfig.ActiveTraceParams;
+            ITraceConfig traceConfig = new TraceConfig();
+            ITraceParams currentConfig = traceConfig.ActiveTraceParams;
             var newConfig = currentConfig.ToBuilder()
                 .SetSampler(Samplers.AlwaysSample)
                 .Build();
@@ -38,30 +44,30 @@ internal static object Run(string zipkinUri)
             using (var scope = tracer.SpanBuilder("Main").StartScopedSpan())
             {
                 Console.WriteLine("About to do a busy work");
-                for (var i = 0; i < 10; i++)
+                for (int i = 0; i < 10; i++)
                 {
                     DoWork(i);
                 }
             }
 
             // 5. Gracefully shutdown the exporter so it'll flush queued traces to Zipkin.
-            Tracing.ExportComponent.SpanExporter.Dispose();
+            exportComponent.SpanExporter.Dispose();
 
             return null;
         }
 
         private static void DoWork(int i)
         {
             // 6. Get the global singleton Tracer object
-            var tracer = Tracing.Tracer;
+            ITracer tracer = Tracing.Tracer;
 
             // 7. Start another span. If another span was already started, it'll use that span as the parent 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.
-            using (var scope = tracer.SpanBuilder("DoWork").StartScopedSpan())
+            using (OpenTelemetry.Context.IScope scope = tracer.SpanBuilder("DoWork").StartScopedSpan())
             {
                 // Simulate some work.
-                var span = tracer.CurrentSpan;
+                ISpan span = tracer.CurrentSpan;
 
                 try
                 {