- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for IsAtLeastVersion (0.26 sec)
-
pkg/kube/version.go
"fmt" "strconv" "k8s.io/apimachinery/pkg/util/version" kubeVersion "k8s.io/apimachinery/pkg/version" ) // IsAtLeastVersion returns true if the client is at least the specified version. // For example, on Kubernetes v1.15.2, IsAtLeastVersion(13) == true, IsAtLeastVersion(17) == false func IsAtLeastVersion(client Client, minorVersion uint) bool { clusterVersion, err := client.GetKubernetesVersion() if err != nil { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 23:16:29 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/kube/version_test.go
want: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { cl := NewFakeClientWithVersion(fmt.Sprint(tt.clusterVersion)) if got := IsAtLeastVersion(cl, tt.minorVersion); got != tt.want { t.Errorf("IsAtLeastVersion() = %v, want %v", got, tt.want) } }) } } func TestIsLessThanVersionVersion(t *testing.T) { tests := []struct { name string clusterVersion uint
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 23:16:29 UTC 2024 - 3.1K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version.go
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
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 22 02:07:51 UTC 2024 - 2.6K bytes - Viewed (0) -
operator/pkg/util/k8s.go
ver, err := client.GetKubernetesVersion() if err != nil { return fmt.Errorf("failed to determine support for K8s legacy signer. Use the --force flag to ignore this: %v", err) } if kube.IsAtLeastVersion(client, 22) { return fmt.Errorf("configuration PILOT_CERT_PROVIDER=%s not supported in Kubernetes %v."+ "Please pick another value for PILOT_CERT_PROVIDER", ca, ver.String()) } } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/test/framework/components/cluster/topology.go
c.ConfigClusterName = configClusterName return c } func (c Topology) MinKubeVersion(minor uint) bool { cluster := c.AllClusters[c.ClusterName] return kube.IsAtLeastVersion(cluster, minor) } func (c Topology) MaxKubeVersion(minor uint) bool { cluster := c.AllClusters[c.ClusterName] return kube.IsLessThanVersion(cluster, minor+1) } func (c Topology) String() string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/test/framework/suite.go
for _, c := range ctx.Clusters() { ver, err := c.GetKubernetesVersion() if err != nil { return fmt.Errorf("failed to get Kubernetes version: %v", err) } if !kubelib.IsAtLeastVersion(c, minorVersion) { s.Skip(fmt.Sprintf("Required Kubernetes version (1.%v) is greater than current: %v", minorVersion, ver.String())) } } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.2K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
// Create the service account if it doesn't exist. serviceAccount, err := getOrCreateServiceAccount(client, opt) if err != nil { return nil, err } if !kube.IsAtLeastVersion(client, 24) { return legacyGetServiceAccountSecret(serviceAccount, client, opt) } return getOrCreateServiceAccountSecret(serviceAccount, client, opt) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 11 01:43:17 UTC 2023 - 24K bytes - Viewed (0)