Method AcquireReference

pkg/allocator/allocator_test.go:84–99

(ctx context.Context, id idpool.ID, key AllocatorKey, lock kvstore.KVLocker)

}

func (d *dummyBackend) AcquireReference(ctx context.Context, id idpool.ID, key AllocatorKey, lock kvstore.KVLocker) error {
	d.mutex.Lock()
	defer d.mutex.Unlock()

	if _, ok := d.masterKeys[id]; !ok {
		return fmt.Errorf("identity does not exist")
	}

	d.slaveKeys[id] = key

	if d.handler != nil {
		d.handler.OnUpsert(id, key)
	}

	return nil
}

type dummyLock struct{}