-
Notifications
You must be signed in to change notification settings - Fork 39
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #352 from iRevive/docs/tracing-instrumentation
site: add `Tracing instrumentation` page
- Loading branch information
Showing
2 changed files
with
165 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,5 @@ | ||
laika.title = Instrumentation | ||
|
||
laika.navigationOrder = [ | ||
tracing | ||
] |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,160 @@ | ||
# Tracing | ||
|
||
`Tracer` is an entry point to the tracing capabilities and instrumentation. | ||
It provides various functionalities for creating and managing spans, | ||
extracting context from carriers, propagating context downstream, and more. | ||
|
||
### How to get the `Tracer` | ||
|
||
Currently, `otel4s` has a backend built on top of [OpenTelemetry Java][opentelemetry-java]. | ||
Add the following configuration to the favorite build tool: | ||
|
||
@:select(build-tool) | ||
|
||
@:choice(sbt) | ||
|
||
Add settings to the `build.sbt`: | ||
|
||
```scala | ||
libraryDependencies ++= Seq( | ||
"org.typelevel" %% "otel4s-java" % "@VERSION@", // <1> | ||
"io.opentelemetry" % "opentelemetry-exporter-otlp" % "@OPEN_TELEMETRY_VERSION@" % Runtime, // <2> | ||
"io.opentelemetry" % "opentelemetry-sdk-extension-autoconfigure" % "@OPEN_TELEMETRY_VERSION@" % Runtime // <3> | ||
) | ||
javaOptions += "-Dotel.java.global-autoconfigure.enabled=true" // <4> | ||
``` | ||
|
||
@:choice(scala-cli) | ||
|
||
Add directives to the `*.scala` file: | ||
|
||
```scala | ||
//> using lib "org.typelevel::otel4s-java:@VERSION@" // <1> | ||
//> using lib "io.opentelemetry:opentelemetry-exporter-otlp:@OPEN_TELEMETRY_VERSION@" // <2> | ||
//> using lib "io.opentelemetry:opentelemetry-sdk-extension-autoconfigure:@OPEN_TELEMETRY_VERSION@" // <3> | ||
//> using `java-opt` "-Dotel.java.global-autoconfigure.enabled=true" // <4> | ||
``` | ||
|
||
@:@ | ||
|
||
1. Add the `otel4s-java` library | ||
2. Add an OpenTelemetry exporter. Without the exporter, the application will crash | ||
3. Add an OpenTelemetry autoconfigure extension | ||
4. Enable OpenTelemetry SDK [autoconfigure mode][opentelemetry-java-autoconfigure] | ||
|
||
Once the build configuration is up-to-date, the `Tracer` can be created: | ||
|
||
```scala mdoc:silent | ||
import cats.effect.IO | ||
import org.typelevel.otel4s.trace.Tracer | ||
import org.typelevel.otel4s.java.OtelJava | ||
|
||
OtelJava.global.flatMap { otel4s => | ||
otel4s.tracerProvider.get("com.service").flatMap { implicit tracer: Tracer[IO] => | ||
val _ = tracer // use tracer here | ||
??? | ||
} | ||
} | ||
``` | ||
|
||
### Creating a span | ||
|
||
You can use the `span` or `spanBuilder` API to create a new span. | ||
|
||
The tracer automatically determines whether to create a child span or a root span based on the presence of a valid parent in the tracing context. | ||
If a valid parent is available, the new span becomes a child of it. Otherwise, it becomes a root span. | ||
|
||
Here's how you can do it: | ||
|
||
```scala mdoc:silent:reset | ||
import cats.Monad | ||
import cats.effect.Ref | ||
import cats.syntax.flatMap._ | ||
import cats.syntax.functor._ | ||
import org.typelevel.otel4s.Attribute | ||
import org.typelevel.otel4s.trace.Tracer | ||
|
||
case class User(email: String) | ||
|
||
class UserRepository[F[_]: Monad: Tracer](storage: Ref[F, Map[Long, User]]) { | ||
|
||
def findUser(userId: Long): F[Option[User]] = | ||
Tracer[F].span("find-user", Attribute("user_id", userId)).use { span => | ||
for { | ||
current <- storage.get | ||
user <- Monad[F].pure(current.get(userId)) | ||
_ <- span.addAttribute(Attribute("user_exists", user.isDefined)) | ||
} yield user | ||
} | ||
|
||
} | ||
``` | ||
|
||
### Starting a root span | ||
|
||
A root span is a span that is not a child of any other span. | ||
You can use `Tracer[F].rootScope` to wrap an existing effect or `Tracer[F].rootSpan` to explicitly start a new root span: | ||
|
||
```scala mdoc:silent | ||
import cats.Monad | ||
import cats.syntax.flatMap._ | ||
import cats.syntax.functor._ | ||
|
||
class UserRequestHandler[F[_]: Tracer: Monad](repo: UserRepository[F]) { | ||
private val SystemUserId = -1L | ||
|
||
def handleUser(userId: Long): F[Unit] = | ||
Tracer[F].rootScope(activateUser(userId)) | ||
|
||
def handleUserInternal(userId: Long): F[Unit] = | ||
Tracer[F].rootSpan("handle-user").surround(activateUser(userId)) | ||
|
||
private def activateUser(userId: Long): F[Unit] = | ||
for { | ||
systemUser <- repo.findUser(SystemUserId) | ||
user <- repo.findUser(userId) | ||
_ <- activate(systemUser, user) | ||
} yield () | ||
|
||
private def activate(systemUser: Option[User], target: Option[User]): F[Unit] = { | ||
val _ = (systemUser, target) // some processing logic | ||
Monad[F].unit | ||
} | ||
} | ||
``` | ||
|
||
While the behavior seems similar, the outcome is notably different: | ||
|
||
1. `Tracer[F].rootScope(activateUser(userId))` will create two **independent root** spans: | ||
|
||
``` | ||
> find-user { user_id = -1 } | ||
> find-user { user_id = 123 } | ||
``` | ||
|
||
2. `racer[F].rootSpan("handle-user").surround(activateUser(userId))` will create two **child** spans: | ||
|
||
``` | ||
> handle-user | ||
> find-user { user_id = -1 } | ||
> find-user { user_id = 123 } | ||
``` | ||
|
||
|
||
|
||
### Running effect without tracing | ||
|
||
If you want to disable tracing for a specific section of the effect, you can use the `Tracer[F].noopScope`. | ||
This creates a no-op scope where tracing operations have no effect: | ||
|
||
```scala mdoc:silent | ||
class InternalUserService[F[_]: Tracer](repo: UserRepository[F]) { | ||
|
||
def findUserInternal(userId: Long): F[Option[User]] = | ||
Tracer[F].noopScope(repo.findUser(userId)) | ||
|
||
} | ||
``` | ||
|
||
[opentelemetry-java]: https://github.com/open-telemetry/opentelemetry-java | ||
[opentelemetry-java-autoconfigure]: https://github.com/open-telemetry/opentelemetry-java/blob/main/sdk-extensions/autoconfigure/README.md |