mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-06 02:34:03 +00:00
Merge pull request #14250 from zhengguoyong/LoadBalancer
update createExternalLoadBalancer to createLoadBalancer
This commit is contained in:
commit
26fe0823d5
@ -320,9 +320,9 @@ func (s *ServiceController) createLoadBalancerIfNeeded(namespacedName types.Name
|
|||||||
|
|
||||||
// The load balancer doesn't exist yet, so create it.
|
// The load balancer doesn't exist yet, so create it.
|
||||||
s.eventRecorder.Event(service, "CreatingLoadBalancer", "Creating load balancer")
|
s.eventRecorder.Event(service, "CreatingLoadBalancer", "Creating load balancer")
|
||||||
err := s.createExternalLoadBalancer(service)
|
err := s.createLoadBalancer(service)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to create external load balancer for service %s: %v", namespacedName, err), retryable
|
return fmt.Errorf("Failed to create load balancer for service %s: %v", namespacedName, err), retryable
|
||||||
}
|
}
|
||||||
s.eventRecorder.Event(service, "CreatedLoadBalancer", "Created load balancer")
|
s.eventRecorder.Event(service, "CreatedLoadBalancer", "Created load balancer")
|
||||||
}
|
}
|
||||||
@ -368,7 +368,7 @@ func (s *ServiceController) persistUpdate(service *api.Service) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *ServiceController) createExternalLoadBalancer(service *api.Service) error {
|
func (s *ServiceController) createLoadBalancer(service *api.Service) error {
|
||||||
ports, err := getPortsForLB(service)
|
ports, err := getPortsForLB(service)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
Loading…
Reference in New Issue
Block a user