nsq

Documentation

Index

• type Message
• type Publisher
  • func NewPublish() Publisher
• type PublisherEnv
• type Receiver
  • func NewReceive() Receiver
• type ReceiverEnv

Types

type Message

type Message struct {
	Topic   string
	Content []byte
}

Message nsq message publish object

type Publisher

type Publisher interface {
	Init(*PublisherEnv) error // init function
	Publish(*Message) error   // publish function
}

Publisher producer publish interface

func NewPublish

func NewPublish() Publisher

NewPublish publisher new function

type PublisherEnv

type PublisherEnv struct {
	Address string
	Config  *nsq.Config
}

PublisherEnv nsq publisher init params

type Receiver

type Receiver interface {
	Init(*ReceiverEnv) error // init function
}

Receiver receiver publish interface

func NewReceive

func NewReceive() Receiver

NewReceive receiver new function

type ReceiverEnv

type ReceiverEnv struct {
	Address string
	Config  *nsq.Config
	Topic   string
	Channel string
	Handler *nsq.Handler
}

ReceiverEnv nsq receiver init params