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

Update kubernetes service on start for port changes

Browse Source
This commit is contained in:
Erik Wilson 2019-06-21 17:04:40 -07:00 committed by Rafael Breno
parent b6fa40d42e
commit e168f321f3
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/controlplane/controller/kubernetesservice/controller.go
View File

@ -89,6 +89,11 @@ func (c *Controller) Start(stopCh <-chan struct{}) {
runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync"))
return return
} }
// Service definition is reconciled during first run to correct port and type per expectations.
if err := c.UpdateKubernetesService(true); err != nil {
klog.Errorf("Unable to perform initial Kubernetes service initialization: %v", err)
}
// Reconcile during first run removing itself until server is ready. // Reconcile during first run removing itself until server is ready.
endpointPorts := createEndpointPortSpec(c.PublicServicePort, "https") endpointPorts := createEndpointPortSpec(c.PublicServicePort, "https")
if err := c.EndpointReconciler.RemoveEndpoints(kubernetesServiceName, c.PublicIP, endpointPorts); err == nil { if err := c.EndpointReconciler.RemoveEndpoints(kubernetesServiceName, c.PublicIP, endpointPorts); err == nil {