Merge pull request #2 from wasadus/customGraphitePath

for the case of multiple consumer types from same .exe

Author: Anton92nd

Cassandra.DistributedTaskQueue/Profiling/GraphiteRtqProfiler.cs

@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Diagnostics;
 using System.Linq;
 using System.Net;
@@ -18,26 +18,27 @@ public class GraphiteRtqProfiler : IRtqProfiler
         public GraphiteRtqProfiler([NotNull] IStatsDClient statsDClient,
                                    [NotNull] IGraphiteClient graphiteClient,
                                    [NotNull] string statsDKeyNamePrefix,
-                                   [NotNull] string consumerGraphitePathPrefix)
+                                   [NotNull] string consumerGraphitePathPrefix,
+                                   [CanBeNull] string consumerName = null)
         {
             if (string.IsNullOrEmpty(statsDKeyNamePrefix))
                 throw new InvalidOperationException("statsDKeyNamePrefix is empty");
             if (string.IsNullOrEmpty(consumerGraphitePathPrefix))
                 throw new InvalidOperationException("consumerGraphitePathPrefix is empty");
             this.statsDClient = statsDClient.WithScopes($"{statsDKeyNamePrefix}.{Dns.GetHostName()}", $"{statsDKeyNamePrefix}.Total");
             this.graphiteClient = graphiteClient;
-            this.consumerGraphitePathPrefix = FormatGraphitePathPrefix(consumerGraphitePathPrefix);
+            this.consumerGraphitePathPrefix = FormatGraphitePathPrefix(consumerGraphitePathPrefix, consumerName);
         }
 
         [NotNull]
-        private static string FormatGraphitePathPrefix([NotNull] string graphitePathPrefix)
+        private static string FormatGraphitePathPrefix([NotNull] string graphitePathPrefix, [CanBeNull] string consumerName)
         {
             var processName = Process.GetCurrentProcess()
                                      .ProcessName
                                      .Replace(".exe", string.Empty)
                                      .Split(new[] {'.'}, StringSplitOptions.RemoveEmptyEntries)
                                      .Last();
-            return $"{graphitePathPrefix}.{Dns.GetHostName()}.{processName}";
+            return $"{graphitePathPrefix}.{Dns.GetHostName()}.{consumerName ?? processName}";
         }
 
         public void ProcessTaskCreation([NotNull] TaskMetaInformation meta)