Adopt ServiceContext 1.0 (#127)

Author: ktoso

Docs/SwiftDistributedTracing/empty.swift

@@ -16,4 +16,4 @@
 // This module is left purposefully empty of any source files, as it serves
 // only as a "landing page" for the documentation. This is in-place until docc
 // gains the ability to support package-wide documentation.
-// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! //
+// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! //

IntegrationTests/tests_01_performance/test_01_resources/run-nio-alloc-counter-tests.sh

@@ -53,7 +53,7 @@ fi
 
 "$here/../../allocation-counter-tests-framework/run-allocation-counter.sh" \
     -p "$here/../../.." \
-    -m Baggage \
+    -m ServiceContext \
     -m Instrumentation \
     -m NIOInstrumentation \
     -s "$here/shared.swift" \

IntegrationTests/tests_01_performance/test_01_resources/shared.swift

@@ -27,7 +27,7 @@
 //===----------------------------------------------------------------------===//
 
 import Foundation
-import InstrumentationBaggage
+import ServiceContextModule
 
 @inline(never)
 func take1(context: BaggageContext) -> Int {

IntegrationTests/tests_01_performance/test_01_resources/test_001_pass_around_static_strings_small.swift

@@ -26,7 +26,7 @@
 //
 //===----------------------------------------------------------------------===//
 
-import InstrumentationBaggage
+import ServiceContextModule
 
 func run(identifier: String) {
     measure(identifier: identifier) {

IntegrationTests/tests_01_performance/test_01_resources/test_002_pass_around_static_strings_large.swift

@@ -26,7 +26,7 @@
 //
 //===----------------------------------------------------------------------===//
 
-import InstrumentationBaggage
+import ServiceContextModule
 
 func run(identifier: String) {
     measure(identifier: identifier) {

Package.swift

@@ -14,7 +14,8 @@ let package = Package(
         .library(name: "Tracing", targets: ["Tracing"]),
     ],
     dependencies: [
-        .package(url: "https://github.com/apple/swift-distributed-tracing-baggage.git", .upToNextMinor(from: "0.4.1")),
+        //        .package(url: "https://github.com/apple/swift-service-context.git", from: "1.0.0"),
+        .package(url: "https://github.com/apple/swift-service-context.git", branch: "main"),
         .package(url: "https://github.com/apple/swift-docc-plugin", from: "1.0.0"),
     ],
     targets: [
@@ -24,7 +25,7 @@ let package = Package(
         .target(
             name: "Instrumentation",
             dependencies: [
-                .product(name: "InstrumentationBaggage", package: "swift-distributed-tracing-baggage"),
+                .product(name: "ServiceContextModule", package: "swift-service-context"),
             ]
         ),
         .testTarget(
@@ -56,7 +57,7 @@ let package = Package(
         .executableTarget(
             name: "_TracingBenchmarks",
             dependencies: [
-                .product(name: "InstrumentationBaggage", package: "swift-distributed-tracing-baggage"),
+                .product(name: "ServiceContextModule", package: "swift-service-context"),
                 .target(name: "Tracing"),
                 .target(name: "_TracingBenchmarkTools"),
             ]

README.md

@@ -25,5 +25,5 @@
 //===----------------------------------------------------------------------===//
 
 func sleep(for duration: ContinuousClock.Duration) async {
-  try? await Task.sleep(until: ContinuousClock.now + duration, clock: .continuous)
-}
+    try? await Task.sleep(until: ContinuousClock.now + duration, clock: .continuous)
+}

Samples/Dinner/Sources/Onboarding/Clock+Extensions.swift

@@ -24,67 +24,66 @@
 //
 //===----------------------------------------------------------------------===//
 
-
 import Tracing
 
 func makeDinner() async throws -> Meal {
-  try await InstrumentationSystem.tracer.withSpan("makeDinner") { _ in
-    await sleep(for: .milliseconds(200))
+    try await InstrumentationSystem.tracer.withSpan("makeDinner") { _ in
+        await sleep(for: .milliseconds(200))
 
-    async let veggies = try chopVegetables()
-    async let meat = marinateMeat()
-    async let oven = preheatOven(temperature: 350)
-    // ...
-    return try await cook(veggies, meat, oven)
-  }
+        async let veggies = try chopVegetables()
+        async let meat = marinateMeat()
+        async let oven = preheatOven(temperature: 350)
+        // ...
+        return try await cook(veggies, meat, oven)
+    }
 }
 
 func chopVegetables() async throws -> [Vegetable] {
-  try await otelChopping1.tracer().withSpan("chopVegetables") { _ in
-    // Chop the vegetables...!
-    //
-    // However, since chopping is a very difficult operation,
-    // one chopping task can be performed at the same time on a single service!
-    // (Imagine that... we cannot parallelize these two tasks, and need to involve another service).
-    async let carrot = try chop(.carrot, tracer: otelChopping1.tracer())
-    async let potato = try chop(.potato, tracer: otelChopping2.tracer())
-    return try await [carrot, potato]
-  }
+    try await otelChopping1.tracer().withSpan("chopVegetables") { _ in
+        // Chop the vegetables...!
+        //
+        // However, since chopping is a very difficult operation,
+        // one chopping task can be performed at the same time on a single service!
+        // (Imagine that... we cannot parallelize these two tasks, and need to involve another service).
+        async let carrot = try chop(.carrot, tracer: otelChopping1.tracer())
+        async let potato = try chop(.potato, tracer: otelChopping2.tracer())
+        return try await [carrot, potato]
+    }
 }
 
 func chop(_ vegetable: Vegetable, tracer: any Tracer) async throws -> Vegetable {
-  await tracer.withSpan("chop-\(vegetable)") { _ in
-    await sleep(for: .seconds(5))
-    // ...
-    return vegetable // "chopped"
-  }
+    await tracer.withSpan("chop-\(vegetable)") { _ in
+        await sleep(for: .seconds(5))
+        // ...
+        return vegetable // "chopped"
+    }
 }
 
 func marinateMeat() async -> Meat {
-  await sleep(for: .milliseconds(620))
+    await sleep(for: .milliseconds(620))
 
-  return await InstrumentationSystem.tracer.withSpan("marinateMeat") { _ in
-    await sleep(for: .seconds(3))
-    // ...
-    return Meat()
-  }
+    return await InstrumentationSystem.tracer.withSpan("marinateMeat") { _ in
+        await sleep(for: .seconds(3))
+        // ...
+        return Meat()
+    }
 }
 
 func preheatOven(temperature: Int) async -> Oven {
-  await InstrumentationSystem.tracer.withSpan("preheatOven") { _ in
-    // ...
-    await sleep(for: .seconds(6))
-    return Oven()
-  }
+    await InstrumentationSystem.tracer.withSpan("preheatOven") { _ in
+        // ...
+        await sleep(for: .seconds(6))
+        return Oven()
+    }
 }
 
 func cook(_: Any, _: Any, _: Any) async -> Meal {
-  await InstrumentationSystem.tracer.withSpan("cook") { span in
-    span.addEvent("children-asking-if-done-already")
-    await sleep(for: .seconds(3))
-    span.addEvent("children-asking-if-done-already-again")
-    await sleep(for: .seconds(2))
-    // ...
-    return Meal()
-  }
+    await InstrumentationSystem.tracer.withSpan("cook") { span in
+        span.addEvent("children-asking-if-done-already")
+        await sleep(for: .seconds(3))
+        span.addEvent("children-asking-if-done-already-again")
+        await sleep(for: .seconds(2))
+        // ...
+        return Meal()
+    }
 }

Samples/Dinner/Sources/Onboarding/Dinner.swift

@@ -24,12 +24,10 @@
 //
 //===----------------------------------------------------------------------===//
 
-
 struct Meal: Sendable {}
 struct Meat: Sendable {}
 struct Oven: Sendable {}
 enum Vegetable: Sendable {
-  case potato
-  case carrot
+    case potato
+    case carrot
 }
-