MCPcopy Index your code
hub / github.com/cloudtty/cloudtty / worker

Method worker

pkg/controllers/cloudshell_controller.go:209–217  ·  view source on GitHub ↗
(stopCh <-chan struct{})

Source from the content-addressed store, hash-verified

207}
208
209func (c *Controller) worker(stopCh <-chan struct{}) {
210 for c.processNextItem() {
211 select {
212 case <-stopCh:
213 return
214 default:
215 }
216 }
217}
218
219func (c *Controller) Run(workers int, stopCh <-chan struct{}) {
220 defer utilruntime.HandleCrash()

Callers 1

RunMethod · 0.95

Calls 1

processNextItemMethod · 0.95

Tested by

no test coverage detected