|
|
@ -156,6 +156,11 @@ func main() {
|
|
|
|
os.Exit(1)
|
|
|
|
os.Exit(1)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Ensure Raft adv address is set as per policy.
|
|
|
|
|
|
|
|
if raftAdv == "" {
|
|
|
|
|
|
|
|
raftAdv = raftAddr
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
dataPath := flag.Arg(0)
|
|
|
|
dataPath := flag.Arg(0)
|
|
|
|
|
|
|
|
|
|
|
|
// Display logo.
|
|
|
|
// Display logo.
|
|
|
@ -265,10 +270,6 @@ func main() {
|
|
|
|
// Execute any requested join operation.
|
|
|
|
// Execute any requested join operation.
|
|
|
|
if len(joins) > 0 {
|
|
|
|
if len(joins) > 0 {
|
|
|
|
log.Println("join addresses are:", joins)
|
|
|
|
log.Println("join addresses are:", joins)
|
|
|
|
advAddr := raftAddr
|
|
|
|
|
|
|
|
if raftAdv != "" {
|
|
|
|
|
|
|
|
advAddr = raftAdv
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
joinDur, err := time.ParseDuration(joinInterval)
|
|
|
|
joinDur, err := time.ParseDuration(joinInterval)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
@ -288,7 +289,7 @@ func main() {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if j, err := cluster.Join(joinSrcIP, joins, str.ID(), advAddr, !raftNonVoter,
|
|
|
|
if j, err := cluster.Join(joinSrcIP, joins, str.ID(), raftAdv, !raftNonVoter,
|
|
|
|
joinAttempts, joinDur, &tlsConfig); err != nil {
|
|
|
|
joinAttempts, joinDur, &tlsConfig); err != nil {
|
|
|
|
log.Fatalf("failed to join cluster at %s: %s", joins, err.Error())
|
|
|
|
log.Fatalf("failed to join cluster at %s: %s", joins, err.Error())
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -467,9 +468,6 @@ func idOrRaftAddr() string {
|
|
|
|
if nodeID != "" {
|
|
|
|
if nodeID != "" {
|
|
|
|
return nodeID
|
|
|
|
return nodeID
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if raftAdv == "" {
|
|
|
|
|
|
|
|
return raftAddr
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return raftAdv
|
|
|
|
return raftAdv
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|