- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for clusterIPs (0.28 sec)
-
pkg/proxy/nftables/proxier.go
Type: ipvX_addr, Comment: ptr.To("Active ClusterIPs"), }) // reject traffic to invalid ports of ClusterIPs. tx.Add(&knftables.Rule{ Chain: clusterIPsCheckChain, Rule: knftables.Concat( ipX, "daddr", "@", clusterIPsSet, "reject", ), Comment: ptr.To("Reject traffic to invalid ports of ClusterIPs"), }) // drop traffic to unallocated ClusterIPs. if len(proxier.serviceCIDRs) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass_test.cc
auto clusters = GetClusters(*graph); EXPECT_EQ(4, clusters.size()); EXPECT_EQ(clusters["B"], clusters["C"]); EXPECT_EQ(clusters["E"], clusters["F"]); EXPECT_NE(clusters["B"], clusters["E"]); EXPECT_TRUE(clusters.find("A") == clusters.cend()); EXPECT_TRUE(clusters.find("D") == clusters.cend()); } TEST(XlaCompilationTest, UncompilableCycles) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 10:11:10 UTC 2024 - 79.6K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass.cc
absl::StatusOr<bool> ForEachEdgeInPostOrder(FnTy fn); // Contracts as many edges as possible to create XLA clusters. After this // finishes the clustering decisions made are implicitly stored in // `clusters_`. Status RunEdgeContractionLoop(); // "Fixes up" clusters by removing some modes. // // Autoclustering can sometimes be overeager. For example, clustering large
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 12:19:41 UTC 2024 - 85.3K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
if !reflect.DeepEqual(xdstest.MapKeys(tt.clusters), got) { t.Errorf("expected clusters: %v, got: %v", xdstest.MapKeys(tt.clusters), got) } for cname, c := range cmap { // Check the upstream endpoints match got := xdstest.ExtractLoadAssignments([]*endpoint.ClusterLoadAssignment{c.GetLoadAssignment()})[cname] if !reflect.DeepEqual(tt.clusters[cname], got) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
tensorflow/compiler/jit/encapsulate_subgraphs_pass.cc
namespace { // Return in 'sorted' a topological sort of clusters according to the // dependencies encoded in ancestors. clusters is the list of all clusters // including clusters that are not present in the ancestors map. has_successors // is the set of clusters that are ancestors of some other cluster. void TopologicalClusterSort( const absl::flat_hash_set<string>& clusters, const absl::flat_hash_set<string>& has_successors,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 51K bytes - Viewed (0) -
pkg/kubelet/apis/config/v1beta1/defaults_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 21:10:42 UTC 2024 - 51K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
consistentHash = hash != nil } else { weighted := make([]*route.WeightedCluster_ClusterWeight, 0) for _, dst := range in.Route { if dst.Weight == 0 { // Ignore 0 weighted clusters if there are other clusters in the route. continue } destinationweight, hostname := processWeightedDestination(dst, serviceRegistry, listenerPort, hashByDestination, action) weighted = append(weighted, destinationweight)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0) -
pkg/kubelet/apis/config/v1beta1/zz_generated.conversion.go
if err := v1.Convert_Pointer_int32_To_int32(&in.OOMScoreAdj, &out.OOMScoreAdj, s); err != nil { return err } out.ClusterDomain = in.ClusterDomain out.ClusterDNS = *(*[]string)(unsafe.Pointer(&in.ClusterDNS)) out.StreamingConnectionIdleTimeout = in.StreamingConnectionIdleTimeout out.NodeStatusUpdateFrequency = in.NodeStatusUpdateFrequency out.NodeStatusReportFrequency = in.NodeStatusReportFrequency
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 48.9K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute_test.go
resource.Resource.UnmarshalTo(routeCfg) xdstest.ValidateRouteConfiguration(t, routeCfg) got := map[string][]string{} clusters := map[string]string{} for _, vh := range routeCfg.VirtualHosts { got[vh.Name] = vh.Domains clusters[vh.Name] = vh.GetRoutes()[0].GetRoute().GetCluster() } if !reflect.DeepEqual(tt.expectedHosts, got) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 51.4K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
"Number of conflicting inbound listeners.", ) // DuplicatedClusters tracks duplicate clusters seen while computing CDS DuplicatedClusters = monitoring.NewGauge( "pilot_duplicate_envoy_clusters", "Duplicate envoy clusters caused by service entries with same hostname", ) // DNSNoEndpointClusters tracks dns clusters without endpoints DNSNoEndpointClusters = monitoring.NewGauge( "pilot_dns_cluster_without_endpoints",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)