cleanup

fullerite.conf

@@ -9,12 +9,12 @@
         "Diamond"
     ],
     "handlers": {
+        "Graphite": {},
         "SignalFx": {
             "authToken": "token",
             "endpoint": "http://somethingsomething.com/blah",
             "interval": "10.0"
-        },
-        "Graphite": {}
+        }
     },
     "prefix": "test.",
     "interval": 10,

src/fullerite/collectors.go

@@ -28,8 +28,8 @@ func readCollectorConfig(collector collector.Collector) {
 }
 
 func runCollector(collector collector.Collector) {
+	log.Info("Running ", collector)
 	for {
-		log.Info("Collecting from ", collector)
 		collector.Collect()
 		time.Sleep(time.Duration(collector.Interval()) * time.Second)
 	}

src/fullerite/handler/graphite.go

@@ -13,13 +13,17 @@ type Graphite struct {
 // NewGraphite returns a new Graphite handler.
 func NewGraphite() *Graphite {
 	g := new(Graphite)
-	g.name = "SignalFx"
+	g.name = "Graphite"
 	g.maxBufferSize = DefaultBufferSize
 	g.channel = make(chan metric.Metric)
-
 	return g
 }
 
+// Configure accepts the different configuration options
+func (g Graphite) Configure(conf *map[string]string) {
+	// TODO: implement
+}
+
 // Run sends metrics in the channel to the graphite server.
 func (g Graphite) Run() {
 	// TODO: check interval and queue size and metrics.

src/fullerite/handler/handler.go

@@ -35,6 +35,7 @@ type Handler interface {
 
 	// taken care of by the base
 	Name() string
+	String() string
 	Channel() chan metric.Metric
 
 	Interval() int
@@ -115,12 +116,7 @@ func (handler *BaseHandler) SetInterval(val int) {
 	handler.interval = val
 }
 
-// Configure : this takes a dictionary of values with which the handler can configure itself
-func (handler *BaseHandler) Configure(*map[string]string) {
-	// noop
-}
-
 // String returns the handler name in a printable format.
 func (handler *BaseHandler) String() string {
-	return handler.Name() + "Handler"
+	return handler.name + "Handler"
 }

src/fullerite/handler/signalfx.go

@@ -1,12 +1,14 @@
 package handler
 
 import (
-	"bytes"
 	"fullerite/metric"
-	"github.com/golang/protobuf/proto"
+
+	"bytes"
 	"io/ioutil"
 	"net/http"
 	"time"
+
+	"github.com/golang/protobuf/proto"
 )
 
 // SignalFx Handler
@@ -25,7 +27,7 @@ func NewSignalFx() *SignalFx {
 	return s
 }
 
-// Configure : accepts the different configuration options for the signalfx handler
+// Configure accepts the different configuration options for the signalfx handler
 func (s *SignalFx) Configure(config *map[string]string) {
 	asmap := *config
 	var exists bool
@@ -41,7 +43,6 @@ func (s *SignalFx) Configure(config *map[string]string) {
 
 // Run send metrics in the channel to SignalFx.
 func (s *SignalFx) Run() {
-	log.Info("Starting signalfx handler...")
 	datapoints := make([]*DataPoint, 0, s.maxBufferSize)
 
 	lastEmission := time.Now()

src/fullerite/handlers.go

@@ -7,9 +7,8 @@ import (
 
 func startHandlers(c Config) (handlers []handler.Handler) {
 	log.Info("Starting handlers...")
-
 	for name, config := range c.Handlers {
-		handler := buildHandler(name)
+		handler := handler.New(name)
 
 		// apply any global configs
 		handler.SetInterval(c.Interval)
@@ -21,16 +20,12 @@ func startHandlers(c Config) (handlers []handler.Handler) {
 
 		handlers = append(handlers, handler)
 
+		log.Info("Running ", handler)
 		go handler.Run()
 	}
 	return handlers
 }
 
-func buildHandler(name string) handler.Handler {
-	handler := handler.New(name)
-	return handler
-}
-
 func writeToHandlers(handlers []handler.Handler, metric metric.Metric) {
 	for _, handler := range handlers {
 		handler.Channel() <- metric