msg

Documentation

Index

• type Publisher
  • func NewPublisher(tpc string, addrs *[]string) (*Publisher, error)
  • func (p *Publisher) Run(data chan []byte)
  • func (p *Publisher) Stop()
• type Subscriber
  • func NewSubscriber(tpc, ch string, addrs *[]string) (*Subscriber, error)
  • func (s *Subscriber) HandleMessage(m *nsq.Message) error
  • func (s *Subscriber) Stop()

Types

type Publisher

type Publisher struct {
	Data     chan []byte
	StopChan chan bool
	TermChan chan os.Signal
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(tpc string, addrs *[]string) (*Publisher, error)

func (*Publisher) Run

func (p *Publisher) Run(data chan []byte)

func (*Publisher) Stop

func (p *Publisher) Stop()

type Subscriber

type Subscriber struct {
	C *nsq.Consumer

	Data     chan []byte
	StopChan chan bool
	TermChan chan os.Signal
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(tpc, ch string, addrs *[]string) (*Subscriber, error)

func (*Subscriber) HandleMessage

func (s *Subscriber) HandleMessage(m *nsq.Message) error

func (*Subscriber) Stop

func (s *Subscriber) Stop()