- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 340 for clusterIPs (0.61 sec)
-
tests/integration/pilot/analyze_test.go
t.Helper() if err := t.Clusters().Default().ApplyYAMLFiles(ns, filename); err != nil { t.Fatal(err) } t.Cleanup(func() { _ = t.Clusters().Default().DeleteYAMLFiles(ns, filename) }) } func TestMultiCluster(t *testing.T) { // nolint: staticcheck framework. NewTest(t). Run(func(t framework.TestContext) { if len(t.Environment().Clusters()) < 2 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 16.3K bytes - Viewed (0) -
pkg/test/framework/components/istio/config.go
// on remote clusters for integration tests IntegrationTestRemoteDefaultsIOP = "tests/integration/iop-remote-integration-test-defaults.yaml" // BaseIOP is the path of the base IstioOperator spec BaseIOP = "tests/integration/base.yaml" // IntegrationTestRemoteGatewaysIOP is the path of the default IstioOperator spec to use // to install gateways on remote clusters for integration tests
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 14.8K bytes - Viewed (0) -
tests/integration/pilot/istioctl_test.go
for _, cluster := range t.Clusters().Primaries() { cluster := cluster t.NewSubTest(cluster.StableName()).Run(func(t framework.TestContext) { istioCtl := istioctl.NewOrFail(t, t, istioctl.Config{Cluster: cluster}) var output string args := []string{"remote-clusters"} output, _ = istioCtl.InvokeOrFail(t, args) for _, otherName := range t.Clusters().Exclude(cluster).Names() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 15K bytes - Viewed (0) -
tests/integration/pilot/ingress_test.go
path: %s pathType: Prefix ` successChecker := check.And(check.OK(), check.ReachedClusters(t.AllClusters(), apps.B.Clusters())) failureChecker := check.Status(http.StatusNotFound) count := 2 * t.Clusters().Len() // TODO check all clusters were hit cases := []struct { name string path string prefixPath string call echo.CallOptions }{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
pkg/bootstrap/platform/gcp_test.go
GCEInstanceID: "instance", GCEInstanceTemplate: "instanceTemplate", GCEInstanceCreatedBy: "createdBy", GCPClusterURL: "https://container.googleapis.com/v1/projects/pid/locations/location/clusters/cluster", }, }, { "project id error", func() bool { return true }, func() (string, error) { return "", errors.New("error") }, func() (string, error) { return "npid", nil },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 00:37:33 UTC 2023 - 17.7K bytes - Viewed (0) -
tests/integration/security/reachability_test.go
expectedClusters := to.Clusters().ForNetworks(from.Config().Cluster.NetworkName()) if !check.IsDNSCaptureEnabled(t) && opts.To.Config().Headless { opts.Check = check.And(opts.Check, check.ReachedSourceCluster(t.Clusters())) } else { opts.Check = check.And(opts.Check, check.ReachedClusters(t.Clusters(), expectedClusters)) } } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 20.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
} } // normalizeClusters normalizes clusters to avoid duplicate clusters. This should be called // at the end before adding the cluster to list of clusters. func (cb *ClusterBuilder) normalizeClusters(clusters []*discovery.Resource) []*discovery.Resource { // resolve cluster name conflicts. there can be duplicate cluster names if there are conflicting service definitions.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/cluster_ops_by_policy.cc
} llvm::SmallVector<Cluster> clusters; for (auto &kv : root_clusters) { Cluster &cluster = kv.getSecond(); // Skip degenerate clusters formed by a single basic block argument. if (!cluster.operations.empty()) clusters.emplace_back(std::move(cluster)); } LLVM_DEBUG(llvm::dbgs() << "Found " << clusters.size() << " clusters\n"); return clusters; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 27.9K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter.go
clusterSpecifier.WeightedClusters.Clusters = append(clusterSpecifier.WeightedClusters.Clusters, &tcp.TcpProxy_WeightedCluster_ClusterWeight{ Name: clusterName, Weight: uint32(route.Weight), }) } } // For weighted clusters set hash policy if any of the upstream destinations have sourceIP. maybeSetHashPolicy(destinationRule, tcpProxy, "")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook_v1beta1_test.go
configTmpl: ` clusters: - cluster: certificate-authority: {{ .CA }} server: https://authz.example.com name: foobar users: - name: a cluster user: client-certificate: {{ .Cert }} client-key: {{ .Key }} `, wantErr: true, }, { msg: "multiple clusters with no context", configTmpl: ` clusters: - cluster: certificate-authority: {{ .CA }}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 22:41:27 UTC 2024 - 19.9K bytes - Viewed (0)