nsq

README

NSQ Output Plugin

This plugin writes to a specified NSQD instance, usually local to the producer. It requires a server name and a topic name.

Global configuration options

In addition to the plugin-specific configuration settings, plugins support additional global and plugin configuration settings. These settings are used to modify metrics, tags, and field or create aliases and configure ordering, etc. See the CONFIGURATION.md for more details.

Configuration

# Send telegraf measurements to NSQD
[[outputs.nsq]]
  ## Location of nsqd instance listening on TCP
  server = "localhost:4150"
  ## NSQ topic for producer messages
  topic = "telegraf"

  ## Data format to output.
  ## Each data format has its own unique set of configuration options, read
  ## more about them here:
  ## https://github.com/influxdata/telegraf/blob/master/docs/DATA_FORMATS_OUTPUT.md
  data_format = "influx"

Documentation

Index

• type NSQ
  • func (n *NSQ) Close() error
  • func (n *NSQ) Connect() error
  • func (*NSQ) SampleConfig() string
  • func (n *NSQ) SetSerializer(serializer serializers.Serializer)
  • func (n *NSQ) Write(metrics []telegraf.Metric) error

Types

type NSQ

type NSQ struct {
	Server string
	Topic  string
	Log    telegraf.Logger `toml:"-"`
	// contains filtered or unexported fields
}

func (*NSQ) Close

func (n *NSQ) Close() error

func (*NSQ) Connect

func (n *NSQ) Connect() error

func (*NSQ) SampleConfig

func (*NSQ) SampleConfig() string

func (*NSQ) SetSerializer

func (n *NSQ) SetSerializer(serializer serializers.Serializer)

func (*NSQ) Write

func (n *NSQ) Write(metrics []telegraf.Metric) error