Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for serviceInstance (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. pilot/pkg/networking/core/fake.go

    	ConfigTemplateInput any
    
    	// Services to pre-populate as part of the service discovery
    	Services  []*model.Service
    	Instances []*model.ServiceInstance
    	Gateways  []model.NetworkGateway
    
    	// If provided, this mesh config will be used
    	MeshConfig      *meshconfig.MeshConfig
    	NetworksWatcher mesh.NetworksWatcher
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. pilot/pkg/model/gateway.go

    		}
    	}
    	ret := ports.UnsortedList()
    	if len(ret) == 0 && legacyGatewaySelector {
    		// When we are using legacy gateway label selection, we should bind to the port as-is if there is
    		// no matching ServiceInstance.
    		return []uint32{number}
    	}
    	// For cases where we are directly referencing a Service, we know that they port *must* be in the Service,
    	// so we have no fallback. If there was no match, the Gateway is a no-op.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
Back to top