nsq

package

v0.10.0 Latest Latest Go to latest Published: Jan 9, 2016 License: MIT Imports: 4 Imported by: 0

Details

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

This section is empty.

This section is empty.

This section is empty.

type NSQ struct {
	Server string
	Topic  string
	// contains filtered or unexported fields
}

func (n *NSQ) Close() error

func (n *NSQ) Connect() error

func (n *NSQ) Description() string

func (n *NSQ) SampleConfig() string

func (n *NSQ) Write(points []*client.Point) error