nsqx

package module

v0.0.0-...-91aa13a Latest Latest Go to latest Published: Aug 24, 2023 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/axengine/utils

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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应该生成不同的消费者

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL