Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for CastDestinationRule (0.33 sec)

  1. pilot/pkg/networking/core/cluster_builder.go

    			v3.HttpProtocolOptionsType: protoconv.MessageToAny(mc.httpProtocolOptions),
    		}
    	}
    	return mc.cluster
    }
    
    // CastDestinationRule returns the destination rule enclosed by the config, if not null.
    // Otherwise, return nil.
    func CastDestinationRule(config *config.Config) *networking.DestinationRule {
    	if config != nil {
    		return config.Spec.(*networking.DestinationRule)
    	}
    
    	return nil
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/tls.go

    				alt := GenerateAltVirtualHosts(a.Hostname.String(), 0, node.DNSDomain)
    				sniHosts = append(sniHosts, a.Hostname.String())
    				sniHosts = append(sniHosts, alt...)
    			}
    		}
    		destinationRule := CastDestinationRule(node.SidecarScope.DestinationRule(
    			model.TrafficDirectionOutbound, node, service.Hostname).GetRule())
    		var destinationCIDRs []string
    		if destinationCIDR != "" {
    			destinationCIDRs = []string{destinationCIDR}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/grpcgen/cds.go

    	if b.svc == nil || b.port == nil {
    		return nil
    	}
    
    	// resolve policy from context
    	destinationRule := corexds.CastDestinationRule(b.node.SidecarScope.DestinationRule(
    		model.TrafficDirectionOutbound, b.node, b.svc.Hostname).GetRule())
    	trafficPolicy, _ := util.GetPortLevelTrafficPolicy(destinationRule.GetTrafficPolicy(), b.port)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/networkfilter.go

    	push, node := lb.push, lb.node
    	service := push.ServiceForHostname(node, host.Name(routes[0].Destination.Host))
    	var destinationRule *networking.DestinationRule
    	if service != nil {
    		destinationRule = CastDestinationRule(node.SidecarScope.DestinationRule(model.TrafficDirectionOutbound, node, service.Hostname).GetRule())
    	}
    	if len(routes) == 1 {
    		clusterName := istioroute.GetDestinationCluster(routes[0].Destination, service, port.Port)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/gateway.go

    			if len(push.Mesh.OutboundClusterStatName) != 0 {
    				statPrefix = telemetry.BuildStatPrefix(push.Mesh.OutboundClusterStatName, string(service.Hostname), "", port, 0, &service.Attributes)
    			}
    			destinationRule := CastDestinationRule(proxy.SidecarScope.DestinationRule(
    				model.TrafficDirectionOutbound, proxy, service.Hostname).GetRule())
    
    			// First, we build the standard cluster. We match on the SNI matching the cluster name
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
Back to top