- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 122 for isShutdown (0.17 sec)
-
pilot/cmd/pilot-agent/status/server.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
func (r *RepairIPAddress) RunUntil(onFirstSuccess func(), stopCh chan struct{}) { defer r.cidrQueue.ShutDown() defer r.ipQueue.ShutDown() defer r.svcQueue.ShutDown() r.broadcaster.StartRecordingToSink(stopCh) defer r.broadcaster.Shutdown() klog.Info("Starting ipallocator-repair-controller") defer klog.Info("Shutting down ipallocator-repair-controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
// informersStarted is closed after all the controllers have been initialized and are running. // After that it is safe to start them here, before that it is not. informersStarted <-chan struct{} // stopCh drives shutdown. When a reception from it unblocks, monitors will shut down. // This channel is also protected by monitorLock. stopCh <-chan struct{} // running tracks whether Run() has been called. // it is protected by monitorLock.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
} func (s *DiscoveryServer) sendPushes(stopCh <-chan struct{}) { doSendPushes(stopCh, s.concurrentPushLimit, s.pushQueue) } // Shutdown shuts down DiscoveryServer components. func (s *DiscoveryServer) Shutdown() { s.closeJwksResolver() s.pushQueue.ShutDown() } // Clients returns all currently connected clients. This method can be safely called concurrently,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
defer cancel() obj, disks, err := prepareErasure16(ctx) if err != nil { t.Fatalf("Prepare Erasure backend failed - %v", err) } setObjectLayer(obj) defer obj.Shutdown(context.Background()) defer removeRoots(disks) type tamperKind int const ( noTamper tamperKind = iota deletePart corruptPart ) timeSentinel := time.Unix(1, 0).UTC()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/artifacts/dsl/RepositoryHandler.java
* } * } * </pre> * * @param action a configuration action * @return the added repository * @deprecated JFrog announced JCenter's <a href="https://blog.gradle.org/jcenter-shutdown">sunset</a> in February 2021. Use {@link #mavenCentral()} instead. */ @Deprecated MavenArtifactRepository jcenter(Action<? super MavenArtifactRepository> action); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 03:42:11 UTC 2024 - 13.8K bytes - Viewed (0) -
pkg/features/kube_features.go
// beta: v1.21 // Adds support for kubelet to detect node shutdown and gracefully terminate pods prior to the node being shutdown. GracefulNodeShutdown featuregate.Feature = "GracefulNodeShutdown" // owner: @wzshiming // alpha: v1.23 // beta: v1.24 // Make the kubelet use shutdown configuration based on pod priority values for graceful shutdown.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
c.eventBroadcaster.StartLogging(klog.Infof) c.eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: c.client.CoreV1().Events("")}) defer c.eventBroadcaster.Shutdown() defer c.serviceQueue.ShutDown() defer c.topologyQueue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting endpoint slice controller") defer logger.Info("Shutting down endpoint slice controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
func (adc *attachDetachController) Run(ctx context.Context) { defer runtime.HandleCrash() defer adc.pvcQueue.ShutDown() // Start events processing pipeline. adc.broadcaster.StartStructuredLogging(3) adc.broadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: adc.kubeClient.CoreV1().Events("")}) defer adc.broadcaster.Shutdown() logger := klog.FromContext(ctx) logger.Info("Starting attach detach controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
future.get(); } catch (Throwable t) { // Ignore, we just wanted to block. } String error = errorMessage.get(); assertNull(error, error); } executor.shutdown(); } /** * He did the bash, he did the future bash The future bash, it was a concurrency smash He did the * bash, it caught on in a flash He did the bash, he did the future bash */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0)