Method withImmediateTransaction

internal/resources/kernel.go:1267–1278

(
	ctx context.Context,
	action string,
	run func(exec sqlExecutor) error,
)

}

func (k *Kernel) withImmediateTransaction(
	ctx context.Context,
	action string,
	run func(exec sqlExecutor) error,
) error {
	if err := store.ExecuteWrite(ctx, k.db, func(_ context.Context, tx *store.WriteTx) error {
		return run(tx)
	}); err != nil {
		return fmt.Errorf("resources: %s transaction: %w", action, err)
	}
	return nil
}

func (k *Kernel) lockSource(source ResourceSource) func() {
	key := string(source.Kind) + "\x00" + source.ID