- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for serviceInstance (0.66 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/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) -
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) -
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) -
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) -
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) -
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)