- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 471 for stopCh (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
workers: workers, stopCh: stopCh, config: config, } // The queue underneath is starting a goroutine for metrics // exportint that is only stopped on calling ShutDown. // Given that QuotaEvaluator is created for each layer of apiserver // and often not started for some of those (e.g. aggregated apiserver) // we explicitly shut it down on stopCh signal even if it wasn't // effectively started.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
if isEventedPLEGInUse() { return } setEventedPLEGUsage(true) e.stopCh = make(chan struct{}) e.stopCacheUpdateCh = make(chan struct{}) go wait.Until(e.watchEventsChannel, 0, e.stopCh) go wait.Until(e.updateGlobalCache, globalCacheUpdatePeriod, e.stopCacheUpdateCh) } // Stop stops the Evented PLEG func (e *EventedPLEG) Stop() { e.runningMu.Lock() defer e.runningMu.Unlock() if !isEventedPLEGInUse() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
// always return ErrWaitTimeout. func Test_waitForWithEarlyClosing_waitFunc(t *testing.T) { stopCh := make(chan struct{}) defer close(stopCh) ctx := ContextForChannel(stopCh) start := time.Now() err := waitForWithContext(ctx, func(ctx context.Context) <-chan struct{} { c := make(chan struct{}) close(c) return c
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
// serialize the operations on ServiceCIDRs go wait.Until(r.cidrWorker, r.workerLoopPeriod, stopCh) for i := 0; i < workers; i++ { go wait.Until(r.ipWorker, r.workerLoopPeriod, stopCh) go wait.Until(r.svcWorker, r.workerLoopPeriod, stopCh) } <-stopCh } // runOnce verifies the state of the ClusterIP allocations and returns an error if an unrecoverable problem occurs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
plugin/pkg/admission/podtolerationrestriction/admission_test.go
handler, informerFactory, err := newHandlerForTest(mockClient) if err != nil { t.Fatalf("unexpected error initializing handler: %v", err) } stopCh := make(chan struct{}) defer close(stopCh) informerFactory.Start(stopCh) handler.pluginConfig = &pluginapi.Configuration{Default: test.defaultClusterTolerations, Whitelist: test.clusterWhitelist} pod := test.pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 22 17:10:53 UTC 2023 - 12.8K bytes - Viewed (0) -
pkg/kube/kclient/client.go
} return cast } func (n *informerClient[T]) applyFilter(t T) bool { if n.filter == nil { return true } return n.filter(t) } func (n *informerClient[T]) Start(stopCh <-chan struct{}) { n.startInformer(stopCh) } func (n *writeClient[T]) Create(object T) (T, error) { api := kubeclient.GetWriteClient[T](n.client, object.GetNamespace()) return api.Create(context.Background(), object, metav1.CreateOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go
ExecSeatsGaugeVec: metrics.PriorityLevelExecutionSeatsGaugeVec, QueueSetFactory: cts, }) stopCh, controllerCompletedCh := make(chan struct{}), make(chan struct{}) var controllerErr error informerFactory.Start(stopCh) ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() status := informerFactory.WaitForCacheSync(ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 18.4K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair.go
func (c *Repair) RunUntil(onFirstSuccess func(), stopCh chan struct{}) { c.broadcaster.StartRecordingToSink(stopCh) defer c.broadcaster.Shutdown() var once sync.Once wait.Until(func() { if err := c.runOnce(); err != nil { runtime.HandleError(err) return } once.Do(onFirstSuccess) }, c.interval, stopCh) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
} close(graceCh) }() // close stopCh after request sent to server to guarantee request handler is running. wg.Wait() close(stopCh) time.Sleep(500 * time.Millisecond) if _, err := http.Get("http://127.0.0.1:" + strconv.Itoa(serverPort) + "/200"); err == nil { t.Errorf("Unexpected http success after stopCh was closed") } // wait for wait group handler finish
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0)