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

fix unit test (#3359)

Browse Source 
Signed-off-by: Matthias Hanel <mh@synadia.com>
This commit is contained in:
Matthias Hanel
2022-08-11 01:46:30 +02:00
committed by GitHub
parent 4ceee46bb6
commit 76219f8e5b
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
server/jetstream_super_cluster_test.go
View File

@@ -3082,7 +3082,7 @@ func TestJetStreamSuperClusterPeerEvacuationAndStreamReassignment(t *testing.T)
nc, js := jsClientConnect(t, srv)
defer nc.Close()
test := func(r int, moveTags []string, targetCluster string, testMigrateTo bool, listFrom bool) {
test := func(t *testing.T, r int, moveTags []string, targetCluster string, testMigrateTo bool, listFrom bool) {
si, err := js.AddStream(&nats.StreamConfig{
Name: "TEST",
Subjects: []string{"foo"},
@@ -3208,7 +3208,9 @@ func TestJetStreamSuperClusterPeerEvacuationAndStreamReassignment(t *testing.T)
if !listFrom {
// when needed determine which server move moved away from
si, err := js.StreamInfo("TEST", nats.MaxWait(2*time.Second))
require_NoError(t, err)
if err != nil {
return fmt.Errorf("could not fetch stream info: %v", err)
}
for n := range startSet {
if n != si.Cluster.Leader {
found := false
@@ -3252,21 +3254,21 @@ func TestJetStreamSuperClusterPeerEvacuationAndStreamReassignment(t *testing.T)
for i := 1; i <= 3; i++ {
t.Run(fmt.Sprintf("r%d", i), func(t *testing.T) {
test(i, nil, "C1", false, true)
test(t, i, nil, "C1", false, true)
})
t.Run(fmt.Sprintf("r%d-explicit", i), func(t *testing.T) {
test(i, nil, "C1", true, true)
test(t, i, nil, "C1", true, true)
})
t.Run(fmt.Sprintf("r%d-nosrc", i), func(t *testing.T) {
test(i, nil, "C1", false, false)
test(t, i, nil, "C1", false, false)
})
}
t.Run("r3-cluster-move", func(t *testing.T) {
test(3, []string{"cluster:C2"}, "C2", false, false)
test(t, 3, []string{"cluster:C2"}, "C2", false, false)
})
t.Run("r3-cluster-move-nosrc", func(t *testing.T) {
test(3, []string{"cluster:C2"}, "C2", false, true)
test(t, 3, []string{"cluster:C2"}, "C2", false, true)
})
}