Packages

prima_opentelemetry_ex

1.1.2
2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.1.0-pre.0 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.1.3 1.1.2 1.1.1 retired 1.1.0 1.0.1 1.0.0 1.0.0-rc.4 1.0.0-rc.3 1.0.0-rc.2 1.0.0-rc.1.1

PrimaOpentelemetryEx is a utility library for opentelemetry instrumentation in Prima elixir projects.

HexDocs

Current section

Files

Jump to
Readme
23 Versions
8 Dependencies
Dependants
Files
Activity
prima_opentelemetry_ex lib prima_opentelemetry_ex teletask.ex
Raw

lib/prima_opentelemetry_ex/teletask.ex 

defmodule PrimaOpentelemetryEx.TeleTask do

  @moduledoc """

  Wrapper of Task that mantains the span context

  """



  require OpenTelemetry.Tracer, as: Tracer

  require Logger



  @spec start((() -> any())) :: {:ok, pid()}

  def start(fun) do

    ctx = Tracer.current_span_ctx()

    meta = Logger.metadata()



    Task.start(fn ->

      Tracer.set_current_span(ctx)

      Logger.metadata(meta)

      fun.()

    end)

  end



  @spec async((() -> any)) :: Task.t()

  def async(fun) do

    ctx = Tracer.current_span_ctx()

    meta = Logger.metadata()



    Task.async(fn ->

      Tracer.set_current_span(ctx)

      Logger.metadata(meta)

      fun.()

    end)

  end



  @spec await(Task.t()) :: term

  def await(t) do

    Task.await(t)

  end

end