- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for getProxyServiceTargets (0.36 sec)
-
pilot/pkg/serviceregistry/aggregate/controller_test.go
func TestGetProxyServiceTargets(t *testing.T) { aggregateCtl := buildMockController() // Get Instances from mockAdapter1 instances := aggregateCtl.GetProxyServiceTargets(&model.Proxy{IPAddresses: []string{mock.HelloInstanceV0}}) if len(instances) != 6 { t.Fatalf("Returned GetProxyServiceTargets' amount %d is not correct", len(instances)) } for _, inst := range instances { if inst.Service.Hostname != mock.HelloService.Hostname {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
if r.Provider() != provider.Kubernetes || nodeClusterID == "" { return false } return !r.Cluster().Equals(nodeClusterID) } // GetProxyServiceTargets lists service instances co-located with a given proxy func (c *Controller) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget { out := make([]model.ServiceTarget, 0) nodeClusterID := nodeClusterID(node) for _, r := range c.GetRegistries() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
} serviceInstances := controller.GetProxyServiceTargets(svcNode) if len(serviceInstances) != 1 { t.Fatalf("GetProxyServiceTargets() expected 1 instance, got %d", len(serviceInstances)) } hostname := kube.ServiceHostname("svc1", "nsa", defaultFakeDomainSuffix) if serviceInstances[0].Service.Hostname != hostname { t.Fatalf("GetProxyServiceTargets() wrong service instance returned => hostname %q, want %q",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
}) } } // GetProxyServiceTargets returns service instances co-located with a given proxy // TODO: this code does not return k8s service instances when the proxy's IP is a workload entry // To tackle this, we need a ip2instance map like what we have in service entry. func (esc *endpointSliceController) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
} } return endpoints } // GetProxyServiceTargets returns service targets co-located with a given proxy // TODO: this code does not return k8s service instances when the proxy's IP is a workload entry // To tackle this, we need a ip2instance map like what we have in service entry. func (c *Controller) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget { if len(proxy.IPAddresses) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
endpoints[key] = append(endpoints[key], instance.Endpoint) } } return endpoints } // GetProxyServiceTargets lists service targets co-located with a given proxy // NOTE: The service objects in these instances do not have the auto allocated IP set. func (s *Controller) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget { out := make([]model.ServiceTarget, 0) s.mutex.RLock() defer s.mutex.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/model/service.go
// Services list declarations of all services in the system Services() []*Service // GetService retrieves a service by host name if it exists GetService(hostname host.Name) *Service // GetProxyServiceTargets returns the service targets that co-located with a given Proxy // // Co-located generally means running in the same network namespace and security context. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/model/context.go
AutoPassthroughSNIHosts: prevMergedGateway.GetAutoPassthrughGatewaySNIHosts(), } } func (node *Proxy) SetServiceTargets(serviceDiscovery ServiceDiscovery) { instances := serviceDiscovery.GetProxyServiceTargets(node) // Keep service instances in order of creation/hostname. sort.SliceStable(instances, func(i, j int) bool { if instances[i].Service != nil && instances[j].Service != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
pilot/pkg/model/push_context.go
// the sidecar calls. // Updated by GetProxyServiceTargets ProxyStatusNoService = monitoring.NewGauge( "pilot_no_ip", "Pods not found in the endpoint table, possibly invalid.", ) // ProxyStatusEndpointNotReady represents proxies found not be ready. // Updated by GetProxyServiceTargets. Normal condition when starting // an app with readiness, error if it doesn't change to 0.
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/serviceentry/controller_test.go
t.Helper() // The system is eventually consistent, so add some retries retry.UntilSuccessOrFail(t, func() error { instances := sd.GetProxyServiceTargets(&model.Proxy{IPAddresses: []string{ip}, Metadata: &model.NodeMetadata{}}) sortServiceTargets(instances) sortServiceTargets(expected) if err := compare(t, instances, expected); err != nil { return err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0)