- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,315 for cluster_ (0.74 sec)
-
pkg/kube/client_config.go
Kind: "Config", APIVersion: "v1", Preferences: api.Preferences{}, Clusters: map[string]*api.Cluster{ clusterName: newCluster(&c.restConfig), }, AuthInfos: map[string]*api.AuthInfo{ authInfoName: newAuthInfo(&c.restConfig), }, Contexts: map[string]*api.Context{ contextName: { Cluster: clusterName, AuthInfo: authInfoName, }, }, CurrentContext: contextName, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 17 16:52:06 UTC 2020 - 3.1K bytes - Viewed (0) -
pkg/kube/multicluster/cluster.go
"istio.io/istio/pilot/pkg/features" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/kclient" filter "istio.io/istio/pkg/kube/namespace" "istio.io/istio/pkg/log" ) // Cluster defines cluster struct type Cluster struct { // ID of the cluster. ID cluster.ID // Client for accessing the cluster. Client kube.Client kubeConfigSha [sha256.Size]byte
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/test/framework/components/istio/cleanup.go
} if i.cfg.DeployIstio { errG := multierror.Group{} // Make sure to clean up primary clusters before remotes, or istiod will recreate some of the CMs that we delete // in the remote clusters before it's deleted. for _, c := range i.ctx.AllClusters().Primaries() { i.cleanupCluster(c, &errG) } for _, c := range i.ctx.Clusters().Remotes() { i.cleanupCluster(c, &errG) } return errG.Wait().ErrorOrNil() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass_test.cc
auto clusters = GetClusters(*graph); EXPECT_EQ(4, clusters.size()); EXPECT_EQ(clusters["B"], clusters["C"]); EXPECT_EQ(clusters["E"], clusters["F"]); EXPECT_NE(clusters["B"], clusters["E"]); EXPECT_TRUE(clusters.find("A") == clusters.cend()); EXPECT_TRUE(clusters.find("D") == clusters.cend()); } TEST(XlaCompilationTest, UncompilableCycles) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 10:11:10 UTC 2024 - 79.6K bytes - Viewed (0) -
pkg/kube/inject/webhook_test.go
{ name: "one-kv", in: "/inject/cluster/cluster1", want: map[string]string{"ISTIO_META_CLUSTER_ID": "cluster1"}, }, { name: "two-kv", in: "/inject/cluster/cluster1/net/network1/", want: map[string]string{"ISTIO_META_CLUSTER_ID": "cluster1", "ISTIO_META_NETWORK": "network1"}, }, { name: "kv-with-slashes", in: "/inject/cluster/cluster--slash--1/net/network--slash--1",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 39K bytes - Viewed (1) -
istioctl/pkg/writer/pilot/testdata/multiXdsStatusSinglePilot.txt
NAME CLUSTER CDS LDS EDS RDS ECDS ISTIOD VERSION proxy1 cluster1 STALE SYNCED SYNCED NOT SENT NOT SENT istiod1 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 300 bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
return f.ConfigGen.BuildListeners(p, f.PushContext()) } func (f *ConfigGenTest) Clusters(p *model.Proxy) []*cluster.Cluster { raw, _ := f.ConfigGen.BuildClusters(p, &model.PushRequest{Push: f.PushContext()}) res := make([]*cluster.Cluster, 0, len(raw)) for _, r := range raw { c := &cluster.Cluster{} if err := r.Resource.UnmarshalTo(c); err != nil { f.t.Fatal(err) } res = append(res, c) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/cluster.go
func FetchInitConfigurationFromCluster(client clientset.Interface, printer output.Printer, logPrefix string, newControlPlane, skipComponentConfigs bool) (*kubeadmapi.InitConfiguration, error) { if printer == nil { printer = &output.TextPrinter{} } printer.Printf("[%s] Reading configuration from the cluster...\n", logPrefix)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 11K bytes - Viewed (0) -
pkg/test/framework/components/cluster/cluster.go
PrimaryName() string // Config returns the config cluster for this cluster. Will return itself if // IsConfig. Config() Cluster // ConfigName returns the name of the config cluster for this cluster. ConfigName() string // HTTPProxy returns the HTTP proxy config to connect to the cluster HTTPProxy() string // Metadata returns the value for a given metadata key for the cluster.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 3K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
func (p clusterPatcher) conditionallyAppend(l []*cluster.Cluster, hosts []host.Name, clusters ...*cluster.Cluster) []*cluster.Cluster { if !p.hasPatches() { return append(l, clusters...) } for _, c := range clusters { if patched := p.doPatch(hosts, c); patched != nil { l = append(l, patched) } } return l } func (p clusterPatcher) insertedClusters() []*cluster.Cluster {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0)