Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for serviceInstance (0.66 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/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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/service/DefaultServiceRegistry.java

            assertMutable();
            ownServices.add(new FixedInstanceService(this, serviceType, serviceInstance));
            return this;
        }
    
        /**
         * Adds a service instance to this registry. The given object is closed when this registry is closed.
         */
        public DefaultServiceRegistry add(Object serviceInstance) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 06:47:40 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  10. 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)
Back to top