4db667573a
newJsonParser function is now unexported, must use NewParser(config)
2018-06-28 15:35:20 -07:00
c50bfc2c71
edit unittests for JSON parser
2018-06-27 16:09:14 -07:00
daddd8bbac
Use nats-io/go-nats instead of nats-io/nats in tests
2018-06-11 16:13:59 -07:00
1c0f63a90d
Add new line protocol parser and serializer, influxdb output ( #3924 )
2018-03-27 17:30:51 -07:00
1402c158b7
remove sleep from tests ( #2555 )
2017-03-24 12:03:36 -07:00
e5c7a71d8e
Fix unit tests for new metric implementation
2016-12-01 18:17:02 +00:00
2150510bd4
nats_consumer: buffer incoming messages
...
fixes #1956
2016-10-27 13:39:27 +01:00
ee468be696
Flush based on buffer size rather than time
...
this includes:
- Add Accumulator to the Start() function of service inputs
- For message consumer plugins, use the Accumulator to constantly add
metrics and make Gather a dummy function
- rework unit tests to match this new behavior.
- make "flush_buffer_when_full" a config option that defaults to true
closes #666
2016-02-16 22:25:22 -07:00
6c353e8b8f
Change point_buffer to metric_buffer to conform will changes in https://github.com/influxdata/telegraf/pull/676
...
closes #680
2016-02-12 10:01:56 -07:00
512d9822f0
Add NATS consumer input plugin.
2016-02-12 09:58:32 -07:00
Max U
Daniel Nelson
Daniel Nelson
Patrick Hemmer
Cameron Sparr
Dragostin Yanev (netixen)