- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for serviceInstance (0.47 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)