Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for serviceInstance (0.16 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/model/validation_test.go

    			Labels:       lbls,
    		}
    	}
    
    	cases := []struct {
    		name     string
    		instance *ServiceInstance
    		valid    bool
    	}{
    		{
    			name: "nil service",
    			instance: &ServiceInstance{
    				Endpoint: endpointWithLabels(labels.Instance{}),
    			},
    		},
    		{
    			name: "bad label",
    			instance: &ServiceInstance{
    				Service:  service1,
    				Endpoint: endpointWithLabels(labels.Instance{"*": "-"}),
    			},
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 23 19:35:35 UTC 2023
    - 4K bytes
    - Viewed (0)
  4. 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)
  5. tests/fuzz/pilot_model_fuzzer.go

    	// Create service instances
    	serviceInstances := make([]*model.ServiceInstance, 0, 20)
    	number, err := f.GetInt()
    	if err != nil {
    		return 0
    	}
    	// We allow a maximum of 20 service instances
    	numberOfS := number % 20
    	for i := 0; i < numberOfS; i++ {
    		si, err := NewSI(f)
    		if err != nil {
    			return 0
    		}
    		serviceInstances = append(serviceInstances, si)
    	}
    
    	// Create services
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 08 18:13:06 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top