| // Copyright Istio Authors. |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| package k8sversion |
| |
| import ( |
| "fmt" |
| ) |
| |
| import ( |
| goversion "github.com/hashicorp/go-version" |
| pkgVersion "istio.io/pkg/version" |
| "k8s.io/apimachinery/pkg/version" |
| ) |
| |
| import ( |
| "github.com/apache/dubbo-go-pixiu/operator/pkg/util/clog" |
| "github.com/apache/dubbo-go-pixiu/pkg/kube" |
| ) |
| |
| const ( |
| // MinK8SVersion is the minimum k8s version required to run this version of Istio |
| // https://istio.io/docs/setup/platform-setup/ |
| MinK8SVersion = 19 |
| UnSupportedK8SVersionLogMsg = "\nThe Kubernetes version %s is not supported by Istio %s. The minimum supported Kubernetes version is 1.%d.\n" + |
| "Proceeding with the installation, but you might experience problems. " + |
| "See https://istio.io/latest/docs/setup/platform-setup/ for a list of supported versions.\n" |
| ) |
| |
| // CheckKubernetesVersion checks if this Istio version is supported in the k8s version |
| func CheckKubernetesVersion(versionInfo *version.Info) (bool, error) { |
| v, err := extractKubernetesVersion(versionInfo) |
| if err != nil { |
| return false, err |
| } |
| return MinK8SVersion <= v, nil |
| } |
| |
| // extractKubernetesVersion returns the Kubernetes minor version. For example, `v1.19.1` will return `19` |
| func extractKubernetesVersion(versionInfo *version.Info) (int, error) { |
| ver, err := goversion.NewVersion(versionInfo.String()) |
| if err != nil { |
| return 0, fmt.Errorf("could not parse %v", err) |
| } |
| // Segments provide slice of int eg: v1.19.1 => [1, 19, 1] |
| num := ver.Segments()[1] |
| return num, nil |
| } |
| |
| // IsK8VersionSupported checks minimum supported Kubernetes version for Istio. |
| // If the K8s version is not atleast the `MinK8SVersion`, it logs a message warning the user that they |
| // may experience problems if they proceed with the install. |
| func IsK8VersionSupported(c kube.Client, l clog.Logger) error { |
| serverVersion, err := c.GetKubernetesVersion() |
| if err != nil { |
| return fmt.Errorf("error getting Kubernetes version: %w", err) |
| } |
| if !kube.IsAtLeastVersion(c, MinK8SVersion) { |
| l.LogAndPrintf(UnSupportedK8SVersionLogMsg, serverVersion.GitVersion, pkgVersion.Info.Version, MinK8SVersion) |
| } |
| return nil |
| } |