From d0ec1e5c112a627c3a11bdb0505efd976b768870 Mon Sep 17 00:00:00 2001
From: Andrei Burd <bandrei@yotpo.com>
Date: Sun, 14 Feb 2016 21:12:21 +0200
Subject: [PATCH] Code formatted, Readme updated based on example

---
 plugins/inputs/raindrops/README.md         | 40 ++++++++++++++++++++--
 plugins/inputs/raindrops/raindrops.go      |  7 ++--
 plugins/inputs/raindrops/raindrops_test.go | 11 +++---
 3 files changed, 45 insertions(+), 13 deletions(-)

diff --git a/plugins/inputs/raindrops/README.md b/plugins/inputs/raindrops/README.md
index 8dc4e51a0..6a73a085b 100644
--- a/plugins/inputs/raindrops/README.md
+++ b/plugins/inputs/raindrops/README.md
@@ -1,15 +1,49 @@
 # Raindrops Input Plugin
 
 The [raindrops](http://raindrops.bogomips.org/) plugin reads from
-specified raindops middleware URI and adds stats to InfluxDB.
+specified raindops [middleware](http://raindrops.bogomips.org/Raindrops/Middleware.html) URI and adds stats to InfluxDB.
+
 ### Configuration:
 
 ```toml
 # Read raindrops stats
 [[inputs.raindrops]]
-  urls = ["http://localhost/_raindrops"]
+  urls = ["http://localhost:8080/_raindrops"]
 ```
 
+### Measurements & Fields:
+
+- raindrops
+    - calling (integer, count)
+    - writing (integer, count)
+- raindrops_listen
+    - active (integer, bytes)
+    - queued (integer, bytes)
+
 ### Tags:
 
-- Multiple listeners are tagged with IP:Port/Socket, ie `0.0.0.0:8080` or  `/tmp/unicorn`
+- Raindops calling/writing of all the workers:
+    - server
+    - port
+
+- raindrops_listen (ip:port):
+    - ip
+    - port
+
+- raindrops_listen (Unix Socket):
+    - socket
+
+### Example Output:
+
+```
+$ ./telegraf -config telegraf.conf -input-filter raindrops -test
+* Plugin: raindrops, Collection 1
+> raindrops,port=8080,server=localhost calling=0i,writing=0i 1455479896806238204
+> raindrops_listen,ip=0.0.0.0,port=8080 active=0i,queued=0i 1455479896806561938
+> raindrops_listen,ip=0.0.0.0,port=8081 active=1i,queued=0i 1455479896806605749
+> raindrops_listen,ip=127.0.0.1,port=8082 active=0i,queued=0i 1455479896806646315
+> raindrops_listen,ip=0.0.0.0,port=8083 active=0i,queued=0i 1455479896806683252
+> raindrops_listen,ip=0.0.0.0,port=8084 active=0i,queued=0i 1455479896806712025
+> raindrops_listen,ip=0.0.0.0,port=3000 active=0i,queued=0i 1455479896806779197
+> raindrops_listen,socket=/tmp/listen.me active=0i,queued=0i 1455479896806813907
+```
diff --git a/plugins/inputs/raindrops/raindrops.go b/plugins/inputs/raindrops/raindrops.go
index 00c711cb2..572422f59 100644
--- a/plugins/inputs/raindrops/raindrops.go
+++ b/plugins/inputs/raindrops/raindrops.go
@@ -22,7 +22,7 @@ type Raindrops struct {
 
 var sampleConfig = `
   ### An array of raindrops middleware URI to gather stats.
-  urls = ["http://localhost/_raindrops"]
+  urls = ["http://localhost:8080/_raindrops"]
 `
 
 func (r *Raindrops) SampleConfig() string {
@@ -119,7 +119,7 @@ func (r *Raindrops) gatherUrl(addr *url.URL, acc telegraf.Accumulator) error {
 			iterate = false
 			break
 		}
-		if strings.Compare(active_line_str, "\n") == 0{
+		if strings.Compare(active_line_str, "\n") == 0 {
 			break
 		}
 		queued_line_str, queued_err = buf.ReadString('\n')
@@ -153,8 +153,7 @@ func (r *Raindrops) gatherUrl(addr *url.URL, acc telegraf.Accumulator) error {
 				"socket": listen_name,
 			}
 		}
-		fmt.Println("raindropssock", lis, tags)
-		acc.AddFields("raindropssock", lis, tags)
+		acc.AddFields("raindrops_listen", lis, tags)
 	}
 	return nil
 }
diff --git a/plugins/inputs/raindrops/raindrops_test.go b/plugins/inputs/raindrops/raindrops_test.go
index d4767b88a..0dee9b1cc 100644
--- a/plugins/inputs/raindrops/raindrops_test.go
+++ b/plugins/inputs/raindrops/raindrops_test.go
@@ -72,8 +72,8 @@ func TestRaindropsGeneratesMetrics(t *testing.T) {
 	require.NoError(t, err)
 
 	fields := map[string]interface{}{
-		"calling":   uint64(100),
-		"writing":  uint64(200),
+		"calling": uint64(100),
+		"writing": uint64(200),
 	}
 	addr, err := url.Parse(ts.URL)
 	if err != nil {
@@ -97,12 +97,11 @@ func TestRaindropsGeneratesMetrics(t *testing.T) {
 
 	tags = map[string]string{
 		"port": "8081",
-		"ip": "0.0.0.0",
+		"ip":   "0.0.0.0",
 	}
-	fields = map[string]interface {} {
+	fields = map[string]interface{}{
 		"active": uint64(3),
 		"queued": uint64(4),
 	}
-	fmt.Println("raindropssock_test", fields, tags)
-	acc.AssertContainsTaggedFields(t, "raindropssock", fields, tags)
+	acc.AssertContainsTaggedFields(t, "raindrops_listen", fields, tags)
 }