Added wildcard support for meter sources.

src/OpenTelemetry/Metrics/MeterProviderSdk.cs

@@ -19,6 +19,7 @@
 using System.Diagnostics;
 using System.Diagnostics.Metrics;
 using System.Linq;
+using System.Text.RegularExpressions;
 using OpenTelemetry.Internal;
 using OpenTelemetry.Resources;
 
@@ -87,19 +88,49 @@ internal MeterProviderSdk(
             }
 
             // Setup Listener
-            var meterSourcesToSubscribe = new Dictionary<string, bool>(StringComparer.OrdinalIgnoreCase);
-            foreach (var name in meterSources)
+            var meterSourcesToSubscribe = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
+            var wildcardMode = false;
+            Regex regex = null;
+            if (meterSources.Any())
             {
-                meterSourcesToSubscribe[name] = true;
+                foreach (var meterSource in meterSources)
+                {
+                    if (meterSource.Contains('*'))
+                    {
+                        wildcardMode = true;
+                        regex = GetWildcardRegex(meterSources);
+                        break;
+                    }
+                }
+
+                if (!wildcardMode)
+                {
+                    foreach (var meterSource in meterSources)
+                    {
+                        meterSourcesToSubscribe.Add(meterSource);
+                    }
+                }
             }
 
+            Func<Instrument, bool> shouldListenTo = instrument =>
+            {
+                if (wildcardMode)
+                {
+                    return regex.IsMatch(instrument.Meter.Name);
+                }
+                else
+                {
+                    return meterSourcesToSubscribe.Contains(instrument.Meter.Name);
+                }
+            };
+
             this.listener = new MeterListener();
             var viewConfigCount = this.viewConfigs.Count;
             if (viewConfigCount > 0)
             {
                 this.listener.InstrumentPublished = (instrument, listener) =>
                 {
-                    if (meterSourcesToSubscribe.ContainsKey(instrument.Meter.Name))
+                    if (shouldListenTo(instrument))
                     {
                         // Creating list with initial capacity as the maximum
                         // possible size, to avoid any array resize/copy internally.
@@ -197,7 +228,7 @@ internal MeterProviderSdk(
             {
                 this.listener.InstrumentPublished = (instrument, listener) =>
                 {
-                    if (meterSourcesToSubscribe.ContainsKey(instrument.Meter.Name))
+                    if (shouldListenTo(instrument))
                     {
                         var metricName = instrument.Name;
                         Metric metric = null;
@@ -243,6 +274,12 @@ internal MeterProviderSdk(
 
             this.listener.MeasurementsCompleted = (instrument, state) => this.MeasurementsCompleted(instrument, state);
             this.listener.Start();
+
+            static Regex GetWildcardRegex(IEnumerable<string> collection)
+            {
+                var pattern = '^' + string.Join("|", from name in collection select "(?:" + Regex.Escape(name).Replace("\\*", ".*") + ')') + '$';
+                return new Regex(pattern, RegexOptions.Compiled | RegexOptions.IgnoreCase);
+            }
         }
 
         internal Resource Resource { get; }

test/OpenTelemetry.Tests/Metrics/MetricAPITest.cs

@@ -165,6 +165,34 @@ void ProcessExport(Batch<Metric> batch)
             Assert.Equal(1, metricCount);
         }
 
+        [Fact]
+        public void MeterSourcesWildCardSupportTest()
+        {
+            var meterSources = new[] { "AbcCompany.XyzProduct.ComponentA", "AbcCompany.XyzProduct.ComponentB", "SomeCompany.SomeProduct.SomeComponent" };
+            using var meter1 = new Meter(meterSources[0]);
+            using var meter2 = new Meter(meterSources[1]);
+            using var meter3 = new Meter(meterSources[2]);
+
+            var exportedItems = new List<Metric>();
+            using var meterProvider = Sdk.CreateMeterProviderBuilder()
+                .AddMeter("AbcCompany.XyzProduct.*")
+                .AddInMemoryExporter(exportedItems)
+                .AddView("name1", "renamed")
+                .Build();
+
+            var measurement = new Measurement<int>(100, new("name", "apple"), new("color", "red"));
+            meter1.CreateObservableGauge("myGauge1", () => measurement);
+            meter2.CreateObservableGauge("myGauge2", () => measurement);
+            meter3.CreateObservableGauge("myGauge3", () => measurement);
+
+            meterProvider.ForceFlush(MaxTimeToAllowForFlush);
+            Assert.Equal("myGauge1", exportedItems[0].Name);
+            Assert.Equal("myGauge2", exportedItems[1].Name);
+
+            // the third element "SomeCompany.SomeProduct.SomeComponent" will not be subscribed.
+            Assert.True(exportedItems.Count == 2);
+        }
+
         [Theory]
         [InlineData(true)]
         [InlineData(false)]