()
| 1894 | } |
| 1895 | |
| 1896 | func (n *node) joinPeers() error { |
| 1897 | pl, err := n.leaderBlocking() |
| 1898 | if err != nil { |
| 1899 | return err |
| 1900 | } |
| 1901 | |
| 1902 | c := pb.NewRaftClient(pl.Get()) |
| 1903 | glog.Infof("Calling JoinCluster via leader: %s", pl.Addr) |
| 1904 | if _, err := c.JoinCluster(n.ctx, n.RaftContext); err != nil { |
| 1905 | return errors.Wrapf(err, "error while joining cluster") |
| 1906 | } |
| 1907 | glog.Infof("Done with JoinCluster call\n") |
| 1908 | return nil |
| 1909 | } |
| 1910 | |
| 1911 | // Checks if its a peer from the leader of the group. |
| 1912 | func (n *node) isMember() (bool, error) { |
nothing calls this directly
no test coverage detected