mirror of
https://github.com/kemko/nomad.git
synced 2026-01-06 18:35:44 +03:00
Fix tests, don't take the address of DefaultConsulCommand()
This commit is contained in:
@@ -42,7 +42,7 @@ func makeAgent(t testing.TB, cb func(*Config)) (string, *Agent) {
|
||||
Serf: getPort(),
|
||||
}
|
||||
conf.NodeName = fmt.Sprintf("Node %d", conf.Ports.RPC)
|
||||
conf.Consul = &config.DefaultConsulConfig()
|
||||
conf.Consul = config.DefaultConsulConfig()
|
||||
|
||||
// Tighten the Serf timing
|
||||
config.SerfConfig.MemberlistConfig.SuspicionMult = 2
|
||||
|
||||
@@ -46,7 +46,7 @@ func TestConsulServiceRegisterServices(t *testing.T) {
|
||||
t.Skip()
|
||||
|
||||
shutdownCh := make(chan struct{})
|
||||
cs, err := NewSyncer(&config.DefaultConsulConfig(), shutdownCh, logger)
|
||||
cs, err := NewSyncer(config.DefaultConsulConfig(), shutdownCh, logger)
|
||||
if err != nil {
|
||||
t.Fatalf("Err: %v", err)
|
||||
}
|
||||
@@ -82,7 +82,7 @@ func TestConsulServiceUpdateService(t *testing.T) {
|
||||
t.Skip()
|
||||
|
||||
shutdownCh := make(chan struct{})
|
||||
cs, err := NewSyncer(&config.DefaultConsulConfig(), shutdownCh, logger)
|
||||
cs, err := NewSyncer(config.DefaultConsulConfig(), shutdownCh, logger)
|
||||
if err != nil {
|
||||
t.Fatalf("Err: %v", err)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user