- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ServiceEndpoints (0.21 sec)
-
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) -
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) -
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) -
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) -
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)