Method wait

cache/memcached_client.go:627–640

wait submits an async task and blocks until it completes. This can be used during tests to ensure that async "sets" have completed before attempting to read them.

()

// wait submits an async task and blocks until it completes. This can be used during
// tests to ensure that async "sets" have completed before attempting to read them.
func (c *MemcachedClient) wait() error {
	var wg sync.WaitGroup

	wg.Add(1)
	err := c.queue.submit(func() {
		wg.Done()
	})
	if err != nil {
		return err
	}

	wg.Wait()
	return nil
}

func (c *MemcachedClient) trackError(op string, err error, msg ...interface{}) {
	severity := level.DebugValue()