- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for instancesByPort (0.28 sec)
-
pilot/pkg/config/kube/gateway/context.go
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]() for servicePort, instances := range instancesByPort { for _, i := range instances { if i.EndpointPort == uint32(port) {
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/model/push_context.go
svcKey := service.Key() for port, inst := range instances { if _, exists := ps.ServiceIndex.instancesByPort[svcKey]; !exists { ps.ServiceIndex.instancesByPort[svcKey] = make(map[int][]*IstioEndpoint) } ps.ServiceIndex.instancesByPort[svcKey][port] = append(ps.ServiceIndex.instancesByPort[svcKey][port], inst...) } } // StatusJSON implements json.Marshaller, with a lock.
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/xds/eds.go
} else { inboundServiceUpdates.Increment() } } // EDSUpdate computes destination address membership across all clusters and networks. // This is the main method implementing EDS. // It replaces InstancesByPort in model - instead of iterating over all endpoints it uses // the hostname-keyed map. And it avoids the conversion from Endpoint to ServiceEntry to envoy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
EndpointPort: 8000, ServicePortName: "uds", }, }, }, }, }, } ps.initServiceRegistry(env, nil) instancesByPort := ps.ServiceIndex.instancesByPort[svc5_1.Key()] assert.Equal(t, len(instancesByPort), 2) } func TestGetHostsFromMeshConfig(t *testing.T) { ps := NewPushContext() env := &Environment{Watcher: mesh.NewFixedWatcher(&meshconfig.MeshConfig{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
// Run through all the workload instances, select ones that match the service labels // only if this is a kubernetes internal service and of ClientSideLB (eds) type // as InstancesByPort is called by the aggregate controller. We dont want to include // workload instances for any other registry workloadInstancesExist := !c.workloadInstancesIndex.Empty() c.RLock()
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/kube/controller/controller_test.go
t.Fatalf("eds update after adding workload entry did not match expected list. got %v, want %v", gotEndpointIPs, expectedEndpointIPs) } // Check if InstancesByPort returns the same list converted := controller.Services() if len(converted) != 1 { t.Fatalf("failed to get services (%v), converted", converted) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0)