استفاده از OpenTelemetry در Agentها

using OpenTelemetry;
using OpenTelemetry.Metrics;
using OpenTelemetry.Resources;
using System.Diagnostics.Metrics;

namespace My
{
    public class Monitoring
    {
        public static readonly Meter Meter = new Meter("name.me");

        public static void InitOpenTelemetry(string serviceName)
        {
            Sdk.CreateMeterProviderBuilder()
                    .SetResourceBuilder(ResourceBuilder.CreateDefault().AddService(serviceName))
                    .AddMeter("name.me")
                    .AddPrometheusExporter(options =>
                    {
                        options.HttpListenerPrefixes = new[] { "http://site-me.com:4123" };
                    })
                    .Build();
        }
    }
}

Monitoring.InitOpenTelemetry("agent-name");

private readonly Counter<long> _acceptedMessageCounter;

protected QMessageDetector(string queueAddress)
{
    _acceptedMessageCounter = Monitoring.Meter.CreateCounter<long>("AcceptedMessage");
}

private void queue_ReceiveCompleted(string msg)
{
    _acceptedMessageCounter.Add(1, new KeyValuePair<string, object>("queue", msg.Length));
}

using OpenTelemetry;
using OpenTelemetry.Resources;
using OpenTelemetry.Trace;
using System;
using System.Diagnostics;

namespace My
{
    public sealed class TraceLogger : IDisposable
    {
        private Activity _activity;
        public static readonly ActivitySource ActivitySource = new ActivitySource("my.tracer");

        public TraceLogger(string actionName)
        {
            _activity = ActivitySource.StartActivity(actionName);
        }

        public void Dispose()
        {
            _activity?.Dispose();
        }

        public static void InitOpenTelemetry(string serviceName, Func<TracerProviderBuilder, TracerProviderBuilder> custom = null)
        {
            var sdk = Sdk.CreateTracerProviderBuilder()
                    .SetResourceBuilder(ResourceBuilder.CreateDefault().AddService(serviceName))
                    .AddSource("my.tracer")
                    .AddAspNetInstrumentation();

            if (custom != null)
            {
                sdk = custom(sdk);
            }

            sdk.AddJaegerExporter(options =>
            {
                options.AgentHost = "172.20.19.68";
                options.AgentPort = "31392";
            }).Build();
        }
    }
}

TraceLogger.InitOpenTelemetry("my-agent");



internal void Dispatch(string message)
{
    using (new TraceLogger("Msg_Dispatch"))
    {
        AddToTransactionalQueue(queue, message);
    }
}