mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-17 03:24:40 -07:00
@@ -2,9 +2,9 @@ language: go
|
||||
go:
|
||||
- 1.4
|
||||
install:
|
||||
- DST=~/gopath/src/github.com/apcera
|
||||
- DST=~/gopath/src/github.com/nats-io
|
||||
- mkdir -p "$DST"
|
||||
- git clone --depth=1 --quiet https://github.com/apcera/nats.git "$DST"/nats
|
||||
- git clone --depth=1 --quiet https://github.com/nats-io/nats.git "$DST"/nats
|
||||
- go get golang.org/x/tools/cmd/vet
|
||||
- go get golang.org/x/tools/cmd/cover
|
||||
- go get github.com/mattn/goveralls
|
||||
|
||||
12
README.md
12
README.md
@@ -1,8 +1,8 @@
|
||||
# gnatsd
|
||||
[](http://opensource.org/licenses/MIT)
|
||||
[](http://travis-ci.org/apcera/gnatsd)
|
||||
[](https://github.com/apcera/gnatsd/releases/tag/v0.6.0)
|
||||
[](https://coveralls.io/r/apcera/gnatsd?branch=master)
|
||||
[](http://travis-ci.org/nats-io/gnatsd)
|
||||
[](https://github.com/nats-io/gnatsd/releases/tag/v0.6.0)
|
||||
[](https://coveralls.io/r/nats-io/gnatsd?branch=master)
|
||||
|
||||
A High Performance [NATS](https://nats.io) Server written in [Go.](http://golang.org)
|
||||
|
||||
@@ -109,11 +109,11 @@ presentations, references and more.
|
||||
## Client libraries
|
||||
|
||||
There are several client language bindings for NATS.
|
||||
- [Go](https://github.com/apcera/nats)
|
||||
- [Go](https://github.com/nats-io/nats)
|
||||
- [Java](https://github.com/tyagihas/java_nats)
|
||||
- [Java - Spring](https://github.com/mheath/jnats)
|
||||
- [Node.js](https://github.com/derekcollison/node_nats)
|
||||
- [Ruby](https://github.com/derekcollison/nats)
|
||||
- [Node.js](https://github.com/nats-io/node-nats)
|
||||
- [Ruby](https://github.com/nats-io/ruby-nats)
|
||||
|
||||
|
||||
## License
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
package auth
|
||||
|
||||
import (
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
type Plain struct {
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
package auth
|
||||
|
||||
import (
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
type Token struct {
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2012-2013 Apcera Inc. All rights reserved.
|
||||
// Copyright 2012-2015 Apcera Inc. All rights reserved.
|
||||
|
||||
package main
|
||||
|
||||
@@ -7,9 +7,9 @@ import (
|
||||
"os"
|
||||
"strings"
|
||||
|
||||
"github.com/apcera/gnatsd/auth"
|
||||
"github.com/apcera/gnatsd/logger"
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/auth"
|
||||
"github.com/nats-io/gnatsd/logger"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
func main() {
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2012-2013 Apcera Inc. All rights reserved.
|
||||
// Copyright 2012-2015 Apcera Inc. All rights reserved.
|
||||
|
||||
// HashMap defines a high performance hashmap based on
|
||||
// fast hashing and fast key comparison. Simple chaining
|
||||
@@ -11,7 +11,7 @@ import (
|
||||
"errors"
|
||||
"unsafe"
|
||||
|
||||
"github.com/apcera/gnatsd/hash"
|
||||
"github.com/nats-io/gnatsd/hash"
|
||||
)
|
||||
|
||||
// HashMap stores Entry items using a given Hash function.
|
||||
|
||||
@@ -12,8 +12,8 @@ import (
|
||||
"sync/atomic"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/hashmap"
|
||||
"github.com/apcera/gnatsd/sublist"
|
||||
"github.com/nats-io/gnatsd/hashmap"
|
||||
"github.com/nats-io/gnatsd/sublist"
|
||||
)
|
||||
|
||||
const (
|
||||
|
||||
@@ -10,7 +10,7 @@ import (
|
||||
"strconv"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/sublist"
|
||||
"github.com/nats-io/gnatsd/sublist"
|
||||
)
|
||||
|
||||
// Snapshot this
|
||||
|
||||
@@ -11,7 +11,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/nats"
|
||||
"github.com/nats-io/nats"
|
||||
)
|
||||
|
||||
const CLIENT_PORT = 11224
|
||||
|
||||
@@ -11,7 +11,7 @@ import (
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/conf"
|
||||
"github.com/nats-io/gnatsd/conf"
|
||||
)
|
||||
|
||||
// Options block for gnatsd server.
|
||||
|
||||
@@ -7,7 +7,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/nats"
|
||||
"github.com/nats-io/nats"
|
||||
)
|
||||
|
||||
const PING_CLIENT_PORT = 11228
|
||||
|
||||
@@ -9,7 +9,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/nats"
|
||||
"github.com/nats-io/nats"
|
||||
)
|
||||
|
||||
func TestRouteConfig(t *testing.T) {
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2012-2014 Apcera Inc. All rights reserved.
|
||||
// Copyright 2012-2015 Apcera Inc. All rights reserved.
|
||||
|
||||
package server
|
||||
|
||||
@@ -17,7 +17,7 @@ import (
|
||||
// Allow dynamic profiling.
|
||||
_ "net/http/pprof"
|
||||
|
||||
"github.com/apcera/gnatsd/sublist"
|
||||
"github.com/nats-io/gnatsd/sublist"
|
||||
)
|
||||
|
||||
// Info is the information sent to clients to help them understand information
|
||||
|
||||
@@ -7,8 +7,8 @@ import (
|
||||
"net"
|
||||
"testing"
|
||||
|
||||
"github.com/apcera/gnatsd/hashmap"
|
||||
"github.com/apcera/gnatsd/sublist"
|
||||
"github.com/nats-io/gnatsd/hashmap"
|
||||
"github.com/nats-io/gnatsd/sublist"
|
||||
)
|
||||
|
||||
func TestSplitBufferSubOp(t *testing.T) {
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2013 Apcera Inc. All rights reserved.
|
||||
// Copyright 2013-2015 Apcera Inc. All rights reserved.
|
||||
|
||||
package server
|
||||
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2012 Apcera Inc. All rights reserved.
|
||||
// Copyright 2012-2015 Apcera Inc. All rights reserved.
|
||||
|
||||
package server
|
||||
|
||||
|
||||
@@ -11,8 +11,8 @@ import (
|
||||
"sync/atomic"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/hash"
|
||||
"github.com/apcera/gnatsd/hashmap"
|
||||
"github.com/nats-io/gnatsd/hash"
|
||||
"github.com/nats-io/gnatsd/hashmap"
|
||||
)
|
||||
|
||||
// A Sublist stores and efficiently retrieves subscriptions. It uses a
|
||||
|
||||
@@ -9,8 +9,8 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/auth"
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/auth"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
func doAuthConnect(t tLogger, c net.Conn, token, user, pass string) {
|
||||
|
||||
@@ -12,7 +12,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
const PERF_PORT = 8422
|
||||
|
||||
@@ -10,7 +10,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/nats"
|
||||
"github.com/nats-io/nats"
|
||||
)
|
||||
|
||||
func TestServerRestartReSliceIssue(t *testing.T) {
|
||||
|
||||
@@ -8,7 +8,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
func runServers(t *testing.T) (srvA, srvB *server.Server, optsA, optsB *server.Options) {
|
||||
|
||||
@@ -11,7 +11,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
const MONITOR_PORT = 11422
|
||||
|
||||
@@ -5,7 +5,7 @@ package test
|
||||
import (
|
||||
"testing"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
func runPedanticServer() *server.Server {
|
||||
|
||||
@@ -7,7 +7,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
const (
|
||||
|
||||
@@ -7,7 +7,7 @@ import (
|
||||
"strconv"
|
||||
"testing"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
func TestResolveRandomPort(t *testing.T) {
|
||||
|
||||
@@ -6,7 +6,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
const PROTO_TEST_PORT = 9922
|
||||
|
||||
@@ -11,7 +11,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
func runRouteServer(t *testing.T) (*server.Server, *server.Options) {
|
||||
|
||||
@@ -15,7 +15,7 @@ import (
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/apcera/gnatsd/server"
|
||||
"github.com/nats-io/gnatsd/server"
|
||||
)
|
||||
|
||||
const natsServerExe = "../gnatsd"
|
||||
|
||||
Reference in New Issue
Block a user