- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 807 for cluster1 (0.21 sec)
-
cmd/kubeadm/app/util/kubeconfig/kubeconfig.go
// file and eventually embeds it into the kubeconfig func EnsureCertificateAuthorityIsEmbedded(cluster *clientcmdapi.Cluster) error { if cluster == nil { return errors.New("received nil value for Cluster") } if len(cluster.CertificateAuthorityData) == 0 && len(cluster.CertificateAuthority) != 0 { ca, err := os.ReadFile(cluster.CertificateAuthority) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 10:21:33 UTC 2024 - 7.2K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/client_tracing_test.go
func TestClientTracing(t *testing.T) { framework.NewTest(t). Run(func(t framework.TestContext) { appNsInst := tracing.GetAppNamespace() for _, cluster := range t.Clusters().ByNetwork()[t.Clusters().Default().NetworkName()] { cluster := cluster t.NewSubTest(cluster.StableName()).Run(func(ctx framework.TestContext) { retry.UntilSuccessOrFail(ctx, func() error { // Send test traffic with a trace header.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.4K bytes - Viewed (0) -
tests/integration/pilot/gw_topology_test.go
`).ApplyOrFail(t, apply.NoCleanup) cs := t.Clusters().Default().(*kubecluster.Cluster) retry.UntilSuccessOrFail(t, func() error { _, err := kubetest.CheckPodsAreReady(kubetest.NewPodFetch(cs, gatewayNs.Name(), "istio=ingressgateway")) return err }, retry.Timeout(time.Minute*2), retry.Delay(time.Second)) for _, tt := range common.XFFGatewayCase(&apps, fmt.Sprintf("custom-gateway.%s.svc.cluster.local", gatewayNs.Name())) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8K bytes - Viewed (0) -
tests/integration/pilot/piggyback_test.go
output, _, err := istioCtl.Invoke(args) if err != nil { return err } return expectSubstrings(output, "Clusters Match", "Listeners Match", "Routes Match") }) // Test gRPC-based tapped XDS using istioctl. retry.UntilSuccessOrFail(t, func() error { pf, err := t.Clusters()[0].NewPortForwarder(podName, namespace, "localhost", 0, 15004) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matchers_test.go
} var ( allClusters = make(cluster.Map) // 2 clusters on 2 networks cls1 = &kube.Cluster{Topology: cluster.Topology{ ClusterName: "cls1", Network: "n1", PrimaryClusterName: "cls1", ConfigClusterName: "cls1", Index: 0, AllClusters: allClusters, }} // simple pod a1 = &fakeInstance{Cluster: cls1, Namespace: namespace.Static("echo"), Service: "a"}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/utils/cluster_util.cc
// of same target. If that is infeasible (say because of violating // def-before-use), create a new cluster with that operation and move on. llvm::StringMap<SmallVector<Cluster>> all_clusters; // Map from operation to the cluster that contains the operation. llvm::DenseMap<Operation*, Cluster*> op_to_cluster_map; llvm::StringMap<Cluster> nearest_clusters;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jul 28 00:32:55 UTC 2023 - 8.3K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/server_tracing_test.go
appNsInst := tracing.GetAppNamespace() for _, cluster := range t.Clusters().ByNetwork()[t.Clusters().Default().NetworkName()] { t.NewSubTest(cluster.StableName()).Run(func(t framework.TestContext) { retry.UntilSuccessOrFail(t, func() error { err := tracing.SendTraffic(t, nil, cluster) if err != nil { return fmt.Errorf("cannot send traffic from cluster %s: %v", cluster.Name(), err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tpu_identity_pruning.cc
}); } void TPUIdentityPruning::runOnOperation() { SmallVector<tf_device::ClusterOp, 4> clusters; getOperation().walk( [&](tf_device::ClusterOp cluster) { clusters.push_back(cluster); }); for (tf_device::ClusterOp cluster : clusters) { RemoveIdentityFromRegion(cluster.getBody()); auto reachable_funcs = CollectReachableFunctions(cluster.getBody()); for (func::FuncOp reachable_func : reachable_funcs)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Oct 05 23:50:19 UTC 2022 - 4.1K bytes - Viewed (0) -
releasenotes/notes/jwks-cluster.yaml
dwq <******@****.***> 1702032306 +0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 10:45:06 UTC 2023 - 296 bytes - Viewed (0) -
istioctl/pkg/workload/testdata/vmconfig-nil-proxy-metadata/cluster.env.golden
Xiaopeng Han <******@****.***> 1686841337 +0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 546 bytes - Viewed (0)