Update all the core deserializers

I've updated all the deserializers in the core namespace to use the new mapping syntax. Part of tomkerkhove#1092
adamconnelly · Jun 16, 2020 · 53394c9 · 53394c9
1 parent eae2747
commit 53394c9
Show file tree

Hide file tree

Showing 9 changed files with 36 additions and 29 deletions.
diff --git a/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/AggregationDeserializer.cs b/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/AggregationDeserializer.cs
@@ -10,7 +10,8 @@ public class AggregationDeserializer : Deserializer<AggregationV1>
 
         public AggregationDeserializer(ILogger<AggregationDeserializer> logger) : base(logger)
         {
-            MapOptional(aggregation => aggregation.Interval, defaultAggregationInterval);
+            Map(aggregation => aggregation.Interval)
+                .WithDefault(defaultAggregationInterval);
         }
     }
 }
diff --git a/...Core.Scraping/Configuration/Serialization/v1/Core/AzureMetricConfigurationDeserializer.cs b/...Core.Scraping/Configuration/Serialization/v1/Core/AzureMetricConfigurationDeserializer.cs
@@ -8,9 +8,13 @@ public class AzureMetricConfigurationDeserializer : Deserializer<AzureMetricConf
         public AzureMetricConfigurationDeserializer(IDeserializer<MetricDimensionV1> dimensionDeserializer, IDeserializer<MetricAggregationV1> aggregationDeserializer, ILogger<AzureMetricConfigurationDeserializer> logger)
             : base(logger)
         {
-            MapRequired(config => config.MetricName);
-            MapOptional(config => config.Dimension, dimensionDeserializer);
-            MapRequired(config => config.Aggregation, aggregationDeserializer);
+            Map(config => config.MetricName)
+                .IsRequired();
+            Map(config => config.Dimension)
+                .MapUsingDeserializer(dimensionDeserializer);
+            Map(config => config.Aggregation)
+                .IsRequired()
+                .MapUsingDeserializer(aggregationDeserializer);
         }
     }
 }
diff --git a/....Core.Scraping/Configuration/Serialization/v1/Core/AzureResourceCollectionDeserializer.cs b/....Core.Scraping/Configuration/Serialization/v1/Core/AzureResourceCollectionDeserializer.cs
@@ -7,7 +7,8 @@ public class AzureResourceCollectionDeserializer : Deserializer<AzureResourceCol
     {
         public AzureResourceCollectionDeserializer(ILogger<AzureResourceCollectionDeserializer> logger) : base(logger)
         {
-            MapRequired(metadata => metadata.Name);
+            Map(metadata => metadata.Name)
+                .IsRequired();
         }
     }
 }
diff --git a/...omitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricAggregationDeserializer.cs b/...omitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricAggregationDeserializer.cs
@@ -7,8 +7,9 @@ public class MetricAggregationDeserializer : Deserializer<MetricAggregationV1>
     {
         public MetricAggregationDeserializer(ILogger<MetricAggregationDeserializer> logger) : base(logger)
         {
-            MapRequired(aggregation => aggregation.Type);
-            MapOptional(aggregation => aggregation.Interval);
+            Map(aggregation => aggregation.Type)
+                .IsRequired();
+            Map(aggregation => aggregation.Interval);
         }
     }
 }
diff --git a/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricDefaultsDeserializer.cs b/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricDefaultsDeserializer.cs
@@ -10,8 +10,11 @@ public MetricDefaultsDeserializer(
             IDeserializer<ScrapingV1> scrapingDeserializer,
             ILogger<MetricDefaultsDeserializer> logger) : base(logger)
         {
-            MapOptional(defaults => defaults.Aggregation, aggregationDeserializer);
-            MapRequired(defaults => defaults.Scraping, scrapingDeserializer);
+            Map(defaults => defaults.Aggregation)
+                .MapUsingDeserializer(aggregationDeserializer);
+            Map(defaults => defaults.Scraping)
+                .IsRequired()
+                .MapUsingDeserializer(scrapingDeserializer);
         }
     }
 }
diff --git a/...romitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricDefinitionDeserializer.cs b/...romitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricDefinitionDeserializer.cs
@@ -21,12 +21,18 @@ public MetricDefinitionDeserializer(IDeserializer<AzureMetricConfigurationV1> az
             _azureResourceCollectionDeserializer = azureResourceCollectionDeserializer;
             _azureResourceDeserializerFactory = azureResourceDeserializerFactory;
 
-            MapRequired(definition => definition.Name);
-            MapRequired(definition => definition.Description);
-            MapRequired(definition => definition.ResourceType);
-            MapRequired(definition => definition.AzureMetricConfiguration, azureMetricConfigurationDeserializer);
-            MapOptional(definition => definition.Labels);
-            MapOptional(definition => definition.Scraping, scrapingDeserializer);
+            Map(definition => definition.Name)
+                .IsRequired();
+            Map(definition => definition.Description)
+                .IsRequired();
+            Map(definition => definition.ResourceType)
+                .IsRequired();
+            Map(definition => definition.AzureMetricConfiguration)
+                .IsRequired()
+                .MapUsingDeserializer(azureMetricConfigurationDeserializer);
+            Map(definition => definition.Labels);
+            Map(definition => definition.Scraping)
+                .MapUsingDeserializer(scrapingDeserializer);
             IgnoreField(ResourceCollectionsTag);
             IgnoreField(ResourcesTag);
         }

diff --git a/...Promitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricDimensionDeserializer.cs b/...Promitor.Core.Scraping/Configuration/Serialization/v1/Core/MetricDimensionDeserializer.cs
@@ -1,24 +1,14 @@
 using Microsoft.Extensions.Logging;
 using Promitor.Core.Scraping.Configuration.Serialization.v1.Model;
-using YamlDotNet.RepresentationModel;
 
 namespace Promitor.Core.Scraping.Configuration.Serialization.v1.Core
 {
     public class MetricDimensionDeserializer : Deserializer<MetricDimensionV1>
     {
-        private const string NameTag = "name";
-
         public MetricDimensionDeserializer(ILogger<MetricDimensionDeserializer> logger)
             : base(logger)
         {
-        }
-
-        public override MetricDimensionV1 Deserialize(YamlMappingNode node, IErrorReporter errorReporter)
-        {
-            return new MetricDimensionV1
-            {
-                Name = node.GetString(NameTag),
-            };
+            Map(dimension => dimension.Name);
         }
     }
 }
diff --git a/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/ScrapingDeserializer.cs b/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/ScrapingDeserializer.cs
@@ -7,7 +7,8 @@ public class ScrapingDeserializer : Deserializer<ScrapingV1>
     {
         public ScrapingDeserializer(ILogger<ScrapingDeserializer> logger) : base(logger)
         {
-            MapRequired(scraping => scraping.Schedule);
+            Map(scraping => scraping.Schedule)
+                .IsRequired();
         }
     }
 }
diff --git a/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/SecretDeserializer.cs b/src/Promitor.Core.Scraping/Configuration/Serialization/v1/Core/SecretDeserializer.cs
@@ -8,8 +8,8 @@ public class SecretDeserializer : Deserializer<SecretV1>
     {
         public SecretDeserializer(ILogger<SecretDeserializer> logger) : base(logger)
         {
-            MapOptional(secret => secret.RawValue);
-            MapOptional(secret => secret.EnvironmentVariable);
+            Map(secret => secret.RawValue);
+            Map(secret => secret.EnvironmentVariable);
         }
 
         public override SecretV1 Deserialize(YamlMappingNode node, IErrorReporter errorReporter)