hub / github.com/nsqio/go-nsq
github.com/nsqio/go-nsq @v1.1.0 sqlite
346 symbols
995 edges
20 files
142 documented · 41%
4 cross-repo links
README
go-nsq
The official Go package for NSQ.
Docs
See godoc and the main repo apps directory for examples of clients built using this package.
Tests
Tests are run via ./test.sh (which requires nsqd and nsqlookupd to be installed).
Extension points exported contracts — how you extend this code
Handler (Interface)Handler is the message processing interface for Consumer Implement this interface for handlers that return whether or n [3 …
consumer.go
BackoffStrategy (Interface)
BackoffStrategy defines a strategy for calculating the duration of time a consumer should backoff for a given attempt [2 …
config.go
ConnDelegate (Interface)
ConnDelegate is an interface of methods that are used as callbacks in Conn [2 implementers]
delegates.go
FailedMessageLogger (Interface)
FailedMessageLogger is an interface that can be implemented by handlers that wish to receive a callback when a message i [2 …
consumer.go
MessageDelegate (Interface)
MessageDelegate is an interface of methods that are used as callbacks in Message [1 implementers]
delegates.go
HandlerFunc (FuncType)
HandlerFunc is a convenience type to avoid having to declare a struct to implement the Handler interface, it can be used
consumer.go
DiscoveryFilter (Interface)
DiscoveryFilter is an interface accepted by `SetBehaviorDelegate()` for filtering the nsqds returned from discovery via
consumer.go
Core symbols most depended-on inside this repo
Stringcalled by 38
producer.go
log
called by 36
consumer.go
Error
called by 34
errors.go
log
called by 27
conn.go
NewConfig
called by 19
config.go
Write
called by 17
conn.go
Log
called by 13
mock_test.go
conns
called by 12
consumer.go
Shape
Languages
Go100%
Modules by API surface
consumer.go67 symbols
delegates.go48 symbols
conn.go41 symbols
config.go41 symbols
producer.go39 symbols
producer_test.go22 symbols
mock_test.go18 symbols
command.go18 symbols
consumer_test.go14 symbols
message.go13 symbols
protocol.go6 symbols
config_test.go5 symbols
Used by 4 indexed graphs manifest dependencies, hub-wide
Dependencies from manifests, versioned
github.com/golang/snappyv0.0.1 · 1×
For agents
$ claude mcp add go-nsq \
-- python -m otcore.mcp_server <graph>