Versions in this module Expand all Collapse all v1 v1.2.0 Mar 24, 2017 Changes in this version + type NSQConsumer struct + Channel string + MaxInFlight int + Server string + Topic string + func (n *NSQConsumer) Description() string + func (n *NSQConsumer) Gather(acc telegraf.Accumulator) error + func (n *NSQConsumer) SampleConfig() string + func (n *NSQConsumer) SetParser(parser parsers.Parser) + func (n *NSQConsumer) Start(acc telegraf.Accumulator) error + func (n *NSQConsumer) Stop()
Go to main page