Remove public availability of MultiSpanProcessor

All configuration for SpanProcessors is now available from TracerProviderSDK

Author: Ignacio Bonafonte

Sources/OpenTelemetrySdk/Trace/MultiSpanProcessor.swift

@@ -18,12 +18,12 @@ import OpenTelemetryApi
 
 /// Implementation of the SpanProcessor that simply forwards all received events to a list of
 /// SpanProcessors.
-public struct MultiSpanProcessor: SpanProcessor {
+ struct MultiSpanProcessor: SpanProcessor {
     var spanProcessorsStart = [SpanProcessor]()
     var spanProcessorsEnd = [SpanProcessor]()
     var spanProcessorsAll = [SpanProcessor]()
 
-    public init(spanProcessors: [SpanProcessor]) {
+     init(spanProcessors: [SpanProcessor]) {
         spanProcessorsAll = spanProcessors
         spanProcessorsAll.forEach {
             if $0.isStartRequired {
@@ -35,33 +35,33 @@ public struct MultiSpanProcessor: SpanProcessor {
         }
     }
 
-    public var isStartRequired: Bool {
+     var isStartRequired: Bool {
         return spanProcessorsStart.count > 0
     }
 
-    public var isEndRequired: Bool {
+     var isEndRequired: Bool {
         return spanProcessorsEnd.count > 0
     }
 
-    public func onStart(parentContext: SpanContext?, span: ReadableSpan) {
+     func onStart(parentContext: SpanContext?, span: ReadableSpan) {
         spanProcessorsStart.forEach {
             $0.onStart(parentContext: parentContext, span: span)
         }
     }
 
-    public func onEnd(span: ReadableSpan) {
+     func onEnd(span: ReadableSpan) {
         for var processor in spanProcessorsEnd {
             processor.onEnd(span: span)
         }
     }
 
-    public func shutdown() {
+     func shutdown() {
         for var processor in spanProcessorsAll {
             processor.shutdown()
         }
     }
 
-    public func forceFlush() {
+     func forceFlush() {
         spanProcessorsAll.forEach {
             $0.forceFlush()
         }

Sources/OpenTelemetrySdk/Trace/TracerProviderSdk.swift

@@ -115,19 +115,28 @@ public class TracerProviderSdk: TracerProvider {
         sharedState.setSampler(newSampler)
     }
 
-    /// Returns the active SpanProcessor.
-    public func getActiveSpanProcessor() -> SpanProcessor {
-        sharedState.activeSpanProcessor
+    /// Returns the active SpanProcessors.
+    public func getActiveSpanProcessors() -> [SpanProcessor] {
+        if let processor = sharedState.activeSpanProcessor as? MultiSpanProcessor {
+            return processor.spanProcessorsAll
+        } else {
+            return [sharedState.activeSpanProcessor]
+        }
     }
 
-    /// Adds a new SpanProcessor to this Tracer.
+    /// Adds a new SpanProcessor to this TracerProvider.
     /// Any registered processor cause overhead, consider to use an async/batch processor especially
     /// for span exporting, and export to multiple backends using the MultiSpanExporter
     /// - Parameter spanProcessor: the new SpanProcessor to be added.
     public func addSpanProcessor(_ spanProcessor: SpanProcessor) {
         sharedState.addSpanProcessor(spanProcessor)
     }
 
+    /// Removes all SpanProcessors from this provider
+    public func resetSpanProcessors() {
+        sharedState.activeSpanProcessor = NoopSpanProcessor()
+    }
+
     /// Attempts to stop all the activity for this Tracer. Calls SpanProcessor.shutdown()
     /// for all registered SpanProcessors.
     /// This operation may block until all the Spans are processed. Must be called before turning

Tests/OpenTelemetrySdkTests/Trace/MultiSpanProcessorTests.swift

@@ -13,8 +13,8 @@
 // limitations under the License.
 //
 
-import OpenTelemetrySdk
 import OpenTelemetryApi
+@testable import OpenTelemetrySdk
 import XCTest
 
 class MultiSpanProcessorTest: XCTestCase {