From 2c7662e0833a89bdb6f678ac63371a03b4949fd9 Mon Sep 17 00:00:00 2001
From: Brandon H <hurlburb@microsoft.com>
Date: Tue, 26 Mar 2019 14:54:06 -0700
Subject: [PATCH] Adding **configuration** support for
 <metric>.scraping.interval

Fixes #258
---
 .../Model/Metrics/MetricDefinition.cs              |  9 ++++++++-
 .../Serialization/Core/MetricDeserializer.cs       | 14 +++++++++++++-
 2 files changed, 21 insertions(+), 2 deletions(-)

diff --git a/src/Promitor.Core.Scraping/Configuration/Model/Metrics/MetricDefinition.cs b/src/Promitor.Core.Scraping/Configuration/Model/Metrics/MetricDefinition.cs
index 0690b0e64..59be4d97f 100644
--- a/src/Promitor.Core.Scraping/Configuration/Model/Metrics/MetricDefinition.cs
+++ b/src/Promitor.Core.Scraping/Configuration/Model/Metrics/MetricDefinition.cs
@@ -1,4 +1,6 @@
-namespace Promitor.Core.Scraping.Configuration.Model.Metrics
+using System;
+
+namespace Promitor.Core.Scraping.Configuration.Model.Metrics
 {
     public abstract class MetricDefinition
     {
@@ -21,5 +23,10 @@ public abstract class MetricDefinition
         ///     Type of resource that is configured
         /// </summary>
         public abstract ResourceType ResourceType { get; }
+
+        /// <summary>
+        /// Gets or sets the scraping interval.
+        /// </summary>
+        public TimeSpan? ScrapingInterval { get; set; }
     }
 }
diff --git a/src/Promitor.Core.Scraping/Configuration/Serialization/Core/MetricDeserializer.cs b/src/Promitor.Core.Scraping/Configuration/Serialization/Core/MetricDeserializer.cs
index 16a520895..317347a4a 100644
--- a/src/Promitor.Core.Scraping/Configuration/Serialization/Core/MetricDeserializer.cs
+++ b/src/Promitor.Core.Scraping/Configuration/Serialization/Core/MetricDeserializer.cs
@@ -1,4 +1,5 @@
-using GuardNet;
+using System;
+using GuardNet;
 using Microsoft.Extensions.Logging;
 using Promitor.Core.Scraping.Configuration.Model.Metrics;
 using YamlDotNet.RepresentationModel;
@@ -38,6 +39,17 @@ protected virtual TMetricDefinition DeserializeMetricDefinition<TMetricDefinitio
                 AzureMetricConfiguration = azureMetricConfiguration
             };
 
+            if (metricNode.Children.ContainsKey(@"scraping"))
+            {
+                var scrapingNode = (YamlMappingNode)metricNode.Children[new YamlScalarNode(@"scraping")];
+                var scrapingIntervalNode = scrapingNode?.Children[new YamlScalarNode(@"interval")];
+
+                if (scrapingIntervalNode != null)
+                {
+                    metricDefinition.ScrapingInterval = TimeSpan.Parse(scrapingIntervalNode.ToString());
+                }
+            }
+
             return metricDefinition;
         }
     }