github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-15 14:14:39 +00:00
Code Issues Projects Releases Wiki Activity

Svc REST: rename allocUpdateServiceNodePortsNew

Browse Source
This commit is contained in:
Tim Hockin
2021-08-24 22:04:50 -07:00
parent bb815e6687
commit 7d9357b181
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -180,7 +180,7 @@ func (al *RESTAllocStuff) allocateUpdate(service, oldService *api.Service, dryRu
} }
// Allocate ports // Allocate ports
if txn, err := al.allocUpdateServiceNodePortsNew(service, oldService, dryRun); err != nil { if txn, err := al.txnUpdateNodePorts(service, oldService, dryRun); err != nil {
result.Revert() result.Revert()
return nil, err return nil, err
} else { } else {
@@ -190,8 +190,7 @@ func (al *RESTAllocStuff) allocateUpdate(service, oldService *api.Service, dryRu
return result, nil return result, nil
} }
//FIXME: rename and merge with updateNodePorts? func (al *RESTAllocStuff) txnUpdateNodePorts(service, oldService *api.Service, dryRun bool) (transaction, error) {
func (al *RESTAllocStuff) allocUpdateServiceNodePortsNew(service, oldService *api.Service, dryRun bool) (transaction, error) {
// The allocator tracks dry-run-ness internally. // The allocator tracks dry-run-ness internally.
nodePortOp := portallocator.StartOperation(al.serviceNodePorts, dryRun) nodePortOp := portallocator.StartOperation(al.serviceNodePorts, dryRun)