Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for efKeys (0.47 sec)

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

    	}
    	if t.service != nil {
    		configs = append(configs, model.ConfigKey{Kind: kind.ServiceEntry, Name: string(t.service.Hostname), Namespace: t.service.Attributes.Namespace}.HashCode())
    	}
    	for _, efKey := range t.envoyFilterKeys {
    		items := strings.Split(efKey, "/")
    		configs = append(configs, model.ConfigKey{Kind: kind.EnvoyFilter, Name: items[1], Namespace: items[0]}.HashCode())
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/httproute.go

    func (configgen *ConfigGeneratorImpl) buildSidecarOutboundHTTPRouteConfig(
    	node *model.Proxy,
    	req *model.PushRequest,
    	routeName string,
    	vHostCache map[int][]*route.VirtualHost,
    	efw *model.EnvoyFilterWrapper,
    	efKeys []string,
    ) (*discovery.Resource, bool) {
    	listenerPort, useSniffing, err := extractListenerPort(routeName)
    	if err != nil && routeName != model.RDSHttpProxy && !strings.HasPrefix(routeName, model.UnixAddressPrefix) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster.go

    	resources := make([]*discovery.Resource, 0)
    	efKeys := cp.efw.KeysApplyingTo(networking.EnvoyFilter_CLUSTER)
    	hit, miss := 0, 0
    	for _, service := range services {
    		if service.Resolution == model.Alias {
    			continue
    		}
    		for _, port := range service.Ports {
    			if port.Protocol == protocol.UDP {
    				continue
    			}
    			clusterKey := buildClusterKey(service, port, cb, proxy, efKeys)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/route/route_cache.go

    		for _, dr := range mergedDR.GetFrom() {
    			configs = append(configs, model.ConfigKey{Kind: kind.DestinationRule, Name: dr.Name, Namespace: dr.Namespace}.HashCode())
    		}
    	}
    
    	for _, efKey := range r.EnvoyFilterKeys {
    		items := strings.Split(efKey, "/")
    		configs = append(configs, model.ConfigKey{Kind: kind.EnvoyFilter, Name: items[1], Namespace: items[0]}.HashCode())
    	}
    	return configs
    }
    
    func (r *Cache) Key() any {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 5.8K bytes
    - Viewed (0)
Back to top