18 Commits

Author	SHA1	Message	Date
Paweł Żak	74a1acd814	Linter fixes - revive:unused-parameter, unparam, varcheck and unused (#8984) ... * Linter fixes - revive:unused-parameter and unparam * Linter fixes - revive:unused-parameter and unparam * Linter fixes - revive:unused-parameter and unparam * "nolint"'s removed * Fixes for "varcheck" and "unused" added. * Fixes for "varcheck" and "unused" added. * Fixes for "varcheck" and "unused" added. * Fixes for "varcheck" and "unused" added. * Fixes for "varcheck" and "unused" added. * Fixes for "varcheck" and "unused" added. * Fixes for "varcheck" and "unused" added. Co-authored-by: Pawel Zak <Pawel Zak>	2021-03-22 12:21:36 -05:00
Helen Weller	f3a208ee28	Fix reconnection issues mqtt (#8821)	2021-02-11 11:45:13 -05:00
Steven Soroka	e39208d60a	fix issue with mqtt concurrent map write (#8562)	2020-12-16 15:38:33 -05:00
Greg	817c9a69a9	Document and add support to input plugins for logging alias (#6357)	2019-09-23 15:39:50 -07:00
Daniel Nelson	92385a4630	Add topic_tag option to mqtt_consumer (#6266)	2019-08-19 19:05:22 -07:00
Daniel Nelson	5e06e56785	Fix persistent session in mqtt_consumer (#6236)	2019-08-14 17:05:34 -07:00
Greg	6f2e57ad64	Update paho.mqtt.golang (#6149)	2019-07-22 14:14:23 -07:00
Daniel Nelson	6e5c2f8bb6	Remove outputs blocking inputs when output is slow (#4938)	2018-11-05 13:34:28 -08:00
Daniel Nelson	152365ae06	Rework mqtt_consumer connect/reconnect (#4846)	2018-10-15 13:03:52 -07:00
maxunt	2729378b7f	Add name, time, path and string field options to JSON parser (#4351)	2018-08-22 19:26:48 -07:00
DanKans	5488f4b3ac	Fix MQTT input exits if Broker is not available on startup (#3202)	2017-09-11 12:24:51 -07:00
Patrick Hemmer	1402c158b7	remove sleep from tests (#2555)	2017-03-24 12:03:36 -07:00
Cameron Sparr	54cfbb5b87	metric: Fix negative number handling ... closes #2324	2017-02-01 10:07:31 +00:00
Cameron Sparr	e5c7a71d8e	Fix unit tests for new metric implementation	2016-12-01 18:17:02 +00:00
Cameron Sparr	62105bb353	Use github paho mqtt client instead of gerrit ... this might fix #921	2016-03-30 11:54:01 -06:00
Cameron Sparr	41534c73f0	mqtt_consumer: option to set persistent session and client ID ... closes #797	2016-03-07 14:34:42 +01:00
Cameron Sparr	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
Cameron Sparr	8d0f50a6fd	MQTT Consumer Input plugin	2016-02-12 11:13:32 -07:00