Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for serviceToAddressInfo (0.26 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top