- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 2,006 for cluster0 (0.28 sec)
-
pkg/test/framework/components/echo/kube/sidecar.go
) var _ echo.Sidecar = &sidecar{} type sidecar struct { podNamespace string podName string cluster cluster.Cluster } func newSidecar(pod corev1.Pod, cluster cluster.Cluster) *sidecar { sidecar := &sidecar{ podNamespace: pod.Namespace, podName: pod.Name, cluster: cluster, } return sidecar } func (s *sidecar) Info() (*admin.ServerInfo, error) { msg := &admin.ServerInfo{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 09 03:49:49 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/settings.go
// controlPlaneTopology maps each cluster to the cluster that runs its control plane. For replicated control // plane cases (where each cluster has its own control plane), the cluster will map to itself (e.g. 0->0). controlPlaneTopology clusterTopology // networkTopology is used for the initial assignment of networks to each cluster. // The source of truth clusters' networks is the Cluster instances themselves, rather than this field.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/cds.go
subsetClusters := b.applyDestinationRule(defaultCluster) out := make([]*cluster.Cluster, 0, 1+len(subsetClusters)) if defaultCluster != nil { out = append(out, defaultCluster) } return append(out, subsetClusters...) } // edsCluster creates a simple cluster to read endpoints from ads/eds. func edsCluster(name string) *cluster.Cluster { return &cluster.Cluster{ Name: name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 9.2K bytes - Viewed (0) -
tests/integration/pilot/workloadentry_test.go
} gatewayAddresses := map[string]gwAddr{} for _, cluster := range t.Clusters() { if _, ok := gatewayAddresses[cluster.NetworkName()]; ok { continue } ips, ports := i.EastWestGatewayFor(cluster).AddressesForPort(15443) if ips != nil { gatewayAddresses[cluster.NetworkName()] = gwAddr{ips[0], ports[0]} } } if len(t.Clusters().Networks()) != len(gatewayAddresses) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.1K bytes - Viewed (0) -
tensorflow/compiler/jit/encapsulate_subgraphs_pass_test.cc
"_cluster", graph_before_encapsulation, /*rewrite_subgraph_fn=*/{}, /*reuse_existing_functions=*/false, &graph, &library)); std::vector<string> expected_nodes = {"cluster1", "cluster2", "mul", "x"}; EXPECT_EQ(expected_nodes, GraphNodes(*graph)); std::vector<std::pair<string, string>> expected_edges = { {"cluster1:0", "cluster2:0"}, {"cluster1:0", "mul:0"},
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 113.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/tpu_host_computation_expansion.mlir
func.func @identity_at_head_expanded(%arg0: tensor<?xi32>) { // CHECK: "tf_device.cluster" // CHECK-NEXT: "tf.Identity" // CHECK-SAME: _xla_outside_compilation = "" "tf_device.cluster"() ({ %1 = "tf.Identity"(%arg0) : (tensor<?xi32>) -> (tensor<?xi32>) "tf.B"(%1) {_xla_outside_compilation = "cluster1"} : (tensor<?xi32>) -> () "tf.C"() : () -> () tf_device.return }) : () -> () func.return }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Mar 28 12:06:33 UTC 2022 - 3.2K bytes - Viewed (0) -
pkg/test/framework/resource/context.go
CreateTmpDirectory(prefix string) (string, error) // ConfigKube returns a Context that writes config to the provided clusters. If // no clusters are provided, writes to all clusters in the mesh. ConfigKube(clusters ...cluster.Cluster) config.Factory // ConfigIstio returns a Context that writes config to all Istio config clusters. ConfigIstio() config.Factory // RecordTraceEvent records an event. This is later saved to trace.yaml for analysis
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 3.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/run.go
ctx.Skipf("no gateway for %s", fromCluster.StableName()) } testFn(ctx, gwIngress, dst) } if len(ctx.Clusters()) == 1 { doTest(ctx, ctx.Clusters()[0], dstInstances) } else { t.fromEachCluster(ctx, func(ctx framework.TestContext, c cluster.Cluster) { doTest(ctx, c, dstInstances) }) } }) } func (t *T) RunViaIngress(testFn ingressTest) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 27 22:08:42 UTC 2023 - 13K bytes - Viewed (0) -
tools/bug-report/pkg/bugreport/bugreport.go
} getClusterResourcesCancel() }() resources, err := cluster2.GetClusterResources(clusterResourcesCtx, clientset, config) if err != nil { return err } logRuntime(curTime, "Done collecting cluster resource") dumpRevisionsAndVersions(ctx, resources, config.IstioNamespace, config.DryRun) log.Infof("Cluster resource tree:\n\n%s\n\n", resources)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 20:57:29 UTC 2024 - 20.7K bytes - Viewed (0) -
pkg/test/framework/config.go
type configFactory struct { ctx resource.Context clusters []cluster.Cluster prefix string } func newConfigFactory(ctx resource.Context, clusters cluster.Clusters) config.Factory { if len(clusters) == 0 { clusters = ctx.Clusters() } return &configFactory{ ctx: ctx, clusters: clusters, } } // GlobalYAMLWrites records how many YAMLs we have applied from all sources.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.2K bytes - Viewed (0)