Skip to content
This repository was archived by the owner on Jul 16, 2024. It is now read-only.

Commit 3442565

Browse files
authored
Merge pull request #396 from ahrtr/remove_member_20240427
Fix the issue that an incorrect member may be removed
2 parents 39cfe40 + 31f8e5f commit 3442565

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

etcd-manager/pkg/controller/etcdclusterstate.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -144,21 +144,21 @@ func (s *etcdClusterState) etcdAddMember(ctx context.Context, nodeInfo *protoetc
144144
return nil, fmt.Errorf("unable to reach any cluster member, when trying to add new member %q", nodeInfo.PeerUrls)
145145
}
146146

147-
func (s *etcdClusterState) etcdRemoveMember(ctx context.Context, member *etcdclient.EtcdProcessMember) error {
147+
func (s *etcdClusterState) etcdRemoveMember(ctx context.Context, nodeInfo *etcdclient.EtcdProcessMember) error {
148148
for id, member := range s.members {
149149
etcdClient, err := s.newEtcdClient(member)
150150
if err != nil {
151151
klog.Warningf("unable to build client for member %s: %v", member.Name, err)
152152
continue
153153
}
154154

155-
err = etcdClient.RemoveMember(ctx, member)
155+
err = etcdClient.RemoveMember(ctx, nodeInfo)
156156
etcdclient.LoggedClose(etcdClient)
157157
if err != nil {
158158
klog.Warningf("Remove member call failed on %s: %v", id, err)
159159
continue
160160
}
161161
return nil
162162
}
163-
return fmt.Errorf("unable to reach any cluster member, when trying to remove member %s", member)
163+
return fmt.Errorf("unable to reach any cluster member, when trying to remove member %s", nodeInfo)
164164
}

0 commit comments

Comments
 (0)