gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Gateways [WIP]

Browse Source 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
This commit is contained in:
Ivan Kozlovic
2018-11-12 15:47:23 -07:00
parent b04fce922f
commit 10fd3ca0c6
16 changed files with 5876 additions and 203 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/split_test.go
View File

@@ -24,7 +24,11 @@ func TestSplitBufferSubOp(t *testing.T) {
defer cli.Close()
defer trash.Close()
s := &Server{gacc: &Account{Name: globalAccountName}, accounts: make(map[string]*Account)}
gws, err := newGateway(DefaultOptions())
if err != nil {
t.Fatalf("Error creating gateways: %v", err)
}
s := &Server{gacc: &Account{Name: globalAccountName}, accounts: make(map[string]*Account), gateway: gws}
s.registerAccount(s.gacc)
c := &client{srv: s, acc: s.gacc, subs: make(map[string]*subscription), nc: cli}
@@ -61,7 +65,7 @@ func TestSplitBufferSubOp(t *testing.T) {
}
func TestSplitBufferUnsubOp(t *testing.T) {
s := &Server{gacc: &Account{Name: globalAccountName}, accounts: make(map[string]*Account)}
s := &Server{gacc: &Account{Name: globalAccountName}, accounts: make(map[string]*Account), gateway: &srvGateway{}}
s.registerAccount(s.gacc)
c := &client{srv: s, acc: s.gacc, subs: make(map[string]*subscription)}