nsqx

Documentation

Index

• Constants
• type Producer
  • func NewProducer(nsqdTcpAddr string) *Producer
  • func (p *Producer) Publish(topic string, msg []byte) error
• type TopicDiscoverer
  • func NewTopicDiscoverer(topics []string, channel string, maxInFlight int, lookupdHTTPAddrs []string, ...) *TopicDiscoverer

Constants

const (
	USER_AGENT = "go agent v0.1"
)

Types

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer(nsqdTcpAddr string) *Producer

func (*Producer) Publish

func (p *Producer) Publish(topic string, msg []byte) error

type TopicDiscoverer

type TopicDiscoverer struct {
	// contains filtered or unexported fields
}

func NewTopicDiscoverer

func NewTopicDiscoverer(topics []string, channel string, maxInFlight int, lookupdHTTPAddrs []string, handle func(string, interface{})) *TopicDiscoverer

NewTopicDiscoverer 生成多个主题发现的消费者 topics 订阅主题列表 channel channel名称 maxInFlight NSQD在有maxInFlight*25条消息时向下推送 lookupdHTTPAddrs NSQLOOKUPs的http地址 handle 消息处理句柄 PS:对channel不同的topic应该生成不同的消费者