ETCD数据库源码分析——集群间网络层客户端peerRt

peerRt（RoundTripper类型）主要负责实现etcdserver的网络请求等功能，用于向集群其他节点发送version或lease服务请求。我们知道其是在ETCD数据库源码分析——etcdserver bootstrap初始化中的第二步进行初始化的。如何使用它呢？
如server/etcdserver/cluster_util.go的promoteMemberHTTP所示，使用peerRt创建http客户端，然后构造请求Url和指定请求方法为POST，创建http Request结构体，调用http客户端的do函数向服务端进行请求，并获取其响应。

func promoteMemberHTTP(ctx context.Context, url string, id uint64, peerRt http.RoundTripper) ([]*membership.Member, error) {
    
	cc := &http.Client{
    Transport: peerRt}  // 使用peerRt创建http客户端
	// TODO: refactor member http handler code cannot import etcdhttp, so manually construct url
	requestUrl := url + "/members/promote/" + fmt.Sprintf("%d", id)
	req, err := http.NewRequest("POST", requestUrl, nil)
	if err != nil {
     return nil, err }
	req = req.WithContext(ctx)
	resp, err := cc.Do(req)
	if err != nil {
     return nil, err }
	defer resp.Body.Close()
	b, err := io.ReadAll(resp.Body)
	if err != nil {
     return nil, err }
 
    // 处理请求超时
	if resp.StatusCode == http.StatusRequestTimeout {
     return nil, errors.ErrTimeout }
	if resp.StatusCode == http.StatusPreconditionFailed {
    
		// both ErrMemberNotLearner and ErrLearnerNotReady have same http status code
		if strings.Contains(string(b), errors.ErrLearnerNotReady.Error()) {
     return nil, errors.ErrLearnerNotReady }
		if strings.Contains(string(b), membership.ErrMemberNotLearner.Error()) {
     return nil, membership.ErrMemberNotLearner }
		return nil, fmt.Errorf("member promote: unknown error(%s)", string(b))
	}
	if resp.StatusCode == http.StatusNotFound {
     return nil, membership.ErrIDNotFound }
    // 其他类型的错误
	if resp.StatusCode != http.StatusOK {
     // all other types of errors
		return nil, fmt.Errorf("member promote: unknown error(%s)", string(b))
	}

	var membs []*membership.Member
	if err := json.Unmarshal(b, &membs); err != nil {
     return nil, err } // 反序列化请求响应内容
	return membs, nil
}

如下server/etcdserver/adapters.go中的GetMembersVersions也是使用peerRt获取MembersVersions。

func (s *serverVersionAdapter) GetMembersVersions() map[string]*version.Versions {
    
	return getMembersVersions(s.lg, s.cluster, s.MemberId(), s.peerRt, s.Cfg.ReqTimeout())
}