github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 21:47:07 +00:00
Code Issues Projects Releases Wiki Activity

Svc REST: rename healthCheckNodePortUpdate

Browse Source
This commit is contained in:
Tim Hockin 2021-08-24 22:16:53 -07:00
parent 5dfcb905d1
commit 6b06b9bfd3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/registry/core/service/storage/rest.go
View File

@ -131,9 +131,9 @@ func shouldAllocateNodePorts(service *api.Service) bool {
return false return false
} }
// healthCheckNodePortUpdate handles HealthCheckNodePort allocation/release // updateHealthCheckNodePort handles HealthCheckNodePort allocation/release
// and adjusts HealthCheckNodePort during service update if needed. // and adjusts HealthCheckNodePort during service update if needed.
func (al *RESTAllocStuff) healthCheckNodePortUpdate(oldService, service *api.Service, nodePortOp *portallocator.PortAllocationOperation) (bool, error) { func (al *RESTAllocStuff) updateHealthCheckNodePort(oldService, service *api.Service, nodePortOp *portallocator.PortAllocationOperation) (bool, error) {
neededHealthCheckNodePort := apiservice.NeedsHealthCheck(oldService) neededHealthCheckNodePort := apiservice.NeedsHealthCheck(oldService)
oldHealthCheckNodePort := oldService.Spec.HealthCheckNodePort oldHealthCheckNodePort := oldService.Spec.HealthCheckNodePort
@ -222,7 +222,7 @@ func (al *RESTAllocStuff) txnUpdateNodePorts(service, oldService *api.Service, d
} }
// Handle ExternalTraffic related updates. // Handle ExternalTraffic related updates.
success, err := al.healthCheckNodePortUpdate(oldService, service, nodePortOp) success, err := al.updateHealthCheckNodePort(oldService, service, nodePortOp)
if !success || err != nil { if !success || err != nil {
txn.Revert() txn.Revert()
return nil, err return nil, err