Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ExtractWorkloadsFromAddresses (0.35 sec)

  1. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    	// Since it is a part of VIP1 which we are subscribe to, add it to the subscriptions
    	for addr := range allAddresses {
    		for _, wl := range model.ExtractWorkloadsFromAddresses(a.Lookup(addr)) {
    			// We may have gotten an update for Pod, but are subscribed to a Service.
    			// We need to force a subscription on the Pod as well
    			for namespacedHostname := range wl.Services {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  2. pilot/pkg/model/service.go

    }
    
    func NewSelector(l map[string]string) LabelSelector {
    	return LabelSelector{l}
    }
    
    func (l LabelSelector) GetLabelSelector() map[string]string {
    	return l.Labels
    }
    
    func ExtractWorkloadsFromAddresses(addrs []AddressInfo) []WorkloadInfo {
    	return slices.MapFilter(addrs, func(a AddressInfo) *WorkloadInfo {
    		switch addr := a.Type.(type) {
    		case *workloadapi.Address_Workload:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  3. pilot/pkg/model/push_context.go

    	// We should get 0 or 1 workloads, so just return the first.
    	infos, _ := ps.ambientIndex.AddressInformation(sets.New(n.String() + "/" + ip))
    	for _, wl := range ExtractWorkloadsFromAddresses(infos) {
    		if wl.TunnelProtocol == workloadapi.TunnelProtocol_HBONE {
    			return true
    		}
    	}
    	return false
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
Back to top