Method start

pkg/allocator/cache.go:260–275

start requests a LIST operation from the kvstore and starts watching the prefix in a go subroutine.

()

// start requests a LIST operation from the kvstore and starts watching the
// prefix in a go subroutine.
func (c *cache) start() waitChan {
	c.listDone = make(waitChan)

	c.mutex.Lock()

	// start with a fresh nextCache
	c.nextCache = idMap{}
	c.nextKeyCache = keyMap{}
	c.mutex.Unlock()

	c.stopWatchWg.Go(func() {
		c.allocator.backend.ListAndWatch(c.ctx, c)
	})

	return c.listDone
}

func (c *cache) stop() {
	c.cancel()