- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for GetDestinationCluster (0.24 sec)
-
pilot/pkg/networking/core/networkfilter.go
} for _, route := range routes { service := lb.push.ServiceForHostname(lb.node, host.Name(route.Destination.Host)) if route.Weight > 0 { clusterName := istioroute.GetDestinationCluster(route.Destination, service, port.Port) clusterSpecifier.WeightedClusters.Clusters = append(clusterSpecifier.WeightedClusters.Clusters, &tcp.TcpProxy_WeightedCluster_ClusterWeight{ Name: clusterName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
WeightedClusters: &route.WeightedCluster{ Clusters: weighted, }, } } } // GetDestinationCluster generates a cluster name for the route, or error if no cluster // can be found. Called by translateRule to determine if func (lb *ListenerBuilder) GetDestinationCluster(destination *networking.Destination, service *model.Service, listenerPort int) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
Port: port.Port, Services: []*model.Service{svc}, Routes: []*route.Route{httpRoute}, } } // GetDestinationCluster generates a cluster name for the route, or error if no cluster // can be found. Called by translateRule to determine if func GetDestinationCluster(destination *networking.Destination, service *model.Service, listenerPort int) string { if len(destination.GetHost()) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
if node.SidecarScope.OutboundTrafficPolicy.EgressProxy != nil { // user has provided an explicit destination for all the unknown traffic. // build a cluster out of this destination egressCluster = istio_route.GetDestinationCluster(node.SidecarScope.OutboundTrafficPolicy.EgressProxy, nil, 0) } } else { egressCluster = util.BlackHoleCluster } tcpProxy := &tcp.TcpProxy{ StatPrefix: egressCluster,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute.go
if node.SidecarScope.OutboundTrafficPolicy.EgressProxy != nil { // user has provided an explicit destination for all the unknown traffic. // build a cluster out of this destination egressCluster = istio_route.GetDestinationCluster(node.SidecarScope.OutboundTrafficPolicy.EgressProxy, nil, 0) } routeAction := &route.RouteAction{ ClusterSpecifier: &route.RouteAction_Cluster{Cluster: egressCluster},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 32.7K bytes - Viewed (0)