- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for isDNSTypeServiceEntry (0.18 sec)
-
pilot/pkg/serviceregistry/serviceentry/util.go
var out []types.NamespacedName for key := range old { if _, ok := curr[key]; !ok { out = append(out, key) } } return out } func isDNSTypeServiceEntry(se *networking.ServiceEntry) bool { if se == nil { return false } return se.Resolution == networking.ServiceEntry_DNS || se.Resolution == networking.ServiceEntry_DNS_ROUND_ROBIN }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 1.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
configsUpdated := sets.New[model.ConfigKey]() addConfigs := func(se *networking.ServiceEntry, services []*model.Service) { // If serviceentry's resolution is DNS, make a full push // TODO: maybe cds? if isDNSTypeServiceEntry(se) { fullPush = true for key, value := range getUpdatedConfigs(services) { configsUpdated[key] = value } } } cfgs := s.store.List(gvk.ServiceEntry, curr.Namespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion.go
services = convertServices(cfg) } endpointsNum := len(serviceEntry.Endpoints) hostnameToServiceInstance := false if len(serviceEntry.Endpoints) == 0 && serviceEntry.WorkloadSelector == nil && isDNSTypeServiceEntry(serviceEntry) { hostnameToServiceInstance = true endpointsNum = 1 } out := make([]*model.ServiceInstance, 0, len(services)*len(serviceEntry.Ports)*endpointsNum) for _, service := range services {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 16.9K bytes - Viewed (0)