JoinMembers joins the cluster with given members. See https://godoc.org/github.com/hashicorp/memberlist#Memberlist.Join This call is only valid after KV service has been started and is still running.
(members []string)
| 740 | // See https://godoc.org/github.com/hashicorp/memberlist#Memberlist.Join |
| 741 | // This call is only valid after KV service has been started and is still running. |
| 742 | func (m *KV) JoinMembers(members []string) (int, error) { |
| 743 | if m.State() != services.Running { |
| 744 | return 0, fmt.Errorf("service not Running") |
| 745 | } |
| 746 | return m.memberlist.Join(members) |
| 747 | } |
| 748 | |
| 749 | // fastJoinMembersOnStartup attempts to reach small subset of nodes (computed as RetransmitMult * log10(number of discovered members + 1)). |
| 750 | func (m *KV) fastJoinMembersOnStartup(ctx context.Context) error { |