- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 191 for Handles (0.19 sec)
-
src/unique/handle_bench_test.go
} func BenchmarkMakeManyMany(b *testing.B) { benchmarkMake(b, testDataLarge[:]) } func benchmarkMake(b *testing.B, testData []string) { handles := make([]Handle[string], 0, len(testData)) for i := range testData { handles = append(handles, Make(testData[i])) } b.ReportAllocs() b.ResetTimer() b.RunParallel(func(pb *testing.PB) { i := 0 for pb.Next() { _ = Make(testData[i])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 18:14:07 UTC 2024 - 1.1K bytes - Viewed (0) -
src/unique/handle.go
"internal/weak" "runtime" "sync" _ "unsafe" ) // Handle is a globally unique identity for some value of type T. // // Two handles compare equal exactly if the two values used to create the handles // would have also compared equal. The comparison of two handles is trivial and // typically much more efficient than comparing the values used to create them. type Handle[T comparable] struct { value *T }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 16:01:55 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/proxy/node.go
klog.FlushAndExit(klog.ExitFlushTimeout, 1) } } // OnNodeDelete is a handler for Node deletes. func (n *NodePodCIDRHandler) OnNodeDelete(node *v1.Node) { n.logger.Error(nil, "Current Node is being deleted", "node", klog.KObj(node)) } // OnNodeSynced is a handler for Node syncs. func (n *NodePodCIDRHandler) OnNodeSynced() {} // NodeEligibleHandler handles the life cycle of the Node's eligibility, as
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/jvm/plugins-java/src/integTest/groovy/org/gradle/java/compile/daemon/DaemonJavaCompilerIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 31 20:20:39 UTC 2024 - 4.4K bytes - Viewed (0) -
security/pkg/nodeagent/test/mock/caserver.go
} cert := pem.EncodeToMemory(block) return cert, nil } // Check handles health check requests. func (s *CAServer) Check(ctx context.Context, in *ghc.HealthCheckRequest) (*ghc.HealthCheckResponse, error) { return &ghc.HealthCheckResponse{ Status: ghc.HealthCheckResponse_SERVING, }, nil } // Watch handles health check streams.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5.9K bytes - Viewed (0) -
doc/next/6-stdlib/2-unique.md
`Make[T]` function, which produces a reference to a canonical copy of the value in the form of a `Handle[T]`. Two `Handle[T]` are equal if and only if the values used to produce the handles are equal, allowing programs to deduplicate values and reduce their memory footprint. Comparing two `Handle[T]` values is efficient, reducing down to a simple
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 18:34:13 UTC 2024 - 566 bytes - Viewed (0) -
pilot/pkg/bootstrap/webhook.go
} return len(p), nil } // initSSecureWebhookServer handles initialization for the HTTPS webhook server. // If https address is off the injection handlers will be registered on the main http endpoint, with // TLS handled by a proxy/gateway in front of Istiod. func (s *Server) initSecureWebhookServer(args *PilotArgs) { // create the https server for hosting the k8s injectionWebhook handlers. if args.ServerOptions.HTTPSAddr == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 17:37:53 UTC 2024 - 2.7K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/test/groovy/org/gradle/jvm/toolchain/internal/WindowsInstallationSupplierTest.groovy
} def "handles absent adoptopenjdk keys"() { given: registry.getSubkeys(WindowsRegistry.Key.HKEY_LOCAL_MACHINE, _) >> { throw new MissingRegistryEntryException() } def supplier = createSupplier() when: def locations = supplier.get() then: locations.isEmpty() } def "gracefully handles unavailable native integration"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 08 22:14:10 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/kubeapiserver/admission/initializer_test.go
) type doNothingAdmission struct{} func (doNothingAdmission) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error { return nil } func (doNothingAdmission) Handles(o admission.Operation) bool { return false } func (doNothingAdmission) Validate() error { return nil } type WantsCloudConfigAdmissionPlugin struct { doNothingAdmission cloudConfig []byte }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 1.5K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/test/TestTaskPropertiesServiceIntegrationTest.groovy
.addConverter(new groovy.json.JsonGenerator.Converter() { @Override boolean handles(Class<?> type) { ${Stream.name}.isAssignableFrom(type) } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 10:21:26 UTC 2024 - 7.9K bytes - Viewed (0)