nsq

Documentation

Overview

Package nsq provides a Vice implementation for NSQ.

Index

• Constants
• type Transport
  • func New() *Transport
  • func (t *Transport) Done() chan struct{}
  • func (t *Transport) ErrChan() <-chan error
  • func (t *Transport) Receive(name string) <-chan []byte
  • func (t *Transport) Send(name string) chan<- []byte
  • func (t *Transport) Stop()

Constants

const DefaultTCPAddr = "localhost:4150"

DefaultTCPAddr is the default NSQ TCP address.

Types

type Transport

type Transport struct {

	// NewProducer is a func that creates an nsq.Producer.
	NewProducer func() (*nsq.Producer, error)

	// NewConsumer is a func that creates an nsq.Consumer.
	NewConsumer func(name string) (*nsq.Consumer, error)

	// ConnectConsumer is a func that connects the nsq.Consumer
	// to NSQ.
	ConnectConsumer func(consumer *nsq.Consumer) error
	// contains filtered or unexported fields
}

Transport is a vice.Transport for NSQ.

func New

func New() *Transport

New makes a new Transport.

func (*Transport) Done

func (t *Transport) Done() chan struct{}

Done gets a channel which is closed when the transport has successfully stopped.

func (*Transport) ErrChan

func (t *Transport) ErrChan() <-chan error

ErrChan gets the channel on which errors are sent.

func (*Transport) Receive

func (t *Transport) Receive(name string) <-chan []byte

Receive gets a channel on which to receive messages with the specified name.

func (*Transport) Send

func (t *Transport) Send(name string) chan<- []byte

Send gets a channel on which messages with the specified name may be sent.

func (*Transport) Stop

func (t *Transport) Stop()

Stop stops the transport. The channel returned from Done() will be closed when the transport has stopped.