Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for serviceInstance (0.23 sec)

  1. pilot/pkg/serviceregistry/serviceentry/store.go

    type serviceInstancesStore struct {
    	ip2instance map[string][]*model.ServiceInstance
    	// service instances by hostname -> config
    	instances map[instancesKey]map[configKeyWithParent][]*model.ServiceInstance
    	// instances only for serviceentry
    	instancesBySE map[types.NamespacedName]map[configKey][]*model.ServiceInstance
    	// instancesByHostAndPort tells whether the host has instances.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/store_test.go

    	store := serviceInstancesStore{
    		ip2instance:            map[string][]*model.ServiceInstance{},
    		instances:              map[instancesKey]map[configKeyWithParent][]*model.ServiceInstance{},
    		instancesBySE:          map[types.NamespacedName]map[configKey][]*model.ServiceInstance{},
    		instancesByHostAndPort: sets.Set[hostPort]{},
    	}
    	instances := []*model.ServiceInstance{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    		}
    		if len(sd.serviceInstances.instances[key]) != 0 {
    			t.Fatalf("service instances store `instances` memory leak, expect 0, got %d", len(sd.serviceInstances.instances[key]))
    		}
    		if len(sd.serviceInstances.instancesBySE[namespacedName]) != 0 {
    			t.Fatalf("service instances store `instancesBySE` memory leak, expect 0, got %d", len(sd.serviceInstances.instancesBySE[namespacedName]))
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  4. 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)
  5. pkg/config/analysis/analyzers/multicluster/service.go

    		}
    		inconsistents, errors := findInconsistencies(clusterServices)
    		if len(inconsistents) > 0 {
    			var serviceInstance *resource.Instance
    			for _, r := range clusterServices {
    				if r != nil {
    					serviceInstance = r
    					break
    				}
    			}
    			message := msg.NewMultiClusterInconsistentService(serviceInstance, fullname.Name.String(),
    				fullname.Namespace.String(), inconsistents, errors)
    
    			c.Report(gvk.Service, message)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 08:32:06 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. platforms/core-runtime/service-provider/src/main/java/org/gradle/internal/service/ServiceRegistration.java

         * @param serviceType The type to make this service visible as.
         * @param serviceInstance The service implementation.
         */
        <T> void add(Class<T> serviceType, T serviceInstance);
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  10. 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)
Back to top