Skip to content

K
k3s
Commit ab7f726e authored by Erik Wilson's avatar Erik Wilson
Browse files
Options

Update kubernetes service on start for port changes

parent 7a8ccac0
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
pkg/master/controller.go
View file @ ab7f726e
...@@ -142,6 +142,10 @@ func (c *Controller) Start() { ...@@ -142,6 +142,10 @@ func (c *Controller) Start() {
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", c.ExtraEndpointPorts) endpointPorts := createEndpointPortSpec(c.PublicServicePort, "https", c.ExtraEndpointPorts)
if err := c.EndpointReconciler.RemoveEndpoints(kubernetesServiceName, c.PublicIP, endpointPorts); err != nil { if err := c.EndpointReconciler.RemoveEndpoints(kubernetesServiceName, c.PublicIP, endpointPorts); err != nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment