- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for InsertAll (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)