- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 547 for cluster1 (0.27 sec)
-
pkg/config/analysis/analyzers/multicluster_analyzers_test.go
return sa, nil } type fakeClientImpl struct { kube.CLIClient clusterID cluster.ID } func (f *fakeClientImpl) ClusterID() cluster.ID { return f.clusterID } func addStore(sa *local.IstiodAnalyzer, clusterName string, yamls []string) error { client := &fakeClientImpl{ CLIClient: kube.NewFakeClient(), clusterID: cluster.ID(clusterName), } // Gather test files
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/verify_no_outside_compilation_markers_pass_test.cc
func.func @main() -> () { %0 = "tf_device.cluster"() ({ "tf_device.launch"() ({ "tf.B"() : () -> () tf_device.return // end device }) {device = "/job:worker/replica:0/task:0/device:CPU:0"} : () -> () tf_device.return // end cluster }) {cluster_attr = "cluster_attr"} : () -> tensor<*xi32> func.return } })";
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/test/framework/components/zipkin/kube.go
if err != nil { return err } return nil } func newKube(ctx resource.Context, cfgIn Config) (Instance, error) { c := &kubeComponent{ cluster: ctx.Clusters().GetOrDefault(cfgIn.Cluster), } c.id = ctx.TrackResource(c) // Find the zipkin pod and service, and start forwarding a local port. cfg, err := istio.DefaultConfig(ctx) if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 19:29:38 UTC 2023 - 8K bytes - Viewed (0) -
pkg/test/framework/components/cluster/clusters.go
func (c Clusters) Default() Cluster { return c[0] } // GetOrDefault returns the given cluster if non-nil. Otherwise returns the first // Cluster in the list. func (c Clusters) GetOrDefault(cluster Cluster) Cluster { if cluster != nil { return cluster } return c.Default() } // GetByName returns the Cluster with the given name or nil if it is not in the list.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 4.7K 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) -
istioctl/pkg/writer/compare/cluster.go
} diff := difflib.UnifiedDiff{ FromFile: "Istiod Clusters", A: difflib.SplitLines(istiodBytes.String()), ToFile: "Envoy Clusters", B: difflib.SplitLines(envoyBytes.String()), Context: c.context, } text, err := difflib.GetUnifiedDiffString(diff) if err != nil { return err } if text != "" { fmt.Fprintln(c.w, "Clusters Don't Match") fmt.Fprintln(c.w, text) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 10:02:09 UTC 2024 - 1.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/cluster_outlining.mlir
} // CHECK: func private @[[CLUSTER]] // CHECK-SAME: () -> tensor<?xi32> // CHECK: %[[A_OUTPUT:[0-9]*]] = "tf.A"() // CHECK: return %[[A_OUTPUT]] // ----- // Tests cluster attributes are copied over to cluster_func. // CHECK-LABEL: func @cluster_attrs func.func @cluster_attrs() -> tensor<?xi32> { %0 = "tf_device.cluster"() ({ %1 = "tf.A"() : () -> tensor<?xi32>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 30 21:25:12 UTC 2024 - 4.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/tests/auto_clustering_test_helper.cc
} clusters[cluster][n->type_string()]++; cluster_size[cluster]++; } string result = absl::StrCat("Clustered nodes: ", clustered_nodes, "\nUnclustered nodes: ", cluster_size[kNoCluster], "\nNumber of clusters: ", clusters.size() - 1, "\n\n"); for (const auto& pair : clusters) { if (pair.first == kNoCluster) { absl::StrAppend(&result, "unclustered");
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 12:11:46 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/metrics-v3-cluster-config.go
"Reduced redundancy storage class parity") configStandardParityMD = NewGaugeMD(configStandardParity, "Standard storage class parity") ) // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config // such as standard and RRS parity. func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { clusterDriveMetrics, err := c.clusterDriveMetrics.Get() if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 1.5K bytes - Viewed (0)