- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for serviceToAddressInfo (0.26 sec)
-
pilot/pkg/serviceregistry/memory/discovery.go
} func (sd *ServiceDiscovery) AddServiceInfo(infos ...*model.ServiceInfo) { sd.mutex.Lock() defer sd.mutex.Unlock() for _, info := range infos { sd.addresses[info.ResourceName()] = serviceToAddressInfo(info.Service) } } func (sd *ServiceDiscovery) RemoveServiceInfo(info *model.ServiceInfo) { sd.mutex.Lock() defer sd.mutex.Unlock() delete(sd.addresses, info.ResourceName()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
return []model.AddressInfo{modelWorkloadToAddressInfo(wls[0])} } // 3. Service if svc := a.lookupService(key); svc != nil { res := []model.AddressInfo{serviceToAddressInfo(svc.Service)} for _, w := range a.workloads.ByServiceKey.Lookup(svc.ResourceName()) { res = append(res, workloadToAddressInfo(w.Workload)) } return res } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go
Workload: w, }, }, } } func modelWorkloadToAddressInfo(w model.WorkloadInfo) model.AddressInfo { return workloadToAddressInfo(w.Workload) } func serviceToAddressInfo(s *workloadapi.Service) model.AddressInfo { return model.AddressInfo{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Service{ Service: s, }, }, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 22 20:35:23 UTC 2024 - 7.2K bytes - Viewed (0)