Cameron Sparr
e02973b6f4
Go fmt kinesis output test file
2015-12-11 11:45:07 -07:00
James Lamb
b91eab6737
add amazon kinesis as an output plugin
...
closes #428
2015-12-11 11:29:03 -07:00
Cameron Sparr
2be7fc072f
Don't use panic-happy prometheus client With() function
...
Deals with part of #405 , although it doesn't deal with the underlying
label error that is occuring.
2015-12-01 10:21:36 -07:00
Cameron Sparr
ca222a14de
Make Prometheus output tests skipped in short mode.
...
Because they do some networking.
Fixes #385
2015-12-01 09:45:25 -07:00
Cameron Sparr
970bfce997
Fix kafka plugin and rename to kafka_consumer
...
fixes #371
2015-11-19 13:41:58 -07:00
Cameron Sparr
a3feddd8ed
Riemann output: remove some of the object referencing/dereferencing
...
closes #378
closes #379
2015-11-18 15:34:05 -07:00
Jeffrey Allen
0823eed546
Add riemann output
...
Closes #34
2015-11-18 13:56:22 -07:00
gunnaraasen
03a6f28d55
Use 'CREATE DATABASE IF NOT EXISTS' syntax
...
closes #376
2015-11-18 00:41:25 -07:00
Cameron Sparr
a6ae597dfc
MQTT output unit tests w/ docker container
2015-11-13 13:42:06 -07:00
Cameron Sparr
0f036d6bec
InfluxDB output: add tests and a README
2015-11-13 10:42:35 -07:00
Cameron Sparr
10a20e208a
Godep update and dependency resolution
2015-11-12 15:20:01 -07:00
Cameron Sparr
e10394ba3b
Use the UDP client for writing to InfluxDB
2015-11-12 14:52:35 -07:00
Cameron Sparr
352ccde52b
Fix new error return of client.NewPoint
2015-11-11 15:38:22 -07:00
Cameron Sparr
acf9c1141a
Change duration -> internal and implement private gopsutil methods
2015-11-11 15:38:22 -07:00
martinrusev
1accab02ed
Amon output
...
closes #350
2015-11-09 10:44:28 -07:00
Eugene Dementiev
688ffd024b
[amqp output] Add ability to specify influxdb database
...
and retention policy, as well as precision as amqp headers
closes #333
2015-11-02 11:12:09 -07:00
Cameron Sparr
d2fb065d0d
Prometheus client test refactor
...
closes #318
2015-10-28 16:25:15 -06:00
Tait Clarridge
4449f7f2fb
Add prometheus_client service output module, update prometheus client
...
- Adds a client implementation using the prometheus go_client library
that exposes metrics.
- Adds a new type of output "ServiceOutput" which follows inline with
the "ServicePlugin", adding a Stop and Start method for the service
This change also requires the newer prometheus/client_golang code, so
the prometheus plugin needed to be changed.
Added the following to Godep:
- bitbucket.org/ww/goautoneg (in github.com/common/expfmt/encode.go)
- prometheus/common/expfmt (in plugins/prometheus.go)
- github.com/prometheus/common/model (in plugins/prometheus.go)
- github.com/prometheus/procfs (in github.com/client_golang/prometheus)
- github.com/beorn7/perks/quantile (in github.com/client_golang/prometheus)
X-Github-Meta: closes #306
2015-10-28 15:28:39 -06:00
Jonathan Cross
e622bd5e7f
fixing test for NoError
...
closes #325
2015-10-27 15:44:22 -06:00
Jonathan Cross
0d31f40e16
use index 0 of server array for nsq test
2015-10-27 15:44:22 -06:00
Jonathan Cross
e13500fc4f
updated for new output Write function
...
removed HTTP listener port in docker compose. Not being used by plugin.
2015-10-27 15:44:22 -06:00
Jonathan Cross
2a76942a74
NSQ Output plugin
...
NSQ output plugin, following the NSQ methodology output is a producer
to one instance of NSQD. The go library does not accept array values be
default for a Producer. Additionally service discovery is generally
done as a consumer.
Follows same methodology as Kafka Output without the tag reference.
2015-10-27 15:44:22 -06:00
JP
7d15061984
add librato output plugin, update datadog plugin to skip non-number metrics
...
closes #322
2015-10-26 13:29:53 -06:00
JP
869483617b
add host to metric, replace '_' with '.'
...
closes #312
2015-10-23 18:25:26 -06:00
palkan
de7ad9dfbc
Replace opentsb docker image with the official one
...
closes #314
2015-10-23 17:34:12 -06:00
Cameron Sparr
c8852339c9
Do not fail Connect() in influxdb output when db creation fails
...
Fixes #304
2015-10-22 11:14:10 -06:00
Cameron Sparr
a1067fa4ae
Normalize collection interval to nearest interval
...
closes #301
2015-10-21 17:31:27 -06:00
gotyaoi
0299a17da1
Moving the Duration wrapper to it's own package to break import loops.
2015-10-21 12:00:21 -07:00
Eugene Dementiev
553208a960
Combine BatchPoints with the same RoutingTag to one message in amqp output
...
closes #287
2015-10-21 11:53:08 -06:00
Cameron Sparr
c26ce9c4fe
Utilizing new client and overhauling Accumulator interface
...
Fixes #280
Fixes #281
Fixes #289
2015-10-20 13:53:58 -06:00
Cameron Sparr
4e5ed9d3b9
Change config file indentation to 2 spaces
2015-10-15 15:53:29 -06:00
Cameron Sparr
52be516fa3
wget and install go1.5.1 on machine
2015-10-14 17:54:00 -06:00
Cameron Sparr
eb2a4dc724
Statsd listener plugin
...
implement gauges, sets, counters
2015-10-14 17:54:00 -06:00
Shirou WAKAYAMA
63e9a4ae68
Fix godeps for MQTT output and remove hostname setting
...
Closes #241
2015-10-05 10:56:43 -06:00
Shirou WAKAYAMA
7e96a9afda
Change MQTT output topic format to split plugin name.
2015-10-05 10:43:46 +09:00
Shirou WAKAYAMA
6f4a3816a5
Add MQTT output.
2015-10-04 22:52:29 +09:00
Eugene Dementiev
c6283d1b5a
AMQP auto reconnect feature
...
Closes #207
2015-09-24 10:30:00 -07:00
Eugene Dementiev
74b3309225
Add timestamps to points in Kafka/AMQP outputs
2015-09-23 15:31:37 -07:00
Cameron Sparr
d979ee5573
AMQP routing tag doc & add routing tag for Kafka
...
closes #200
2015-09-16 12:10:26 -07:00
Eugene Dementiev
5d280e4d25
AMQP output plugin typo fixes and added README and RoutingTag
2015-09-16 10:59:29 -07:00
Eugene Dementiev
f00d43aa09
Added amqp output
2015-09-16 10:58:38 -07:00
Roman Plessl
9a0c0886ce
added more UNIT test cases for covering all parts of the code
...
added debug statement for debugging OpenTSDB communication
Closes #182
2015-09-14 18:43:56 -07:00
Roman Plessl
fc41cc9878
added prefix settings of the module and rearrange go test code
2015-09-14 18:41:43 -07:00
Roman Plessl
08b220a1fb
added docker image unit test with OpenTSDB
2015-09-14 18:41:43 -07:00
Roman Plessl
7e3beaf822
fix spaces with gofmt
2015-09-14 18:41:43 -07:00
Roman Plessl
d2150efc19
added readme as suggested / whished in #177
2015-09-14 18:41:43 -07:00
Roman Plessl
2bf096cfc7
adds opentsdb telnet output plugin
2015-09-14 18:41:42 -07:00
Roman Plessl
cb887dee81
change/fix expected test result
2015-09-14 18:41:42 -07:00
Roman Plessl
2ee7d5eeb6
code improvements after running tests / compile step
2015-09-14 18:41:42 -07:00
Cameron Sparr
3c7c8926fb
Support InfluxDB clusters
...
Closes #143
2015-09-09 17:57:17 -06:00