Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ServiceEndpoints (0.21 sec)

  1. pilot/pkg/config/kube/gateway/context.go

    					if !foundPending.Contains(g) {
    						warnings = append(warnings, fmt.Sprintf("address pending for hostname %q", g))
    						foundPending.Insert(g)
    					}
    				}
    			} else {
    				instancesByPort := gc.ps.ServiceEndpoints(svcKey)
    				if instancesEmpty(instancesByPort) {
    					warnings = append(warnings, fmt.Sprintf("no instances found for hostname %q", g))
    				} else {
    					hintPort := sets.New[string]()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 18:33:02 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go

    			}
    			delete(expectedHosts, si.Service.Hostname)
    		}
    
    		if len(expectedHosts) > 0 {
    			return fmt.Errorf("failed to find proxy ServiceEndpoints for hosts: %v", expectedHosts)
    		}
    
    		return nil
    	}, serviceImportTimeout)
    }
    
    func (ic *serviceImportCacheImpl) updateKubeService(t *testing.T) {
    	t.Helper()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 18:50:38 UTC 2023
    - 15.2K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/conversion.go

    			Namespace:    configKey.namespace,
    		},
    		Service:     service,
    		ServicePort: convertPort(servicePort),
    	}
    }
    
    // convertWorkloadEntryToServiceInstances translates a WorkloadEntry into ServiceEndpoints. This logic is largely the
    // same as the ServiceEntry convertServiceEntryToInstances.
    func (s *Controller) convertWorkloadEntryToServiceInstances(wle *networking.WorkloadEntry, services []*model.Service,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  4. pilot/pkg/model/push_context.go

    			if labels.SubsetOf(instance.Labels) {
    				out = append(out, instance)
    			}
    		}
    	}
    
    	return out
    }
    
    // ServiceEndpoints returns the cached instances by svc if exists.
    func (ps *PushContext) ServiceEndpoints(svcKey string) map[int][]*IstioEndpoint {
    	if instances, exists := ps.ServiceIndex.instancesByPort[svcKey]; exists {
    		return instances
    	}
    
    	return nil
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/controller.go

    		// metadata already. Because of this, we can still get most of the information we need.
    		// If we cannot accurately construct ServiceEndpoints from just the metadata, this will return an error and we can
    		// attempt to read the real pod.
    		out, err := c.GetProxyServiceTargetsFromMetadata(proxy)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top