|
@@ -1,6 +1,7 @@
|
|
package discovery
|
|
package discovery
|
|
|
|
|
|
import (
|
|
import (
|
|
|
|
+ "fmt"
|
|
"testing"
|
|
"testing"
|
|
"time"
|
|
"time"
|
|
)
|
|
)
|
|
@@ -86,6 +87,13 @@ func TestDiscoveryOpts(t *testing.T) {
|
|
t.Fatalf("Heartbeat - Expected : %v, Actual : %v", expected, heartbeat)
|
|
t.Fatalf("Heartbeat - Expected : %v, Actual : %v", expected, heartbeat)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ discaveryTTL := fmt.Sprintf("%d", defaultDiscoveryTTLFactor-1)
|
|
|
|
+ clusterOpts = map[string]string{"discovery.ttl": discaveryTTL}
|
|
|
|
+ heartbeat, ttl, err = discoveryOpts(clusterOpts)
|
|
|
|
+ if err == nil && heartbeat == 0 {
|
|
|
|
+ t.Fatal("discovery.heartbeat must be positive")
|
|
|
|
+ }
|
|
|
|
+
|
|
clusterOpts = map[string]string{}
|
|
clusterOpts = map[string]string{}
|
|
heartbeat, ttl, err = discoveryOpts(clusterOpts)
|
|
heartbeat, ttl, err = discoveryOpts(clusterOpts)
|
|
if err != nil {
|
|
if err != nil {
|