Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetDestinationCluster (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top