How to propagate external context to Phobos? about phobos-issues HOT 10 CLOSED

    let createSetup (sp: IServiceProvider) enableMetrics enableTracing =
        let metrics = sp.GetRequiredService<IMetricsRoot>()
        let tracer = sp.GetRequiredService<OpenTracing.ITracer>()
        let builder = Phobos.Actor.Configuration.PhobosConfigBuilder()
        let builder =
            if enableMetrics then
                builder.WithMetrics(fun b -> b.SetMetricsRoot(metrics) |> ignore)
            else
                builder
        let builder =
            if enableTracing then
                builder.WithTracing (fun b -> b.SetTracer(tracer) |> ignore)
            else
                builder
        PhobosSetup.Create(builder)

module PhobosBootstrapper =
    let private createMetrics (mb: IMetricsBuilder) =
        mb.Configuration.Configure (fun opts ->
            opts.GlobalTags.Add("host", Dns.GetHostName())
            opts.DefaultContextLabel <- "akka.net"
            opts.Enabled <- true
            opts.ReportingEnabled <- true)

    let createSetup (sp: IServiceProvider) =
        let metrics = sp.GetRequiredService<IMetricsRoot>()
        let tracer = sp.GetRequiredService<OpenTracing.ITracer>()
        let builder = Phobos.Actor.Configuration.PhobosConfigBuilder()
        let builder = builder.WithTracing (fun b -> b.SetTracer(tracer) |> ignore)
        PhobosSetup.Create(builder)


[<AutoOpen>]
module BootstrapperExtensions =
    let assemblyName = Reflection.Assembly.GetEntryAssembly().GetName().Name

    let buildTraceProvider (builder: TracerProviderBuilder) =
        builder
            .AddSource(assemblyName)
            .SetResourceBuilder(
                ResourceBuilder
                    .CreateDefault()
                    .AddService(assemblyName)
            )
            .AddAzureMonitorTraceExporter(fun o ->
                o.ConnectionString <-
                    "InstrumentationKey="MY_KEY";IngestionEndpoint=https://westeurope-2.in.applicationinsights.azure.com/")
            .Build()

    type IServiceCollection with
        member services.ConfigureTracing() : IServiceCollection =
            services.AddOpenTelemetryTracing(fun builder -> buildTraceProvider (Sdk.CreateTracerProviderBuilder()) |> ignore)
            |> ignore
            services.AddSingleton<ITracer> (fun sp ->
                let traceProvider = sp.GetRequiredService<TracerProvider>()
                let tracer = new TracerShim(traceProvider.GetTracer(assemblyName), Propagators.DefaultTextMapPropagator)
                GlobalTracer.RegisterIfAbsent(tracer) |> ignore
                tracer :> ITracer)

module Bootstrapper =
    let createActorSystem oddjobConfig serviceProvider enablePhobos =

        let actorSystemSetup =
            if oddjobConfig.Features.EnablePhobosInstrumentation && enablePhobos then
                let bootstrapSetup = loadAkkaClusterConfigurationWithPhobos () |> BootstrapSetup.Create().WithConfig
                (PhobosBootstrapper.createSetup serviceProvider oddjobConfig.Features.EnableAppMetrics oddjobConfig.Features.EnableOpenTracing)
                    .And(bootstrapSetup)
            else
                let bootstrapSetup = loadAkkaClusterConfiguration () |> BootstrapSetup.Create().WithConfig
                Akka.Actor.Setup.ActorSystemSetup.Create bootstrapSetup

        ActorSystem.Create(OddjobSystem, actorSystemSetup)