Commit 701e45f4 authored by Hussein Galal's avatar Hussein Galal Committed by Brad Davidson

skip node delete from removed member (#2413)

* skip node delete from removed member Signed-off-by: 's avatargalal-hussein <hussein.galal.ahmed.11@gmail.com> * use grpc errors Signed-off-by: 's avatargalal-hussein <hussein.galal.ahmed.11@gmail.com> * go imports Signed-off-by: 's avatargalal-hussein <hussein.galal.ahmed.11@gmail.com> * exit if node is the etcd that being removed Signed-off-by: 's avatargalal-hussein <hussein.galal.ahmed.11@gmail.com>
parent 085a3b29
...@@ -28,6 +28,7 @@ import ( ...@@ -28,6 +28,7 @@ import (
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
etcd "go.etcd.io/etcd/clientv3" etcd "go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/clientv3/snapshot" "go.etcd.io/etcd/clientv3/snapshot"
"go.etcd.io/etcd/etcdserver/api/v3rpc/rpctypes"
"go.etcd.io/etcd/etcdserver/etcdserverpb" "go.etcd.io/etcd/etcdserver/etcdserverpb"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
utilnet "k8s.io/apimachinery/pkg/util/net" utilnet "k8s.io/apimachinery/pkg/util/net"
...@@ -511,8 +512,14 @@ func (e *ETCD) removePeer(ctx context.Context, id, address string) error { ...@@ -511,8 +512,14 @@ func (e *ETCD) removePeer(ctx context.Context, id, address string) error {
return err return err
} }
if u.Hostname() == address { if u.Hostname() == address {
if e.address == address {
logrus.Fatalf("node has been delete from the cluster. Backup and delete ${datadir}/server/db if you like to rejoin the node")
}
logrus.Infof("Removing name=%s id=%d address=%s from etcd", member.Name, member.ID, address) logrus.Infof("Removing name=%s id=%d address=%s from etcd", member.Name, member.ID, address)
_, err := e.client.MemberRemove(ctx, member.ID) _, err := e.client.MemberRemove(ctx, member.ID)
if err == rpctypes.ErrGRPCMemberNotFound {
return nil
}
return err return err
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment