Completed singleton and N-node cluster boot up and joining phase.
* Simplified node join phase. * Added tests for cluster node startup and joining, both for singleton cluster and 2-node cluster. * Fixed bug in cluster node address and cluster daemon lookup. * Changed some APIs. * Renamed 'contact-point' to 'node-to-join'. * Minor refactorings. Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
parent
3b5c5e5f0f
commit
0413b44c98
2 changed files with 1 additions and 15 deletions
|
|
@ -8,19 +8,9 @@
|
|||
akka {
|
||||
|
||||
cluster {
|
||||
<<<<<<< HEAD
|
||||
# node to join - the full URI defined by a string on the form of "akka://system@hostname:port"
|
||||
# leave as empty string if the node should be a singleton cluster
|
||||
node-to-join = ""
|
||||
=======
|
||||
join {
|
||||
# contact point on the form of "hostname:port" of a node to try to join
|
||||
# leave as empty string if the node should be a singleton cluster
|
||||
contact-point = ""
|
||||
timeout = 30s
|
||||
max-time-to-retry = 30s
|
||||
}
|
||||
>>>>>>> Removed cluster seed nodes, added 'join.contact-point', changed joining phase, added singleton cluster mode plus misc other changes.
|
||||
|
||||
gossip {
|
||||
initialDelay = 5s
|
||||
|
|
|
|||
|
|
@ -25,11 +25,7 @@ class ClusterConfigSpec extends AkkaSpec(
|
|||
import settings._
|
||||
FailureDetectorThreshold must be(8)
|
||||
FailureDetectorMaxSampleSize must be(1000)
|
||||
|
||||
JoinContactPoint must be(None)
|
||||
JoinTimeout must be(30 seconds)
|
||||
JoinMaxTimeToRetry must be(30 seconds)
|
||||
|
||||
NodeToJoin must be(None)
|
||||
GossipInitialDelay must be(5 seconds)
|
||||
GossipFrequency must be(1 second)
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue