code: func newClusterPeer(srv *server, connInfo services.TunnelConnection) (*clusterPeer, error) {
  	clusterPeer := &clusterPeer{
  		srv:      srv,
  		connInfo: connInfo,
  		log: log.WithFields(log.Fields{
  			trace.Component: teleport.ComponentReverseTunnelServer,
  			trace.ComponentFields: map[string]string{
  				"cluster": connInfo.GetClusterName(),
  			},
  		}),
  	}
  
  	return clusterPeer, nil
  }
docs: // newClusterPeer returns new cluster peer