Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for serviceInstance (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top