- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for serviceInstance (0.56 sec)
-
pilot/pkg/serviceregistry/memory/discovery.go
instancesByPortNum map[string][]*model.ServiceInstance instancesByPortName map[string][]*model.ServiceInstance // Used by GetProxyServiceInstance, used to configure inbound (list of services per IP) // We generally expect a single instance - conflicting services need to be reported. ip2instance map[string][]*model.ServiceInstance WantGetProxyServiceTargets []model.ServiceTarget
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
curr config.Config, services []*model.Service, ) (map[configKey][]*model.ServiceInstance, []*model.ServiceInstance) { currentServiceEntry := curr.Spec.(*networking.ServiceEntry) var serviceInstances []*model.ServiceInstance serviceInstancesByConfig := map[configKey][]*model.ServiceInstance{} // for service entry with labels if currentServiceEntry.WorkloadSelector != nil {
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/serviceregistry/serviceentry/conversion_test.go
for _, serviceInstance := range tt.out { serviceInstance.Endpoint.Locality = model.Locality{ Label: tt.wle.Locality, ClusterID: tt.clusterID, } serviceInstance.Endpoint.Network = network.ID(tt.wle.Network) serviceInstance.Endpoint.Labels = labelutil.AugmentLabels(serviceInstance.Endpoint.Labels, tt.clusterID, tt.wle.Locality, "", network.ID(tt.wle.Network))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion.go
func (s *Controller) convertWorkloadEntryToServiceInstances(wle *networking.WorkloadEntry, services []*model.Service, se *networking.ServiceEntry, configKey *configKey, clusterID cluster.ID, ) []*model.ServiceInstance { out := make([]*model.ServiceInstance, 0, len(services)*len(se.Ports)) for _, service := range services { for _, port := range se.Ports { out = append(out, s.convertEndpoint(service, port, wle, configKey, clusterID)) } }
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/service.go
TargetPort: e.Endpoint.EndpointPort, }, } } // DeepCopy creates a copy of ServiceInstance. func (instance *ServiceInstance) DeepCopy() *ServiceInstance { return &ServiceInstance{ Service: instance.Service.DeepCopy(), Endpoint: instance.Endpoint.DeepCopy(), ServicePort: &Port{ Name: instance.ServicePort.Name, Port: instance.ServicePort.Port, Protocol: instance.ServicePort.Protocol, },
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/xds/eds_test.go
Ports: ports, Hostname: host.Name("test1"), } s.MemRegistry.AddService(svc) if _, err := ads.Wait(time.Second*10, watchAll...); err != nil { t.Fatal(err) } i := &model.ServiceInstance{ Service: svc, ServicePort: svc.Ports[0], Endpoint: &model.IstioEndpoint{ Address: "1.2.3.4", ServiceAccount: "spiffe://td1/ns/def/sa/def", HealthStatus: model.UnHealthy, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
buildServiceWithPort("test2.com", 81, protocol.Unsupported, tnow), buildServiceWithPort("test3.com", 82, protocol.TCP, tnow), } instances := make([]*model.ServiceInstance, 0, len(services)) for _, s := range services { instances = append(instances, &model.ServiceInstance{ Service: s, Endpoint: &model.IstioEndpoint{ EndpointPort: uint32(s.Ports[0].Port), Address: "1.1.1.1", },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go
} for _, si := range instances { if si.Service == nil { return fmt.Errorf("proxy ServiceInstance has nil service") } if _, found := expectedHosts[si.Service.Hostname]; !found { return fmt.Errorf("found proxy ServiceInstance for unexpected host: %s", si.Service.Hostname) } delete(expectedHosts, si.Service.Hostname) } if len(expectedHosts) > 0 {
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/config/kube/gateway/conversion_test.go
// Setup a few preconfigured services instances := []*model.ServiceInstance{} for _, svc := range services { instances = append(instances, &model.ServiceInstance{ Service: svc, ServicePort: ports[0], Endpoint: &model.IstioEndpoint{EndpointPort: 8080}, }, &model.ServiceInstance{ Service: svc, ServicePort: ports[1], Endpoint: &model.IstioEndpoint{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 20:24:52 UTC 2024 - 34.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
return "" } return region + "/" + zone + "/" + subzone // Format: "%s/%s/%s" } func (c *Controller) serviceInstancesFromWorkloadInstances(svc *model.Service, reqSvcPort int) []*model.ServiceInstance { // 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
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0)