1
0
Эх сурвалжийг харах

More influx specific code

Nick Babcock 7 жил өмнө
parent
commit
d55c9ace76

+ 2 - 7
OhmGraphite/GraphiteConfig.cs

@@ -1,13 +1,8 @@
-using System;
-using System.Collections.Generic;
-using System.Configuration;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
+using System.Configuration;
 
 namespace OhmGraphite
 {
-    class GraphiteConfig
+    public class GraphiteConfig
     {
         public GraphiteConfig(string host, int port, bool tags)
         {

+ 1 - 1
OhmGraphite/IWriteMetrics.cs

@@ -3,7 +3,7 @@ using System.Collections.Generic;
 
 namespace OhmGraphite
 {
-    interface IWriteMetrics
+    public interface IWriteMetrics
     {
         void ReportMetrics(DateTime reportTime, IEnumerable<ReportedValue> sensors);
     }

+ 5 - 9
OhmGraphite/InfluxConfig.cs

@@ -1,20 +1,16 @@
 using System;
-using System.Collections.Generic;
 using System.Configuration;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace OhmGraphite
 {
-    class InfluxConfig
+    public class InfluxConfig
     {
         public InfluxConfig(Uri address, string db, string user, string password)
         {
-            this.Address = address;
-            this.Db = db;
-            this.User = user;
-            this.Password = password;
+            Address = address;
+            Db = db;
+            User = user;
+            Password = password;
         }
 
         public Uri Address { get; }

+ 1 - 1
OhmGraphite/InfluxWriter.cs

@@ -25,7 +25,7 @@ namespace OhmGraphite
         public void ReportMetrics(DateTime reportTime, IEnumerable<ReportedValue> sensors)
         {
             var payload = new LineProtocolPayload();
-            var client = new LineProtocolClient(_uri, _db, _user, _password);
+            var client = new LineProtocolClient(_config.Address, _config.Db, _config.User, _config.Password);
             var writer = new LineProtocolWriter(Precision.Seconds);
             foreach (var point in sensors.Select(x => NewMethod(reportTime, x)))
             {

+ 2 - 2
OhmGraphite/MetricConfig.cs

@@ -26,8 +26,8 @@ namespace OhmGraphite
             var interval = TimeSpan.FromSeconds(seconds);
 
             var type = ConfigurationManager.AppSettings["type"] ?? "graphite";
-            var gconfig = null;
-            var iconfig = null;
+            GraphiteConfig gconfig = null;
+            InfluxConfig iconfig = null;
 
             switch (type.ToLowerInvariant())
             {

+ 1 - 1
OhmGraphite/Program.cs

@@ -19,7 +19,7 @@ namespace OhmGraphite
                     // to poll the hardware
                     var config = Logger.LogFunction("parse config", MetricConfig.ParseAppSettings);
                     double seconds = config.Interval.TotalSeconds;
-                    IWriteMetrics writer = null;
+                    IWriteMetrics writer;
                     if (config.Graphite != null)
                     {
                         Logger.Info($"Graphite host: {config.Graphite.Host} port: {config.Graphite.Port} interval: {seconds} tags: {config.Graphite.Tags}");