Method acquire

enterprise/tailnet/pgcoord.go:1567–1573

acquire blocks until a work item is available and returns it. After acquiring a key, the worker MUST call done() with the same key to mark it complete and allow new pending work to be acquired for the key.

()

// acquiring a key, the worker MUST call done() with the same key to mark
// it complete and allow new pending work to be acquired for the key.
func (q *workQ[K]) acquire() (key K, err error) {
	items, err := q.acquireBatch(1)
	if err != nil {
		return key, err
	}
	return items[0], nil
}

// done marks the key completed; MUST be called after acquire() for each key.
func (q *workQ[K]) done(keys ...K) {