nsq

README

NSQ

TO BE DEVELOPED

NSQ

Documentation

Index

• Constants
• type PSMQ
  • func New() *PSMQ
  • func (t *PSMQ) Close()
  • func (t *PSMQ) CreatePublishTopic(name string) chan<- []byte
  • func (t *PSMQ) Done() chan struct{}
  • func (t *PSMQ) ErrChan() chan error
  • func (t *PSMQ) Init()
  • func (t *PSMQ) SubscribeToTopic(name string) <-chan []byte

Constants

const DefaultTCPAddr = "localhost:4150"

Types

type PSMQ

type PSMQ struct {
	NewProducer func() (*nsq.Producer, error)

	NewConsumer func(name string) (*nsq.Consumer, error)

	ConnectConsumer func(consumer *nsq.Consumer) error
	// contains filtered or unexported fields
}

func New

func New() *PSMQ

func (*PSMQ) Close

func (t *PSMQ) Close()

func (*PSMQ) CreatePublishTopic

func (t *PSMQ) CreatePublishTopic(name string) chan<- []byte

func (*PSMQ) Done

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

func (*PSMQ) ErrChan

func (t *PSMQ) ErrChan() chan error

func (*PSMQ) Init

func (t *PSMQ) Init()

func (*PSMQ) SubscribeToTopic

func (t *PSMQ) SubscribeToTopic(name string) <-chan []byte