- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 248 for cluster2b (0.32 sec)
-
pilot/pkg/xds/endpoints/ep_filters_test.go
Weight: 42, }, }, wantWorkloadMetadata: []string{ ";ns;example;;cluster1a", ";ns;example;;cluster1a", ";ns;example;;cluster1b", ";ns;example;;cluster4", ";;;;cluster2a", ";;;;cluster2b", ";;;;cluster2b", }, }, { name: "from_network1_cluster1b", proxy: makeProxy("network1", "cluster1b"), want: []xdstest.LocLbEpInfo{ { LbEps: []xdstest.LbEpInfo{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0) -
tensorflow/compiler/jit/partially_decluster_pass_test.cc
builder.opts().WithName("ClusteredConsumer")); clustered_producer->AddAttr(kXlaClusterAttr, "cluster_0"); clustered_consumer->AddAttr(kXlaClusterAttr, "cluster_0"); consumer_in_different_cluster->AddAttr(kXlaClusterAttr, "cluster_1"); TF_EXPECT_OK(GraphDefBuilderToGraph(builder, graph.get())); } TF_ASSERT_OK(PartiallyDecluster(&graph)); std::vector<Node*> inputs;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 10 12:32:39 UTC 2022 - 23K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
registry2Counter := atomic.NewInt32(0) for _, r := range registries { counter := atomic.NewInt32(0) clusterID := r.Cluster() if clusterID == "cluster1" { counter = registry1Counter } if clusterID == "cluster2" { counter = registry2Counter } ctrl.AppendServiceHandlerForCluster(clusterID, func(_, curr *model.Service, event model.Event) { counter.Add(1) }) ctrl.AddRegistry(r) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pilot/pkg/model/service_test.go
{ first: &Service{ ClusterVIPs: AddressMap{ Addresses: map[cluster.ID][]string{ "cluster-1": {"c1-vip1,c1-vip2"}, "cluster-2": {"c2-vip1,c2-vip2"}, }, }, }, other: &Service{ ClusterVIPs: AddressMap{ Addresses: map[cluster.ID][]string{ "cluster-1": {"c1-vip1,c1-vip2"}, "cluster-2": {"c2-vip1,c2-vip2"}, }, }, }, shouldEq: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 20:38:02 UTC 2024 - 13.9K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
var expectedClusters cluster.Clusters if ht == hostTypeClusterLocal { // Ensure that all requests to cluster.local stay in the same cluster expectedClusters = cluster.Clusters{from.Config().Cluster} } else { // Ensure that requests to clusterset.local reach all destination clusters. expectedClusters = to.Clusters() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
clusterID := srcRegistry.Cluster() if len(dst.ClusterVIPs.GetAddressesFor(clusterID)) == 0 { newAddresses := src.ClusterVIPs.GetAddressesFor(clusterID) dst.ClusterVIPs.SetAddressesFor(clusterID, newAddresses) } } // NetworkGateways merges the service-based cross-network gateways from each registry. func (c *Controller) NetworkGateways() []model.NetworkGateway { var gws []model.NetworkGateway
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
tools/bug-report/pkg/cluster/cluster.go
out.Pod[PodKey(p.Namespace, p.Name)] = &pods.Items[i] } return out, nil } // Resources defines a tree of cluster resource names. type Resources struct { // Root is the first level in the cluster resource hierarchy. // Each level in the hierarchy is a map[string]interface{} to the next level. // The levels are: namespaces/deployments/pods/containers. Root map[string]any
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 14 02:11:31 UTC 2023 - 10.9K bytes - Viewed (1) -
pilot/pkg/serviceregistry/kube/conversion_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/api/annotation" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/config/kube" "istio.io/istio/pkg/config/protocol" ) var ( domainSuffix = "company.com" clusterID = cluster.ID("test-cluster") ) func TestConvertProtocol(t *testing.T) { http := "http" type protocolCase struct { port int32
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/cluster_ops_by_policy.cc
cluster.constraints = std::move(member.constraints); // Add operation to the cluster. if (auto op = member.source.dyn_cast<Operation *>()) cluster.operations.emplace_back(op); } llvm::SmallVector<Cluster> clusters; for (auto &kv : root_clusters) { Cluster &cluster = kv.getSecond(); // Skip degenerate clusters formed by a single basic block argument.
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/xds/xds_test.go
serviceCluster string wantClusterLocal map[cluster.ID][]string wantNonClusterLocal map[cluster.ID][]string }{ // set up a k8s service in each cluster, with a pod in each cluster and a workloadentry in cluster-1 "k8s service with pod and workloadentry": { fakeOpts: func() xds.FakeOptions { k8sObjects := map[cluster.ID]string{ "cluster-1": "", "cluster-2": "", } i := 1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0)