- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for getDevice (0.18 sec)
-
pilot/pkg/serviceregistry/aggregate/controller.go
mergeService(services[previous], s, r) } } } } return services } // GetService retrieves a service by hostname if exists func (c *Controller) GetService(hostname host.Name) *model.Service { var out *model.Service for _, r := range c.GetRegistries() { service := r.GetService(hostname) if service == nil { continue } if r.Provider() != provider.Kubernetes { return service
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Jan 05 13:06:39 UTC 2023 - 29.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultMavenPluginManager.java
if (pathScope != null && !pathScope.isEmpty()) { // resolution PathScope ps = sessionV4.getService(PathScopeRegistry.class).require(pathScope); DependencyResolverResult res = sessionV4.getService(DependencyResolver.class).resolve(sessionV4, project, ps); if (field.getType() == DependencyResolverResult.class) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 46.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
// Get service from mockAdapter1 svc := aggregateCtl.GetService(mock.HelloService.Hostname) if svc == nil { t.Fatal("Fail to get service") } if svc.Hostname != mock.HelloService.Hostname { t.Fatal("Returned service is incorrect") } // Get service from mockAdapter2 svc = aggregateCtl.GetService(mock.WorldService.Hostname) if svc == nil { t.Fatal("Fail to get service") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
out = append(out, svc) } c.RUnlock() sort.Slice(out, func(i, j int) bool { return out[i].Hostname < out[j].Hostname }) return out } // GetService implements a service catalog operation by hostname specified. func (c *Controller) GetService(hostname host.Name) *model.Service { c.RLock() svc := c.servicesMap[hostname] c.RUnlock() return svc } // getPodLocality retrieves the locality for a pod.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_launch_util_gpu_test.cc
auto device = DeviceFactory::NewDevice(device_type.type_string(), SessionOptions(), "/job:localhost/replica:0/task:0"); device_ = device.get(); SetDevice(device_type, std::move(device)); XlaShapeLayoutHelpers::ShapeDeterminationFns shape_fns{ UseNoPreferenceLayoutFn(), IdentityShapeRepresentationFn()}; device_context_ = core::RefCountPtr<DeviceContext>(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 10K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/WorkNodeCodec.kt
setupNode.run(object : NodeExecutionContext { override fun <T : Any> getService(type: Class<T>): T { return ownerService(type) } }) successors = successors + setupNode.postExecutionNodes } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 10.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
var endpoints []*model.IstioEndpoint if slice.AddressType == v1.AddressTypeFQDN { // TODO(https://github.com/istio/istio/issues/34995) support FQDN endpointslice return } svc := esc.c.GetService(hostName) discoverabilityPolicy := esc.c.exports.EndpointDiscoverabilityPolicy(svc) for _, e := range slice.Endpoints { // Draining tracking is only enabled if persistent sessions is enabled.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/internal/BootstrapCoreExtensionManager.java
return new SimpleSession(mavenSession, getRepositorySystem(), repositories); } @Override public <T extends Service> T getService(Class<T> clazz) throws NoSuchElementException { if (clazz == ArtifactCoordinateFactory.class) { return (T) new DefaultArtifactCoordinateFactory();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Jun 12 07:49:10 UTC 2024 - 13K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/featurelifecycle/LoggingDeprecatedFeatureHandler.java
} }) .severity(WARNING); addPossibleLocation(diagnostics, problemSpec); addSolution(usage.getAdvice(), problemSpec); addSolution(usage.getContextualAdvice(), problemSpec); } }); reporter.report(problem); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 12.4K bytes - Viewed (0)