GitHub - nsqio/go-nsq at e2fa67fb349a4233d721b1c67e6dadbbf57a7f69

This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Name	Name	Last commit message	Last commit date
Latest commit iaburton Change new(type) to &type{} to keep with package convention Mar 28, 2019 e2fa67f · Mar 28, 2019 History 565 Commits
test	test	refactor tests and add additional TLS tests	Aug 25, 2014
.travis.yml	.travis.yml	travis: update for go modules; bump Go versions	Mar 6, 2019
ChangeLog.md	ChangeLog.md	bump v1.0.7 stable	Aug 4, 2017
Gopkg.lock	Gopkg.lock	go.mod: bump snappy to v0.0.1	Mar 6, 2019
Gopkg.toml	Gopkg.toml	go.mod: bump snappy to v0.0.1	Mar 6, 2019
LICENSE	LICENSE	add LICENSE	Oct 2, 2014
README.md	README.md	docs: update README	Oct 18, 2015
UPGRADING.md	UPGRADING.md	s/bitly/nsqio	Aug 29, 2015
api_request.go	api_request.go	consumer: disable keep alives for nsqlookupd queries	Jun 3, 2017
command.go	command.go	add DPUB	May 2, 2015
command_test.go	command_test.go	remove test logging cruft	Feb 22, 2015
config.go	config.go	consumer: give up RDY when conn exceeds LowRdyTimeout	Apr 16, 2017
config_flag.go	config_flag.go	Fix CS	Feb 14, 2017
config_flag_test.go	config_flag_test.go	s/bitly/nsqio	Aug 29, 2015
config_test.go	config_test.go	Allow BackoffStrategy to be set via flag	Mar 23, 2015
conn.go	conn.go	Change new(type) to &type{} to keep with package convention	Mar 28, 2019
consumer.go	consumer.go	consumer: backoffMtx and rdyRetryMtx don't read lock	Mar 14, 2019
consumer_test.go	consumer_test.go	tests: cleanup some old NSQ version cruft	Mar 7, 2019
delegates.go	delegates.go	fix some lint, vet, fmt issues	May 2, 2015
errors.go	errors.go	Check updateRDY return error, clear backoffDuration on success	Mar 24, 2015
go.mod	go.mod	go.mod: bump snappy to v0.0.1	Mar 6, 2019
go.sum	go.sum	go.mod: bump snappy to v0.0.1	Mar 6, 2019
message.go	message.go	DecodeMessage: fix formatting of docstring (#193 )	Sep 29, 2016
mock_test.go	mock_test.go	consumer: add test for pausing	Mar 14, 2019
producer.go	producer.go	Expose DeferredPublish command on producer	Sep 29, 2015
producer_test.go	producer_test.go	TestProducerConnection() now green on OSX. fixes #161 .	Oct 3, 2015
protocol.go	protocol.go	make #ephemeral topic names valid to match nsq changes	Nov 19, 2014
states.go	states.go	remove unused states	Oct 31, 2016
test.sh	test.sh	test: bump to Go 1.5.1 and cleanup test.sh	Sep 13, 2015
travis.sh	travis.sh	travis: update for go modules; bump Go versions	Mar 6, 2019
version.go	version.go	bump v1.0.7 stable	Aug 4, 2017

Repository files navigation

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).

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Repository files navigation

go-nsq

Docs

Tests

About

Releases 18

Packages

Contributors 50

Languages

License

nsqio/go-nsq

Folders and files

Latest commit

History

Repository files navigation

go-nsq

Docs

Tests

About

Topics

Resources

License

Stars

Watchers

Forks

Releases 18

Packages 0

Contributors 50

Languages

Packages