k3s-io
/
k3s
mirror of https://github.com/k3s-io/k3s.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Remove node addresses from filter when node is deleted 

Signed-off-by: Brad Davidson <brad.davidson@rancher.com>
pull/13120/head
Brad Davidson 2025-10-22 18:38:51 +00:00 committed by Brad Davidson
parent 171644cf0c
commit 0d9ef273d8
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/cluster/address_controller.go
View File

@ -45,12 +45,19 @@ func (a *addressesHandler) filterCN(cns ...string) []string {
// sync updates the allowed address list to include addresses for the node
func (a *addressesHandler) sync(key string, node *v1.Node) (*v1.Node, error) {
if node != nil && (node.Labels[util.ControlPlaneRoleLabelKey] != "" || node.Labels[util.ETCDRoleLabelKey] != "") {
if node != nil && len(node.Status.Addresses) > 0 {
a.Lock()
defer a.Unlock()
for _, address := range node.Status.Addresses {
a.allowed.Insert(address.String())
addresses := make([]string, len(node.Status.Addresses))
for i, addr := range node.Status.Addresses {
addresses[i] = addr.Address
}
if node.DeletionTimestamp == nil && (node.Labels[util.ControlPlaneRoleLabelKey] != "" || node.Labels[util.ETCDRoleLabelKey] != "") {
a.allowed = a.allowed.Insert(addresses...)
} else {
a.allowed = a.allowed.Delete(addresses...)
}
}
return node, nil