Skip to content

Commit

Permalink
go-nsq: move to github.com/bitly/go-nsq
Browse files Browse the repository at this point in the history
  • Loading branch information
mreiferson committed Aug 30, 2013
1 parent 47e7304 commit 51ede02
Show file tree
Hide file tree
Showing 63 changed files with 240 additions and 2,580 deletions.
1 change: 1 addition & 0 deletions .travis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ env:
- GOARCH=386
install:
- go get github.com/bmizerany/assert
- go get github.com/bitly/go-nsq
- go get github.com/bitly/go-hostpool
- go get github.com/bitly/go-simplejson
script:
Expand Down
68 changes: 3 additions & 65 deletions ChangeLog.md
Original file line number Diff line number Diff line change
Expand Up @@ -279,72 +279,10 @@ removed in a future release.

* Initial public release.

## Go Client Library
## go-nsq Client Library

### 0.3.2 - 2013-08-26

**Upgrading from 0.3.1**: This release requires NSQ binary version `0.2.22+` for TLS support.

New Features/Improvements:

* #227 - TLS feature negotiation
* #164/#202/#255 - add `Writer`
* #186 - `MaxBackoffDuration` of `0` disables backoff
* #175 - support for `nsqd` config option `--max-rdy-count`
* #169 - auto-reconnect to hard-coded `nsqd`

Bug Fixes:

* #254/#256/#257 - new connection RDY starvation
* #250 - `nsqlookupd` polling improvements
* #243 - limit `IsStarved()` to connections w/ in-flight messages
* #169 - use last RDY count for `IsStarved()`; redistribute RDY state
* #204 - fix early termination blocking
* #177 - support `broadcast_address`
* #161 - connection pool goroutine safety

### 0.3.1 - 2013-02-07

**Upgrading from 0.3.0**: This release requires NSQ binary version `0.2.17+` for `TOUCH` support.

* #119 - add TOUCH command
* #133 - improved handling of errors/magic
* #127 - send IDENTIFY (missed in #90)
* #16 - add backoff to Reader

### 0.3.0 - 2013-01-07

**Upgrading from 0.2.4**: There are no backward incompatible changes to applications
written against the public `nsq.Reader` API.

However, there *are* a few backward incompatible changes to the API for applications that
directly use other public methods, or properties of a few NSQ data types:

`nsq.Message` IDs are now a type `nsq.MessageID` (a `[16]byte` array). The signatures of
`nsq.Finish()` and `nsq.Requeue()` reflect this change.

`nsq.SendCommand()` and `nsq.Frame()` were removed in favor of `nsq.SendFramedResponse()`.

`nsq.Subscribe()` no longer accepts `shortId` and `longId`. If upgrading your consumers
before upgrading your `nsqd` binaries to `0.2.16-rc.1` they will not be able to send the
optional custom identifiers.

* #90 performance optimizations
* #81 reader performance improvements / MPUB support

### 0.2.4 - 2012-10-15

* #69 added IsStarved() to reader API

### 0.2.3 - 2012-10-11

* #64 timeouts on reader queries to lookupd
* #54 fix crash issue with reader cleaning up from unexpectedly closed nsqd connections

### 0.2.2 - 2012-10-09

* Initial public release
* #264 moved **go-nsq** to its own [repository](https://github.com/bitly/go-nsq)

## pynsq Python Client Library

* #88 moved **pynsq** to its own [repository](https://github.com/bitly/pynsq).
* #88 moved **pynsq** to its own [repository](https://github.com/bitly/pynsq)
16 changes: 8 additions & 8 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
<p align="center"><img src="docs/images/nsq.png"/></p>
<p align="center"><img src="http://bitly.github.io/nsq/static/img/nsq.png"/></p>

* **Source**: [https://github.com/bitly/nsq][github]
* **Issues**: [https://github.com/bitly/nsq/issues][issues]
Expand Down Expand Up @@ -30,13 +30,13 @@ NOTE: master is our *development* branch and may not be stable at all times.
## In Production

<center><table><tr>
<td><a href="http://bitly.com"><img src="docs/images/bitly_logo.png" width="84"/></a></td>
<td><a href="http://life360.com"><img src="docs/images/life360_logo.png" width="100"/></a></td>
<td><a href="http://hailocab.com"><img src="docs/images/hailo_logo.png" width="62"/></a></td>
<td><a href="http://path.com"><img src="docs/images/path_logo.png" width="84"/></a></td>
<td><a href="http://trendrr.com"><img src="docs/images/trendrr_logo.png" width="97"/></a></td>
<td><a href="http://simplereach.com"><img src="docs/images/simplereach_logo.png" width="136"/></a></td>
<td><a href="http://energyhub.com"><img src="docs/images/energyhub_logo.png" width="99"/></a></td>
<td><a href="http://bitly.com"><img src="http://bitly.github.io/nsq/static/img/bitly_logo.png" width="84"/></a></td>
<td><a href="http://life360.com"><img src="http://bitly.github.io/nsq/static/img/life360_logo.png" width="100"/></a></td>
<td><a href="http://hailocab.com"><img src="http://bitly.github.io/nsq/static/img/hailo_logo.png" width="62"/></a></td>
<td><a href="http://path.com"><img src="http://bitly.github.io/nsq/static/img/path_logo.png" width="84"/></a></td>
<td><a href="http://trendrr.com"><img src="http://bitly.github.io/nsq/static/img/trendrr_logo.png" width="97"/></a></td>
<td><a href="http://simplereach.com"><img src="http://bitly.github.io/nsq/static/img/simplereach_logo.png" width="136"/></a></td>
<td><a href="http://energyhub.com"><img src="http://bitly.github.io/nsq/static/img/energyhub_logo.png" width="99"/></a></td>
</tr></table></center>

## Documentation
Expand Down
2 changes: 1 addition & 1 deletion apps/nsq_pubsub/nsq_pubsub.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"bufio"
"flag"
"fmt"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"github.com/bitly/nsq/util"
"io"
"log"
Expand Down
2 changes: 1 addition & 1 deletion apps/nsq_tail/nsq_tail.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"crypto/tls"
"flag"
"fmt"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"github.com/bitly/nsq/util"
"log"
"math/rand"
Expand Down
2 changes: 1 addition & 1 deletion apps/nsq_to_file/nsq_to_file.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (
"errors"
"flag"
"fmt"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"github.com/bitly/nsq/util"
"log"
"os"
Expand Down
2 changes: 1 addition & 1 deletion apps/nsq_to_http/http.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package main
import (
"bytes"
"fmt"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"github.com/bitly/nsq/util"
"net/http"
"time"
Expand Down
2 changes: 1 addition & 1 deletion apps/nsq_to_http/nsq_to_http.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import (
"flag"
"fmt"
"github.com/bitly/go-hostpool"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"github.com/bitly/nsq/util"
"log"
"math"
Expand Down
2 changes: 1 addition & 1 deletion apps/nsq_to_nsq/nsq_to_nsq.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (
"flag"
"fmt"
"github.com/bitly/go-hostpool"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"github.com/bitly/nsq/util"
"log"
"math"
Expand Down
2 changes: 1 addition & 1 deletion bench/bench_reader/bench_reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package main
import (
"bufio"
"flag"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"log"
"math"
"net"
Expand Down
2 changes: 1 addition & 1 deletion bench/bench_writer/bench_writer.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"bufio"
"bytes"
"flag"
"github.com/bitly/nsq/nsq"
"github.com/bitly/go-nsq"
"log"
"net"
"runtime"
Expand Down
7 changes: 5 additions & 2 deletions contrib/nsq.spec
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
%define name nsq
%define version 0.2.19
%define version 0.2.22
%define release 1
%define path usr/local
%define group Database/Applications
Expand Down Expand Up @@ -41,7 +41,10 @@ make PREFIX=/${path} DESTDIR=$RPM_BUILD_ROOT install
/%{path}/bin/nsqadmin
/%{path}/bin/nsqd
/%{path}/bin/nsqlookupd
/%{path}/bin/nsq_to_file
/%{path}/bin/nsq_pubsub
/%{path}/bin/nsq_to_file
/%{path}/bin/nsq_to_http
/%{path}/bin/nsq_to_nsq
/%{path}/bin/nsq_tail
/%{path}/bin/nsq_stat
/%{path}/share/nsqadmin/templates
3 changes: 2 additions & 1 deletion dist.sh
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,9 @@ export GOPATH="$TMPGOPATH:$GOROOT"

echo "... getting dependencies"
go get -v github.com/bitly/go-simplejson
go get -v github.com/bmizerany/assert
go get -v github.com/bitly/go-hostpool
go get -v github.com/bitly/go-nsq
go get -v github.com/bmizerany/assert

pushd $TMPGOPATH/src/github.com/bitly/nsq

Expand Down
Binary file removed docs/images/bitly_logo.png
Binary file not shown.
Binary file removed docs/images/energyhub_logo.png
Binary file not shown.
Binary file removed docs/images/hailo_logo.png
Binary file not shown.
Binary file removed docs/images/life360_logo.png
Binary file not shown.
Binary file removed docs/images/nsq.png
Binary file not shown.
Binary file removed docs/images/path_logo.png
Binary file not shown.
Binary file removed docs/images/simplereach_logo.png
Binary file not shown.
Binary file removed docs/images/trendrr_logo.png
Binary file not shown.
30 changes: 1 addition & 29 deletions nsq/README.md
Original file line number Diff line number Diff line change
@@ -1,29 +1 @@
## go-nsq

`go-nsq` is the official Go package for [NSQ][nsq].

It provides the building blocks for developing applications on the [NSQ][nsq] platform in Go.

Low-level functions and types are provided to communicate over the [NSQ protocol][protocol] as well
as a high-level [Reader][reader] and [Writer][writer] library to implement consumers and producers.

### Installing

$ go get github.com/bitly/nsq/nsq

### Importing

import "github.com/bitly/nsq/nsq"

### Docs

See [godoc][nsq_gopkgdoc] for pretty documentation or:

# in the nsq package directory
$ go doc

[nsq]: https://github.com/bitly/nsq
[nsq_gopkgdoc]: http://godoc.org/github.com/bitly/nsq/nsq
[protocol]: http://bitly.github.io/nsq/clients/tcp_protocol_spec.html
[reader]: http://godoc.org/github.com/bitly/nsq/nsq#Reader
[writer]: http://godoc.org/github.com/bitly/nsq/nsq#Writer
**go-nsq** has moved to https://github.com/bitly/go-nsq
Loading

0 comments on commit 51ede02

Please sign in to comment.