Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 31 for InsertAll (0.12 sec)

  1. pkg/test/framework/components/echo/deployment/builder.go

    func (b *builder) validateTemplates(config echo.Config, c cluster.Cluster) bool {
    	expected := sets.New[string]()
    	for _, subset := range config.Subsets {
    		expected.InsertAll(parseList(subset.Annotations[annotation.InjectTemplates.Name])...)
    	}
    	if b.templates == nil || b.templates[c.Name()] == nil {
    		return expected.IsEmpty()
    	}
    
    	return b.templates[c.Name()].SupersetOf(expected)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. pilot/pkg/xds/delta.go

    		if usedDelta {
    			// Apply the delta
    			newResourceNames = sets.SortedList(sets.New(w.ResourceNames...).
    				DeleteAll(resp.RemovedResources...).
    				InsertAll(currentResources...))
    		} else {
    			newResourceNames = currentResources
    		}
    	}
    	if neverRemoveDelta(w.TypeUrl) {
    		resp.RemovedResources = nil
    	}
    	if len(resp.RemovedResources) > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. pilot/pkg/model/network.go

    	// - the computed map from meshNetworks (triggered by reloadNetworkLookup, the ported logic from getGatewayAddresses)
    	gatewaySet.InsertAll(mgr.env.NetworkGateways()...)
    	resolvedGatewaySet := mgr.resolveHostnameGateways(gatewaySet)
    
    	return mgr.NetworkGateways.update(resolvedGatewaySet) || mgr.Unresolved.update(gatewaySet)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 16.9K bytes
    - Viewed (0)
  4. pilot/pkg/model/gateway.go

    	}
    	if g.ContainsAutoPassthroughGateways {
    		for _, tls := range g.MergedServers {
    			for _, s := range tls.Servers {
    				if s.GetTls().GetMode() == networking.ServerTLSSettings_AUTO_PASSTHROUGH {
    					hosts.InsertAll(s.Hosts...)
    				}
    			}
    		}
    	}
    	return hosts
    }
    
    func udpSupportedPort(number uint32, instances []ServiceTarget) bool {
    	for _, w := range instances {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/cluster.go

    				servicePortClusters, subsetClusters)
    		case kind.DestinationRule:
    			svcs, deleted = configgen.deltaFromDestinationRules(key, proxy, subsetClusters)
    		}
    		services = append(services, svcs...)
    		deletedClusters.InsertAll(deleted...)
    	}
    	clusters, log := configgen.buildClusters(proxy, updates, services)
    	// DeletedClusters contains list of all subset clusters for the deleted DR or updated DR.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/httproute.go

    		return nil
    	}
    
    	for _, virtualHostWrapper := range virtualHostWrappers {
    		for _, svc := range virtualHostWrapper.Services {
    			name := util.DomainName(string(svc.Hostname), virtualHostWrapper.Port)
    			knownFQDN.InsertAll(name, string(svc.Hostname))
    		}
    	}
    
    	for _, virtualHostWrapper := range virtualHostWrappers {
    		// If none of the routes matched by source, skip this virtual host
    		if len(virtualHostWrapper.Routes) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  7. pilot/pkg/model/telemetry.go

    	for _, m := range logs {
    		names := sets.New[string]()
    		for _, p := range m.Logging {
    			if !matchWorkloadMode(p.Match, mode) {
    				continue
    			}
    			subProviders := getProviderNames(p.Providers)
    			names.InsertAll(subProviders...)
    
    			for _, prov := range subProviders {
    				filters[prov] = loggingSpec{
    					Filter: p.Filter,
    				}
    			}
    		}
    
    		if names.Len() > 0 {
    			providerNames = names.UnsortedList()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 18:14:09 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  8. pilot/pkg/model/sidecar.go

    	if sc == nil {
    		return
    	}
    	if sc.configDependencies == nil {
    		sc.configDependencies = sets.New(dependencies...)
    	} else {
    		sc.configDependencies.InsertAll(dependencies...)
    	}
    }
    
    // DestinationRule returns a destinationrule for a svc.
    func (sc *SidecarScope) DestinationRule(direction TrafficDirection, proxy *Proxy, svc host.Name) *ConsolidatedDestRule {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 20:32:23 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  9. pilot/pkg/bootstrap/server.go

    	}
    	knownSans := make([]string, 0, 2*len(knownHosts))
    	for _, altName := range knownHosts {
    		knownSans = append(knownSans,
    			fmt.Sprintf("%s.%s.svc", altName, args.Namespace))
    	}
    	sans.InsertAll(knownSans...)
    	dnsNames := sets.SortedList(sans)
    	log.Infof("Discover server subject alt names: %v", dnsNames)
    	return dnsNames
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  10. pilot/pkg/config/kube/gateway/conversion.go

    			// Short circuit if its a hard failure
    			reportGatewayStatus(r, obj, classInfo, gatewayServices, servers, err)
    			continue
    		}
    		for i, l := range kgw.Listeners {
    			i := i
    			namespaceLabelReferences.InsertAll(getNamespaceLabelReferences(l.AllowedRoutes)...)
    			server, programmed := buildListener(r, obj, l, i, controllerName)
    
    			servers = append(servers, server)
    			if controllerName == constants.ManagedGatewayMeshController {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
Back to top