samples/Prometheus/ReverseProxy.Metrics-Prometheus.Sample/PrometheusOutboundHttpMetrics.cs - main - aprogrammer/reverse-proxy-ms-yarp

samples/Prometheus/ReverseProxy.Metrics-Prometheus.Sample/PrometheusOutboundHttpMetrics.cs

69 строк3 KB

asafdl

chore: fix prometheus sample metric typos in description (#2308)

14 ноя 2023, 19:56

14 ноя 2023, 19:5601ed48e


// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

using System;
using Yarp.Telemetry.Consumption;
using Prometheus;

namespace Yarp.Sample
{
    /// <summary>
    /// Collects outbound http metrics and exposes them using prometheus-net
    /// </summary>
    public sealed class PrometheusOutboundHttpMetrics : IMetricsConsumer<HttpMetrics>
    {
        private static readonly double CUBE_ROOT_10 = Math.Pow(10, (1.0 / 3));

        private static readonly Counter _outboundRequestsStarted = Metrics.CreateCounter(
            "yarp_outbound_http_requests_started",
            "Number of outbound requests initiated by the proxy"
            );

        private static readonly Counter _outboundRequestsFailed = Metrics.CreateCounter(
            "yarp_outbound_http_requests_failed",
            "Number of outbound requests failed"
            );

        private static readonly Gauge _outboundCurrentRequests =Metrics.CreateGauge(
            "yarp_outbound_http_current_requests",
            "Number of active outbound requests that have started but not yet completed or failed"
            );

        private static readonly Gauge _outboundCurrentHttp11Connections = Metrics.CreateGauge(
            "yarp_outbound_http11_connections",
            "Number of currently open HTTP 1.1 connections"
            );

        private static readonly Gauge _outboundCurrentHttp20Connections= Metrics.CreateGauge(
            "yarp_outbound_http20_connections",
            "Number of active proxy requests that have started but not yet completed or failed"
            );

        private static readonly Histogram _outboundHttp11RequestQueueDuration= Metrics.CreateHistogram(
            "yarp_outbound_http11_request_queue_duration",
            "Average time spent on queue for HTTP 1.1 requests that hit the MaxConnectionsPerServer limit in the last metrics interval",
            new HistogramConfiguration
            {
                Buckets = Histogram.ExponentialBuckets(10, CUBE_ROOT_10, 10)
            });

        private static readonly Histogram _outboundHttp20RequestQueueDuration = Metrics.CreateHistogram(
            "yarp_outbound_http20_request_queue_duration",
            "Average time spent on queue for HTTP 2.0 requests that hit the MAX_CONCURRENT_STREAMS limit on the connection in the last metrics interval",
            new HistogramConfiguration
            {
                Buckets = Histogram.ExponentialBuckets(10, CUBE_ROOT_10, 10)
            });

        public void OnMetrics(HttpMetrics previous, HttpMetrics current)
        {
            _outboundRequestsStarted.IncTo(current.RequestsStarted);
            _outboundRequestsFailed.IncTo(current.RequestsFailed);
            _outboundCurrentRequests.Set(current.CurrentRequests);
            _outboundCurrentHttp11Connections.Set(current.CurrentHttp11Connections);
            _outboundCurrentHttp20Connections.Set(current.CurrentHttp20Connections);
            _outboundHttp11RequestQueueDuration.Observe(current.Http11RequestsQueueDuration.TotalMilliseconds);
            _outboundHttp20RequestQueueDuration.Observe(current.Http20RequestsQueueDuration.TotalMilliseconds);
        }
    }
}