nsq

type InputConfig struct {
	config.InputConfig
	NSQ      string `json:"nsq" yaml:"nsq"`                   // NSQd to connect to
	Lookupd  string `json:"lookupd" yaml:"lookupd"`           // lookupd to connect to, can be a NSQd or lookupd
	Topic    string `json:"topic" yaml:"topic"`               // topic to listen from
	Channel  string `json:"channel" yaml:"channel"`           // channel to subscribe to
	InFlight uint   `json:"max_inflight" yaml:"max_inflight"` // max number of messages inflight
	// contains filtered or unexported fields
}