- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,338 for cluster0 (0.15 sec)
-
tests/integration/pilot/revisions/uninstall_test.go
}, retry.Delay(checkResourceDelay), retry.Timeout(checkResourceTimeout)) } // getRemainingResourcesCluster get specific resources from the cluster func getRemainingResourcesCluster(cs cluster.Cluster, gvr schema.GroupVersionResource, ls string) ([]unstructured.Unstructured, []string) { usList, _ := cs.Dynamic().Resource(gvr).List(context.TODO(), metav1.ListOptions{LabelSelector: ls})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.8K bytes - Viewed (0) -
tests/integration/telemetry/tracing/otelcollector/tracing_test.go
for _, cluster := range ctx.Clusters().ByNetwork()[ctx.Clusters().Default().NetworkName()] { cluster := cluster ctx.NewSubTest(cluster.StableName()).Run(func(ctx framework.TestContext) { retry.UntilSuccessOrFail(ctx, func() error { err := tracing.SendTraffic(ctx, nil, cluster) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 22:56:30 UTC 2024 - 5.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/internal/passes/xla_cluster_formation.cc
cluster.getBody().push_back(new Block); call_op->replaceAllUsesWith(cluster.getResults()); call_op->moveBefore(&cluster.GetBody(), cluster.GetBody().end()); builder.setInsertionPointToEnd(&cluster.GetBody()); builder.create<mlir::tf_device::ReturnOp>(call_op->getLoc(), call_op->getResults()); // Propagate necessary attributes to the cluster so that when it's outlined,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Dec 19 19:09:44 UTC 2023 - 6K bytes - Viewed (0) -
pkg/test/framework/components/cluster/topology.go
} func (c Topology) Primary() Cluster { cluster, ok := c.AllClusters[c.PrimaryClusterName] if !ok || cluster == nil { panic(fmt.Errorf("cannot find %s, the primary cluster for %s", c.PrimaryClusterName, c.Name())) } return cluster } func (c Topology) PrimaryName() string { return c.PrimaryClusterName } func (c Topology) Config() Cluster { cluster, ok := c.AllClusters[c.ConfigClusterName]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.5K bytes - Viewed (0) -
prow/lib.sh
fi # https://docs.tilt.dev/choosing_clusters.html#discovering-the-registry for cluster in $(kind get clusters); do # TODO get context/config from existing variables kind export kubeconfig --name="${cluster}" for node in $(kind get nodes --name="${cluster}"); do kubectl annotate node "${node}" "kind.x-k8s.io/registry=localhost:${KIND_REGISTRY_PORT}" --overwrite; done done
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 8.1K bytes - Viewed (0) -
tests/integration/telemetry/api/customize_metrics_test.go
httpMetricVal, err = util.QueryPrometheus(t, cluster, httpDestinationQuery, promInst) if err != nil { util.PromDiff(t, promInst, cluster, httpDestinationQuery) return err } httpChecked = true } _, err = util.QueryPrometheus(t, cluster, grpcDestinationQuery, promInst) if err != nil { util.PromDiff(t, promInst, cluster, grpcDestinationQuery) return err } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/test/framework/test.go
// max clusters doesn't check kube only, the test may be written in a way that doesn't loop over all of Clusters() if t.requiredMaxClusters > 0 && len(t.s.Environment().Clusters()) > t.requiredMaxClusters { t.goTest.Skipf("Skipping %q: number of clusters %d is above required max %d", t.goTest.Name(), len(t.s.Environment().Clusters()), t.requiredMaxClusters) return } if t.minKubernetesMinorVersion > 0 { for _, c := range ctx.Clusters() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 10.3K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
"MeshConfig are excluded.", ).Get() EnableMCSServiceDiscovery = env.Register( "ENABLE_MCS_SERVICE_DISCOVERY", false, "If enabled, istiod will enable Kubernetes Multi-Cluster "+ "Services (MCS) service discovery mode. In this mode, service "+ "endpoints in a cluster will only be discoverable within the "+ "same cluster unless explicitly exported via ServiceExport.").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/utils/cluster_util_test.cc
auto clusters = GetClusters(module.get()); constexpr StringRef kTarget0 = "tpu0"; EXPECT_EQ(clusters.count(kTarget0), 1); EXPECT_EQ(clusters[kTarget0].size(), 1); EXPECT_EQ(clusters[kTarget0][0].ops.size(), 2); constexpr StringRef kTarget1 = "tpu1"; EXPECT_EQ(clusters.count(kTarget1), 1); EXPECT_EQ(clusters[kTarget1].size(), 1);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Apr 26 09:37:10 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/test/framework/components/istio/config.go
// before running tests. DeployEastWestGW bool // DumpKubernetesManifests will cause Kubernetes YAML generated by istioctl install/generate to be dumped to artifacts. DumpKubernetesManifests bool // IstiodlessRemotes makes remote clusters run without istiod, using webhooks/ca from the primary cluster. // TODO we could set this per-cluster if istiod was smarter about patching remotes.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 14.8K bytes - Viewed (0)