From e6d6409cf873b0eac47216ff6061387d9c38b002 Mon Sep 17 00:00:00 2001 From: xiongzhongliang Date: Tue, 2 Mar 2021 00:55:49 +0800 Subject: [PATCH] remove duplicated validation for service-cluster-ip-range --- cmd/kube-apiserver/app/options/options.go | 2 ++ cmd/kube-apiserver/app/server.go | 22 ++++------------------ 2 files changed, 6 insertions(+), 18 deletions(-) diff --git a/cmd/kube-apiserver/app/options/options.go b/cmd/kube-apiserver/app/options/options.go index a16bc5498c5..ab9c404b5a4 100644 --- a/cmd/kube-apiserver/app/options/options.go +++ b/cmd/kube-apiserver/app/options/options.go @@ -71,6 +71,8 @@ type ServerRunOptions struct { // of parsing ServiceClusterIPRange into actual values PrimaryServiceClusterIPRange net.IPNet SecondaryServiceClusterIPRange net.IPNet + // APIServerServiceIP is the first valid IP from PrimaryServiceClusterIPRange + APIServerServiceIP net.IP ServiceNodePortRange utilnet.PortRange SSHKeyfile string diff --git a/cmd/kube-apiserver/app/server.go b/cmd/kube-apiserver/app/server.go index 59413c4be1d..4968a253759 100644 --- a/cmd/kube-apiserver/app/server.go +++ b/cmd/kube-apiserver/app/server.go @@ -330,21 +330,6 @@ func CreateKubeAPIServerConfig( s.Logs.Apply() - serviceIPRange, apiServerServiceIP, err := controlplane.ServiceIPRange(s.PrimaryServiceClusterIPRange) - if err != nil { - return nil, nil, nil, err - } - - // defaults to empty range and ip - var secondaryServiceIPRange net.IPNet - // process secondary range only if provided by user - if s.SecondaryServiceClusterIPRange.IP != nil { - secondaryServiceIPRange, _, err = controlplane.ServiceIPRange(s.SecondaryServiceClusterIPRange) - if err != nil { - return nil, nil, nil, err - } - } - config := &controlplane.Config{ GenericConfig: genericConfig, ExtraConfig: controlplane.ExtraConfig{ @@ -357,9 +342,9 @@ func CreateKubeAPIServerConfig( Tunneler: nodeTunneler, - ServiceIPRange: serviceIPRange, - APIServerServiceIP: apiServerServiceIP, - SecondaryServiceIPRange: secondaryServiceIPRange, + ServiceIPRange: s.PrimaryServiceClusterIPRange, + APIServerServiceIP: s.APIServerServiceIP, + SecondaryServiceIPRange: s.SecondaryServiceClusterIPRange, APIServerServicePort: 443, @@ -611,6 +596,7 @@ func Complete(s *options.ServerRunOptions) (completedServerRunOptions, error) { } s.PrimaryServiceClusterIPRange = primaryServiceIPRange s.SecondaryServiceClusterIPRange = secondaryServiceIPRange + s.APIServerServiceIP = apiServerServiceIP if err := s.SecureServing.MaybeDefaultWithSelfSignedCerts(s.GenericServerRunOptions.AdvertiseAddress.String(), []string{"kubernetes.default.svc", "kubernetes.default", "kubernetes"}, []net.IP{apiServerServiceIP}); err != nil { return options, fmt.Errorf("error creating self-signed certificates: %v", err)