scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 09:05:55 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

set even more ports for Node Command

Browse source
This commit is contained in:
Kuba Podgórski 2021-01-14 20:20:23 +01:00
parent 201e851511
commit 9a0facaaa3
1 changed files with 30 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
server/cluster_test.go
View file

@ -416,10 +416,14 @@ func TestClusterResize_AddNodeConcurrentIndex(t *testing.T) {
// Configure node1
m1 := test.NewCommandNode(t, false)
m1.Config.Gossip.Seeds = []string{seed}
if err := port.GetPort(func(p int) error {
m1.Config.Gossip.Port = fmt.Sprintf("%d", p)
if err := port.GetPorts(func(ports []int) error {
portsCfg := test.GenPortsConfig(test.NewPorts(ports))
m1.Config.Gossip.Port = portsCfg[0].Gossip.Port
m1.Config.DisCo = portsCfg[0].DisCo
m1.Config.BindGRPC = portsCfg[0].BindGRPC
return m1.Start()
}, 10); err != nil {
}, 4, 10); err != nil {
t.Fatalf("starting second main: %v", err)
}
defer m1.Close()
@ -470,10 +474,14 @@ func TestClusterResize_AddNodeConcurrentIndex(t *testing.T) {
// Configure node1
m1 := test.NewCommandNode(t, false)
m1.Config.Gossip.Seeds = []string{seed}
if err := port.GetPort(func(p int) error {
m1.Config.Gossip.Port = fmt.Sprintf("%d", p)
if err := port.GetPorts(func(ports []int) error {
portsCfg := test.GenPortsConfig(test.NewPorts(ports))
m1.Config.Gossip.Port = portsCfg[0].Gossip.Port
m1.Config.DisCo = portsCfg[0].DisCo
m1.Config.BindGRPC = portsCfg[0].BindGRPC
return m1.Start()
}, 10); err != nil {
}, 4, 10); err != nil {
t.Fatalf("starting second main: %v", err)
}
errc := make(chan error, 1)
@ -530,15 +538,20 @@ func TestClusterResize_AddNodeConcurrentIndex(t *testing.T) {
// Configure node1
m1 := test.NewCommandNode(t, false)
m1.Config.Gossip.Seeds = []string{seed}
if err := port.GetPort(func(p int) error {
m1.Config.Gossip.Port = fmt.Sprintf("%d", p)
if err := port.GetPorts(func(ports []int) error {
portsCfg := test.GenPortsConfig(test.NewPorts(ports))
m1.Config.Gossip.Port = portsCfg[0].Gossip.Port
m1.Config.DisCo = portsCfg[0].DisCo
m1.Config.BindGRPC = portsCfg[0].BindGRPC
errc := make(chan error, 1)
go func() {
_, err := m0.API.CreateIndex(context.Background(), "blah", pilosa.IndexOptions{})
errc <- err
}()
return m1.Start()
}, 10); err != nil {
}, 4, 10); err != nil {
t.Fatalf("starting second main: %v", err)
}
defer m1.Close()
@ -587,15 +600,20 @@ func TestClusterResize_AddNodeConcurrentIndex(t *testing.T) {
// Configure node1
m1 := test.NewCommandNode(t, false)
m1.Config.Gossip.Seeds = []string{seed}
if err := port.GetPort(func(p int) error {
m1.Config.Gossip.Port = fmt.Sprintf("%d", p)
if err := port.GetPorts(func(ports []int) error {
portsCfg := test.GenPortsConfig(test.NewPorts(ports))
m1.Config.Gossip.Port = portsCfg[0].Gossip.Port
m1.Config.DisCo = portsCfg[0].DisCo
m1.Config.BindGRPC = portsCfg[0].BindGRPC
errc := make(chan error, 1)
go func() {
_, err := m0.API.CreateIndex(context.Background(), "blah", pilosa.IndexOptions{})
errc <- err
}()
return m1.Start()
}, 10); err != nil {
}, 4, 10); err != nil {
t.Fatalf("starting second main: %v", err)
}