functional/rpcpb/member.go
func (m *Member) IsLeader() (bool, error) {
	cli, err := m.CreateEtcdClient()
	if err != nil {
		return false, fmt.Errorf("%v (%q)", err, m.EtcdClientEndpoint)
	}
	defer cli.Close()

	resp, err := cli.Status(context.Background(), m.EtcdClientEndpoint)
	if err != nil {
		return false, err
	}
	return resp.Header.MemberId == resp.Leader, nil
}
func (m *Member) IsLeader() (bool, error) {
	cli, err := m.CreateEtcdClient()
	if err != nil {
		return false, fmt.Errorf("%v (%q)", err, m.EtcdClientEndpoint)
	}
	defer cli.Close()

	resp, err := cli.Status(context.Background(), m.EtcdClientEndpoint)
	if err != nil {
		return false, err
	}
	return resp.Header.MemberId == resp.Leader, nil
}
func ( m * Member ) IsLeader ( ) ( bool , error ) { cli , err := m . CreateEtcdClient ( ) if err != nil { return false , fmt . Errorf ( " " , err , m . EtcdClientEndpoint ) } defer cli . Close ( ) resp , err := cli . Status ( context . Background ( ) , m . EtcdClientEndpoint ) if err != nil { return false , err } return resp . Header . MemberId == resp . Leader , nil }
// IsLeader returns true if this member is the current cluster leader.
IsLeader returns true if this member is the current cluster leader .