internal void ReportQueueMetrics()

in src/Core/Exporters/Concrete/YarnResourceManagerExporter.cs [47:87]


        internal void ReportQueueMetrics(Queue queue, Dictionary<string, string> labels)
        {
            // Constructing labels
            var localLabels = new Dictionary<string, string>()
            {
                { "QueueName", queue.Name },
            };
            localLabels.TryAdd(labels);

            PrometheusUtils.ReportGauge(Collectors, "Queue_AMResourceLimitMB", queue.AMResourceLimitMB, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AMResourceLimitVCores", queue.AMResourceLimitVCores, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_ActiveApplications", queue.ActiveApplications, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_ActiveUsers", queue.ActiveUsers, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AggregateContainersAllocated", queue.AggregateContainersAllocated, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AggregateContainersReleased", queue.AggregateContainersReleased, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AllocatedContainers", queue.AllocatedContainers, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AllocatedMB", queue.AllocatedMB, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AllocatedVCores", queue.AllocatedVCores, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppAttemptFirstContainerAllocationDelayAvgTime", queue.AppAttemptFirstContainerAllocationDelayAvgTime, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppAttemptFirstContainerAllocationDelayNumOps", queue.AppAttemptFirstContainerAllocationDelayNumOps, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppsCompleted", queue.AppsCompleted, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppsFailed", queue.AppsFailed, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppsKilled", queue.AppsKilled, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppsPending", queue.AppsPending, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppsRunning", queue.AppsRunning, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AppsSubmitted", queue.AppsSubmitted, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AvailableMB", queue.AvailableMB, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_AvailableVCores", queue.AvailableVCores, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_PendingContainers", queue.PendingContainers, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_PendingMB", queue.PendingMB, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_PendingVCores", queue.PendingVCores, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_ReservedContainers", queue.ReservedContainers, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_ReservedMB", queue.ReservedMB, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_ReservedVCores", queue.ReservedVCores, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_UsedAMResourceMB", queue.UsedAMResourceMB, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_UsedAMResourceVCores", queue.UsedAMResourceVCores, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_Running0", queue.Running0, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_Running1440", queue.Running1440, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_Running300", queue.Running300, localLabels);
            PrometheusUtils.ReportGauge(Collectors, "Queue_Running60", queue.Running60, localLabels);
        }