kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-07 10:55:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

agent: all dynamic ports for tests

Browse Source
This commit is contained in:
Ryan Uber
2015-09-25 12:19:04 -07:00
parent 26e31edf1c
commit 80d940d920
1 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
command/agent/agent_test.go
View File

@@ -3,7 +3,6 @@ package agent
import (
"fmt"
"io/ioutil"
"net"
"os"
"strings"
"sync/atomic"
@@ -35,16 +34,16 @@ func makeAgent(t *testing.T, cb func(*Config)) (string, *Agent) {
config := nomad.DefaultConfig()
conf.NomadConfig = config
// Only use loopback
config.RPCAddr = &net.TCPAddr{
IP: []byte{127, 0, 0, 1},
Port: getPort(),
// Bind and set ports
conf.BindAddr = "127.0.0.1"
conf.Ports = &Ports{
HTTP: getPort(),
RPC: getPort(),
Serf: getPort(),
}
config.NodeName = fmt.Sprintf("Node %d", config.RPCAddr.Port)
conf.NodeName = fmt.Sprintf("Node %d", conf.Ports.RPC)
// Tighten the Serf timing
config.SerfConfig.MemberlistConfig.BindAddr = "127.0.0.1"
config.SerfConfig.MemberlistConfig.BindPort = getPort()
config.SerfConfig.MemberlistConfig.SuspicionMult = 2
config.SerfConfig.MemberlistConfig.RetransmitMult = 2
config.SerfConfig.MemberlistConfig.ProbeTimeout = 50 * time.Millisecond