@@ -31,10 +31,10 @@ func (k *K8s) EventNamespace(ns *Namespace, data *Namespace) (updateRequired boo
31
31
updateRequired = true
32
32
case MODIFIED :
33
33
nsStore := k .GetNamespace (data .Name )
34
- if updateRequired = nsStore .Equal (data ); ! updateRequired {
35
- return updateRequired
34
+ updateRequired = ! EqualMap (nsStore .Labels , data .Labels )
35
+ if updateRequired {
36
+ nsStore .Labels = utils .CopyMap (data .Labels )
36
37
}
37
- nsStore .Labels = utils .CopyMap (data .Labels )
38
38
case DELETED :
39
39
_ , ok := k .Namespaces [data .Name ]
40
40
if ok {
@@ -334,11 +334,13 @@ func (k *K8s) EventPublishService(ns *Namespace, data *Service) (updateRequired
334
334
oldService .Addresses = newService .Addresses
335
335
k .PublishServiceAddresses = newService .Addresses
336
336
k .UpdateAllIngresses = true
337
+ updateRequired = true
337
338
case ADDED :
338
339
if service , ok := ns .Services [data .Name ]; ok {
339
340
k .PublishServiceAddresses = data .Addresses
340
341
service .Addresses = data .Addresses
341
342
k .UpdateAllIngresses = true
343
+ updateRequired = true
342
344
return
343
345
}
344
346
logger .Errorf ("Publish service '%s/%s' not found" , data .Namespace , data .Name )
@@ -348,6 +350,7 @@ func (k *K8s) EventPublishService(ns *Namespace, data *Service) (updateRequired
348
350
k .PublishServiceAddresses = nil
349
351
service .Addresses = nil
350
352
k .UpdateAllIngresses = true
353
+ updateRequired = true
351
354
} else {
352
355
logger .Warningf ("Publish service '%s/%s' not registered with controller, cannot delete !" , data .Namespace , data .Name )
353
356
}
0 commit comments