- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for serviceInstance (0.19 sec)
-
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) -
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_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
) func flattenInstances(il ...[]*model.ServiceInstance) []*model.ServiceInstance { ret := []*model.ServiceInstance{} for _, i := range il { ret = append(ret, i...) } return ret } func makeInstances(proxy *model.Proxy, svc *model.Service, servicePort int, targetPort int) []*model.ServiceInstance { ret := []*model.ServiceInstance{} for _, p := range svc.Ports { if p.Port != servicePort {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
instancePlainText := &ServiceInstance{ Endpoint: &IstioEndpoint{ Address: "192.168.1.2", EndpointPort: 1000000, TLSMode: DisabledTLSModeLabel, }, } cases := []struct { name string serviceNamespace string servicePort int serviceResolution Resolution serviceInstances []*ServiceInstance wanted MutualTLSMode }{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/project/DefaultProject.java
.build()); } private <T> void registerServiceOn(ModelRegistry modelRegistry, String path, ModelType<T> type, T instance, String descriptor) { modelRegistry.register(ModelRegistrations.serviceInstance(ModelReference.of(path, type), instance) .descriptor(descriptor) .build() ); } private String instanceDescriptorFor(String path) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 50.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Metadata: &model.NodeMetadata{Namespace: "nsa", ClusterID: clusterID}, } serviceInstances := controller.GetProxyServiceTargets(svcNode) if len(serviceInstances) != 1 { t.Fatalf("GetProxyServiceTargets() expected 1 instance, got %d", len(serviceInstances)) } hostname := kube.ServiceHostname("svc1", "nsa", defaultFakeDomainSuffix) if serviceInstances[0].Service.Hostname != hostname {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
// Full determines whether a full push is required or not. If false, an incremental update will be sent. // Incremental pushes: // * Do not recompute the push context // * Do not recompute proxy state (such as ServiceInstances) // * Are not reported in standard metrics such as push time // As a result, configuration updates should never be incremental. Generally, only EDS will set this, but // in the future SDS will as well. Full bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)