- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 143 for clusterIPs (0.24 sec)
-
cmd/kubeadm/app/phases/kubeconfig/kubeconfig.go
if currentConfig.Clusters[currentCluster].Server != config.Clusters[expectedCluster].Server { klog.Warningf("a kubeconfig file %q exists already but has an unexpected API Server URL: expected: %s, got: %s", kubeConfigFilePath, config.Clusters[expectedCluster].Server, currentConfig.Clusters[currentCluster].Server) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 27K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
} if out == nil { out = service.DeepCopy() } else { // If we are seeing the service for the second time, it means it is available in multiple clusters. mergeService(out, service, r) } } return out } // mergeService only merges two clusters' k8s services func mergeService(dst, src *model.Service, srcRegistry serviceregistry.Instance) { if !src.Ports.Equals(dst.Ports) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
"istio.io/istio/pkg/log" ) // Define experimental features here. var ( // FilterGatewayClusterConfig controls if a subset of clusters(only those required) should be pushed to gateways FilterGatewayClusterConfig = env.Register("PILOT_FILTER_GATEWAY_CLUSTER_CONFIG", false, "If enabled, Pilot will send only clusters that referenced in gateway virtual services attached to gateway").Get() SendUnhealthyEndpoints = atomic.NewBool(env.Register(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0) -
tests/integration/helm/upgrade/util.go
// for upgrade capability func performInPlaceUpgradeFunc(previousVersion string, isAmbient bool) func(framework.TestContext) { return func(t framework.TestContext) { cs := t.Clusters().Default().(*kubecluster.Cluster) h := helm.New(cs.Filename()) nsConfig := helmtest.DefaultNamespaceConfig t.CleanupConditionally(func() { // only need to do call this once as helm doesn't need to remove
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 14.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
weighted := make([]*route.WeightedCluster_ClusterWeight, 0) for _, dst := range in.Route { weight := &wrappers.UInt32Value{Value: uint32(dst.Weight)} if dst.Weight == 0 { // Ignore 0 weighted clusters if there are other clusters in the route. // But if this is the only cluster in the route, then add it as a cluster with weight 100 if len(in.Route) == 1 { weight.Value = uint32(100) } else { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
tests/integration/ambient/main_test.go
ztunnel: terminationGracePeriodSeconds: 5 env: SECRET_TTL: 5m ` }, cert.CreateCASecretAlt)). Setup(func(t resource.Context) error { gatewayConformanceInputs.Client = t.Clusters().Default() gatewayConformanceInputs.Cleanup = !t.Settings().NoCleanup return nil }). Setup(func(t resource.Context) error { return SetupApps(t, i, apps) }). Setup(testRegistrySetup).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
func (f fakeInstance) WorkloadsOrFail(test.Failer) echo.Workloads { panic("implement me") } func (f fakeInstance) MustWorkloads() echo.Workloads { panic("implement me") } func (f fakeInstance) Clusters() cluster.Clusters { panic("implement me") } func (f fakeInstance) Call(echo.CallOptions) (echo.CallResult, error) { panic("implement me") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
tests/integration/telemetry/api/dashboard_test.go
for _, d := range dashboards { d := d t.NewSubTest(d.name).Run(func(t framework.TestContext) { for _, cl := range t.Clusters() { if !cl.IsPrimary() && d.requirePrimary { // Skip verification of dashboards that won't be present on non primary(remote) clusters. continue } t.Logf("Verifying %s for cluster %s", d.name, cl.Name())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig_test.go
if !exists { t.Fatal("failed to find CurrentContext in Contexts of the kubeconfig") } if configWithSameClusterCaByExternalFile.Clusters[currentCtx.Cluster] == nil { t.Fatal("failed to find the given CurrentContext Cluster in Clusters of the kubeconfig") } tmpfile, err := os.CreateTemp("", "external-ca.crt") if err != nil { t.Fatal(err) } defer os.Remove(tmpfile.Name())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 39.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook_v1_test.go
configTmpl: ` clusters: - cluster: certificate-authority: {{ .CA }} server: https://authz.example.com name: foobar users: - name: a cluster user: client-certificate: {{ .Cert }} client-key: {{ .Key }} `, wantErr: true, }, { msg: "multiple clusters with no context", configTmpl: ` clusters: - cluster:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.2K bytes - Viewed (0)