- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,432 for stopCh (0.18 sec)
-
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) -
pkg/registry/apps/statefulset/storage/storage_test.go
return currentObject, nil } } stopCh := make(chan struct{}) wg := &sync.WaitGroup{} wg.Add(1) go func() { defer wg.Done() // continuously submits a patch that updates a label and verifies the label update was effective labelName := "timestamp" for i := 0; ; i++ { select { case <-stopCh: return default: expectedLabelValue := fmt.Sprint(i)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/log/backend.go
return false } if _, err := fmt.Fprint(b.out, line); err != nil { audit.HandlePluginError(PluginName, err, ev) return false } return true } func (b *backend) Run(stopCh <-chan struct{}) error { return nil } func (b *backend) Shutdown() { // Nothing to do here. } func (b *backend) String() string { return PluginName
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 03 14:38:47 UTC 2019 - 2.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) -
pkg/kubelet/prober/prober_manager_test.go
setTestProbe(testPod, readiness, v1.Probe{}) m := newTestManager() defer cleanup(t, m) // Start syncing readiness without leaking goroutine. stopCh := make(chan struct{}) go wait.Until(m.extractedReadinessHandling, 0, stopCh) defer func() { close(stopCh) // Send an update to exit extractedReadinessHandling() m.readinessManager.Set(kubecontainer.ContainerID{}, results.Success, &v1.Pod{}) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/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 - 13.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_fake.go
} return &FakeVolumeManager{ volumes: volumes, reportedInUse: map[v1.UniqueVolumeName]bool{}, } } // Run is not implemented func (f *FakeVolumeManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { } // WaitForAttachAndMount is not implemented func (f *FakeVolumeManager) WaitForAttachAndMount(ctx context.Context, pod *v1.Pod) error { return nil } // WaitForUnmount is not implemented
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/util/iptables/iptables.go
return false, nil } } return true, nil }, stopCh) // Poll until stopCh is closed or iptables is flushed err := utilwait.PollUntil(interval, func() (bool, error) { if exists, err := runner.ChainExists(tables[0], canary); exists { return false, nil } else if isResourceError(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 28.6K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
g.runningMu.Lock() defer g.runningMu.Unlock() if !g.isRunning { g.isRunning = true g.stopCh = make(chan struct{}) go wait.Until(g.Relist, g.relistDuration.RelistPeriod, g.stopCh) } } func (g *GenericPLEG) Stop() { g.runningMu.Lock() defer g.runningMu.Unlock() if g.isRunning { close(g.stopCh) g.isRunning = false } } func (g *GenericPLEG) Update(relistDuration *RelistDuration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0)