- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 4,017 for startm (0.12 sec)
-
pkg/kube/multicluster/cluster.go
// This must be done before we build components, so they can access the filter. namespaces := kclient.New[*corev1.Namespace](c.Client) // This will start a namespace informer and wait for it to be ready. So we must start it in a go routine to avoid blocking. filter := filter.NewDiscoveryNamespacesFilter(namespaces, mesh, c.stop) kube.SetObjectFilter(c.Client, filter)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/timeout/TimeoutHandler.java
/** * Starts a timeout for the given thread. The thread is interrupted if the given timeout is exceeded. * The returned {@link Timeout} object must be used to stop the timeout once the thread has completed * the work that this timeout was supposed to limit, otherwise it may be interrupted doing * some other work later. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 1.6K bytes - Viewed (0) -
security/pkg/util/certutil_test.go
// Cert TTL is 24h, and grace period is 50% of TTL, that is 12h. // The cert expires at 2017-08-24 19:00:40 +0000 UTC, so the grace period starts at 2017-08-24 07:00:40 +0000 UTC // The wait time is the duration from fake now to the grace period start time, which is 10h39s (36039s). cert: testCert, now: time.Date(2017, time.August, 23, 21, 0, 0, 40, time.UTC), expectedWaitTime: 36039,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 30 19:33:26 UTC 2023 - 3.1K bytes - Viewed (0) -
src/internal/filepathlite/path_windows.go
return uncLen(path, len(`\\.\UNC\`)) case pathHasPrefixFold(path, `\\.`) || pathHasPrefixFold(path, `\\?`) || pathHasPrefixFold(path, `\??`): // Path starts with \\.\, and is a Local Device path; or // path starts with \\?\ or \??\ and is a Root Local Device path. // // We treat the next component after the \\.\ prefix as // part of the volume name, which means Clean(`\\?\c:\`)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:50 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/tracing/tracing.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 26 01:07:39 UTC 2023 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v1beta1/kms_plugin_mock.go
return s.lastEncryptRequest.Plain } // SetVersion sets the version of kms-plugin. func (s *Base64Plugin) SetVersion(ver string) { s.ver = ver } // start starts plugin's gRPC service. func (s *Base64Plugin) start() error { var err error s.listener, err = net.Listen(unixProtocol, s.socketPath) if err != nil { return fmt.Errorf("failed to listen on the unix socket, error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 5.2K bytes - Viewed (0) -
src/cmd/trace/gstate.go
} // start indicates that a goroutine has started running on a proc. func (gs *gState[R]) start(ts trace.Time, resource R, ctx *traceContext) { // Set the time for all the active ranges. for name := range gs.activeRanges { gs.activeRanges[name] = activeRange{ts, trace.NoStack} } if gs.startCause.name != "" { // It has a start cause. Emit a flow event.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/ExecHandle.java
File getDirectory(); String getCommand(); List<String> getArguments(); Map<String, String> getEnvironment(); /** * Starts this process, blocking until the process has started. * * @return this */ ExecHandle start(); void removeStartupContext(); ExecHandleState getState(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 21:45:01 UTC 2024 - 1.8K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go
} }() wg1.Wait() time.Sleep(blackOut) // Start KMS Plugin _ = mock.NewBase64Plugin(t, endpoint.path) t.Log("Restarted KMS Plugin") wg2.Wait() if encryptErr != nil { t.Error(encryptErr) } } // Normal encryption and decryption operation. func TestGRPCService(t *testing.T) { t.Parallel() // Start a test gRPC server. endpoint := newEndpoint()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 12.7K bytes - Viewed (0)