Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

go-nsq: move to github.com/bitly/go-nsq #264

Merged
merged 1 commit into from
Sep 3, 2013
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
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