Ignore cluster membership errors when reconciling from temp etcd

pkg/cluster/bootstrap.go

@@ -573,10 +573,10 @@ func (c *Cluster) reconcileEtcd(ctx context.Context) error {
 	e.StartEmbeddedTemporary(reconcileCtx)
 
 	for {
-		if err := e.Test(reconcileCtx); err != nil {
-			logrus.Infof("Failed to test data store connection: %v", err)
+		if err := e.Test(reconcileCtx); err != nil && !errors.Is(err, etcd.ErrNotMember) {
+			logrus.Infof("Failed to test temporary data store connection: %v", err)
 		} else {
-			logrus.Info(e.EndpointName() + " data store connection OK")
+			logrus.Info(e.EndpointName() + " temporary data store connection OK")
 			break
 		}
 

pkg/etcd/etcd.go

@@ -77,6 +77,7 @@ var (
 	NodeAddressAnnotation = "etcd." + version.Program + ".cattle.io/node-address"
 
 	ErrAddressNotSet = errors.New("apiserver addresses not yet set")
+	ErrNotMember     = errNotMember()
 )
 
 type NodeControllerGetter func() controllerv1.NodeController
@@ -103,6 +104,25 @@ type Members struct {
 	Members []*etcdserverpb.Member `json:"members"`
 }
 
+type MembershipError struct {
+	Self    string
+	Members []string
+}
+
+func (e *MembershipError) Error() string {
+	return fmt.Sprintf("this server is a not a member of the etcd cluster. Found %v, expect: %s", e.Members, e.Self)
+}
+
+func (e *MembershipError) Is(target error) bool {
+	switch target {
+	case ErrNotMember:
+		return true
+	}
+	return false
+}
+
+func errNotMember() error { return &MembershipError{} }
+
 // NewETCD creates a new value of type
 // ETCD with an initialized cron value.
 func NewETCD() *ETCD {
@@ -172,7 +192,7 @@ func (e *ETCD) Test(ctx context.Context) error {
 			memberNameUrls = append(memberNameUrls, member.Name+"="+member.PeerURLs[0])
 		}
 	}
-	return errors.Errorf("this server is a not a member of the etcd cluster. Found %v, expect: %s=%s", memberNameUrls, e.name, e.address)
+	return &MembershipError{Members: memberNameUrls, Self: e.name + "=" + e.address}
 }
 
 // DBDir returns the path to dataDir/db/etcd