You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

271 lines
11 KiB

Added file and container image caching (#4828) * File and container image downloads are now cached localy, so that repeated vagrant up/down runs do not trigger downloading of those files. This is especially useful on laptops with kubernetes runnig locally on vm's. The total size of the cache, after an ansible run, is currently around 800MB, so bandwidth (=time) savings can be quite significant. * When download_run_once is false, the default is still not to cache, but setting download_force_cache will still enable caching. * The local cache location can be set with download_cache_dir and defaults to /tmp/kubernetes_cache * A local docker instance is no longer required to cache docker images; Images are cached to file. A local docker instance is still required, though, if you wish to download images on localhost. * Fixed a FIXME, wher the argument was that delegate_to doesn't play nice with omit. That is a correct observation and the fix is to use default(inventory_host) instead of default(omit). See ansible/ansible#26009 * Removed "Register docker images info" task from download_container and set_docker_image_facts because it was faulty and unused. * Removed redundant when:download.{container,enabled,run_once} conditions from {sync,download}_container.yml * All features of commit d6fd0d2acaec9f53e75d82db30411f96a5bf2cc9 by Timoses <timosesu@gmail.com>, merged May 1st 2019, are included in this patch. Not all code was included verbatim, but each feature of that commit was checked to be working in this patch. One notable change: The actual downloading of the kubeadm images was moved to {download,sync)_container, to enable caching. Note 1: I considered splitting this patch, but most changes that are not directly related to caching, are a pleasant by-product of implementing the caching code, so splitting would be impractical. Note 2: I have my doubts about the usefulness of the upload, download and upgrade tags in the download role. Must they remain or can they be removed? If anybody knows, then please speak up.
5 years ago
Added file and container image caching (#4828) * File and container image downloads are now cached localy, so that repeated vagrant up/down runs do not trigger downloading of those files. This is especially useful on laptops with kubernetes runnig locally on vm's. The total size of the cache, after an ansible run, is currently around 800MB, so bandwidth (=time) savings can be quite significant. * When download_run_once is false, the default is still not to cache, but setting download_force_cache will still enable caching. * The local cache location can be set with download_cache_dir and defaults to /tmp/kubernetes_cache * A local docker instance is no longer required to cache docker images; Images are cached to file. A local docker instance is still required, though, if you wish to download images on localhost. * Fixed a FIXME, wher the argument was that delegate_to doesn't play nice with omit. That is a correct observation and the fix is to use default(inventory_host) instead of default(omit). See ansible/ansible#26009 * Removed "Register docker images info" task from download_container and set_docker_image_facts because it was faulty and unused. * Removed redundant when:download.{container,enabled,run_once} conditions from {sync,download}_container.yml * All features of commit d6fd0d2acaec9f53e75d82db30411f96a5bf2cc9 by Timoses <timosesu@gmail.com>, merged May 1st 2019, are included in this patch. Not all code was included verbatim, but each feature of that commit was checked to be working in this patch. One notable change: The actual downloading of the kubeadm images was moved to {download,sync)_container, to enable caching. Note 1: I considered splitting this patch, but most changes that are not directly related to caching, are a pleasant by-product of implementing the caching code, so splitting would be impractical. Note 2: I have my doubts about the usefulness of the upload, download and upgrade tags in the download role. Must they remain or can they be removed? If anybody knows, then please speak up.
5 years ago
Added file and container image caching (#4828) * File and container image downloads are now cached localy, so that repeated vagrant up/down runs do not trigger downloading of those files. This is especially useful on laptops with kubernetes runnig locally on vm's. The total size of the cache, after an ansible run, is currently around 800MB, so bandwidth (=time) savings can be quite significant. * When download_run_once is false, the default is still not to cache, but setting download_force_cache will still enable caching. * The local cache location can be set with download_cache_dir and defaults to /tmp/kubernetes_cache * A local docker instance is no longer required to cache docker images; Images are cached to file. A local docker instance is still required, though, if you wish to download images on localhost. * Fixed a FIXME, wher the argument was that delegate_to doesn't play nice with omit. That is a correct observation and the fix is to use default(inventory_host) instead of default(omit). See ansible/ansible#26009 * Removed "Register docker images info" task from download_container and set_docker_image_facts because it was faulty and unused. * Removed redundant when:download.{container,enabled,run_once} conditions from {sync,download}_container.yml * All features of commit d6fd0d2acaec9f53e75d82db30411f96a5bf2cc9 by Timoses <timosesu@gmail.com>, merged May 1st 2019, are included in this patch. Not all code was included verbatim, but each feature of that commit was checked to be working in this patch. One notable change: The actual downloading of the kubeadm images was moved to {download,sync)_container, to enable caching. Note 1: I considered splitting this patch, but most changes that are not directly related to caching, are a pleasant by-product of implementing the caching code, so splitting would be impractical. Note 2: I have my doubts about the usefulness of the upload, download and upgrade tags in the download role. Must they remain or can they be removed? If anybody knows, then please speak up.
5 years ago
  1. # -*- mode: ruby -*-
  2. # # vi: set ft=ruby :
  3. # For help on using kubespray with vagrant, check out docs/vagrant.md
  4. require 'fileutils'
  5. Vagrant.require_version ">= 2.0.0"
  6. CONFIG = File.join(File.dirname(__FILE__), ENV['KUBESPRAY_VAGRANT_CONFIG'] || 'vagrant/config.rb')
  7. FLATCAR_URL_TEMPLATE = "https://%s.release.flatcar-linux.net/amd64-usr/current/flatcar_production_vagrant.json"
  8. # Uniq disk UUID for libvirt
  9. DISK_UUID = Time.now.utc.to_i
  10. SUPPORTED_OS = {
  11. "flatcar-stable" => {box: "flatcar-stable", user: "core", box_url: FLATCAR_URL_TEMPLATE % ["stable"]},
  12. "flatcar-beta" => {box: "flatcar-beta", user: "core", box_url: FLATCAR_URL_TEMPLATE % ["beta"]},
  13. "flatcar-alpha" => {box: "flatcar-alpha", user: "core", box_url: FLATCAR_URL_TEMPLATE % ["alpha"]},
  14. "flatcar-edge" => {box: "flatcar-edge", user: "core", box_url: FLATCAR_URL_TEMPLATE % ["edge"]},
  15. "ubuntu1604" => {box: "generic/ubuntu1604", user: "vagrant"},
  16. "ubuntu1804" => {box: "generic/ubuntu1804", user: "vagrant"},
  17. "ubuntu2004" => {box: "generic/ubuntu2004", user: "vagrant"},
  18. "centos" => {box: "centos/7", user: "vagrant"},
  19. "centos-bento" => {box: "bento/centos-7.6", user: "vagrant"},
  20. "centos8" => {box: "centos/8", user: "vagrant"},
  21. "centos8-bento" => {box: "bento/centos-8", user: "vagrant"},
  22. "almalinux8" => {box: "almalinux/8", user: "vagrant"},
  23. "almalinux8-bento" => {box: "bento/almalinux-8", user: "vagrant"},
  24. "fedora34" => {box: "fedora/34-cloud-base", user: "vagrant"},
  25. "fedora35" => {box: "fedora/35-cloud-base", user: "vagrant"},
  26. "opensuse" => {box: "opensuse/Leap-15.3.x86_64", user: "vagrant"},
  27. "opensuse-tumbleweed" => {box: "opensuse/Tumbleweed.x86_64", user: "vagrant"},
  28. "oraclelinux" => {box: "generic/oracle7", user: "vagrant"},
  29. "oraclelinux8" => {box: "generic/oracle8", user: "vagrant"},
  30. "rhel7" => {box: "generic/rhel7", user: "vagrant"},
  31. "rhel8" => {box: "generic/rhel8", user: "vagrant"},
  32. }
  33. if File.exist?(CONFIG)
  34. require CONFIG
  35. end
  36. # Defaults for config options defined in CONFIG
  37. $num_instances ||= 3
  38. $instance_name_prefix ||= "k8s"
  39. $vm_gui ||= false
  40. $vm_memory ||= 2048
  41. $vm_cpus ||= 2
  42. $shared_folders ||= {}
  43. $forwarded_ports ||= {}
  44. $subnet ||= "172.18.8"
  45. $subnet_ipv6 ||= "fd3c:b398:0698:0756"
  46. $os ||= "ubuntu1804"
  47. $network_plugin ||= "flannel"
  48. # Setting multi_networking to true will install Multus: https://github.com/intel/multus-cni
  49. $multi_networking ||= "False"
  50. $download_run_once ||= "True"
  51. $download_force_cache ||= "False"
  52. # The first three nodes are etcd servers
  53. $etcd_instances ||= $num_instances
  54. # The first two nodes are kube masters
  55. $kube_master_instances ||= $num_instances == 1 ? $num_instances : ($num_instances - 1)
  56. # All nodes are kube nodes
  57. $kube_node_instances ||= $num_instances
  58. # The following only works when using the libvirt provider
  59. $kube_node_instances_with_disks ||= false
  60. $kube_node_instances_with_disks_size ||= "20G"
  61. $kube_node_instances_with_disks_number ||= 2
  62. $override_disk_size ||= false
  63. $disk_size ||= "20GB"
  64. $local_path_provisioner_enabled ||= "False"
  65. $local_path_provisioner_claim_root ||= "/opt/local-path-provisioner/"
  66. $libvirt_nested ||= false
  67. # boolean or string (e.g. "-vvv")
  68. $ansible_verbosity ||= false
  69. $playbook ||= "cluster.yml"
  70. host_vars = {}
  71. $box = SUPPORTED_OS[$os][:box]
  72. # if $inventory is not set, try to use example
  73. $inventory = "inventory/sample" if ! $inventory
  74. $inventory = File.absolute_path($inventory, File.dirname(__FILE__))
  75. # if $inventory has a hosts.ini file use it, otherwise copy over
  76. # vars etc to where vagrant expects dynamic inventory to be
  77. if ! File.exist?(File.join(File.dirname($inventory), "hosts.ini"))
  78. $vagrant_ansible = File.join(File.dirname(__FILE__), ".vagrant", "provisioners", "ansible")
  79. FileUtils.mkdir_p($vagrant_ansible) if ! File.exist?($vagrant_ansible)
  80. $vagrant_inventory = File.join($vagrant_ansible,"inventory")
  81. FileUtils.rm_f($vagrant_inventory)
  82. FileUtils.ln_s($inventory, $vagrant_inventory)
  83. end
  84. if Vagrant.has_plugin?("vagrant-proxyconf")
  85. $no_proxy = ENV['NO_PROXY'] || ENV['no_proxy'] || "127.0.0.1,localhost"
  86. (1..$num_instances).each do |i|
  87. $no_proxy += ",#{$subnet}.#{i+100}"
  88. end
  89. end
  90. Vagrant.configure("2") do |config|
  91. config.vm.box = $box
  92. if SUPPORTED_OS[$os].has_key? :box_url
  93. config.vm.box_url = SUPPORTED_OS[$os][:box_url]
  94. end
  95. config.ssh.username = SUPPORTED_OS[$os][:user]
  96. # plugin conflict
  97. if Vagrant.has_plugin?("vagrant-vbguest") then
  98. config.vbguest.auto_update = false
  99. end
  100. # always use Vagrants insecure key
  101. config.ssh.insert_key = false
  102. if ($override_disk_size)
  103. unless Vagrant.has_plugin?("vagrant-disksize")
  104. system "vagrant plugin install vagrant-disksize"
  105. end
  106. config.disksize.size = $disk_size
  107. end
  108. (1..$num_instances).each do |i|
  109. config.vm.define vm_name = "%s-%01d" % [$instance_name_prefix, i] do |node|
  110. node.vm.hostname = vm_name
  111. if Vagrant.has_plugin?("vagrant-proxyconf")
  112. node.proxy.http = ENV['HTTP_PROXY'] || ENV['http_proxy'] || ""
  113. node.proxy.https = ENV['HTTPS_PROXY'] || ENV['https_proxy'] || ""
  114. node.proxy.no_proxy = $no_proxy
  115. end
  116. ["vmware_fusion", "vmware_workstation"].each do |vmware|
  117. node.vm.provider vmware do |v|
  118. v.vmx['memsize'] = $vm_memory
  119. v.vmx['numvcpus'] = $vm_cpus
  120. end
  121. end
  122. node.vm.provider :virtualbox do |vb|
  123. vb.memory = $vm_memory
  124. vb.cpus = $vm_cpus
  125. vb.gui = $vm_gui
  126. vb.linked_clone = true
  127. vb.customize ["modifyvm", :id, "--vram", "8"] # ubuntu defaults to 256 MB which is a waste of precious RAM
  128. vb.customize ["modifyvm", :id, "--audio", "none"]
  129. end
  130. node.vm.provider :libvirt do |lv|
  131. lv.nested = $libvirt_nested
  132. lv.cpu_mode = "host-model"
  133. lv.memory = $vm_memory
  134. lv.cpus = $vm_cpus
  135. lv.default_prefix = 'kubespray'
  136. # Fix kernel panic on fedora 28
  137. if $os == "fedora"
  138. lv.cpu_mode = "host-passthrough"
  139. end
  140. end
  141. if $kube_node_instances_with_disks
  142. # Libvirt
  143. driverletters = ('a'..'z').to_a
  144. node.vm.provider :libvirt do |lv|
  145. # always make /dev/sd{a/b/c} so that CI can ensure that
  146. # virtualbox and libvirt will have the same devices to use for OSDs
  147. (1..$kube_node_instances_with_disks_number).each do |d|
  148. lv.storage :file, :device => "hd#{driverletters[d]}", :path => "disk-#{i}-#{d}-#{DISK_UUID}.disk", :size => $kube_node_instances_with_disks_size, :bus => "ide"
  149. end
  150. end
  151. end
  152. if $expose_docker_tcp
  153. node.vm.network "forwarded_port", guest: 2375, host: ($expose_docker_tcp + i - 1), auto_correct: true
  154. end
  155. $forwarded_ports.each do |guest, host|
  156. node.vm.network "forwarded_port", guest: guest, host: host, auto_correct: true
  157. end
  158. if ["rhel7","rhel8"].include? $os
  159. # Vagrant synced_folder rsync options cannot be used for RHEL boxes as Rsync package cannot
  160. # be installed until the host is registered with a valid Red Hat support subscription
  161. node.vm.synced_folder ".", "/vagrant", disabled: false
  162. $shared_folders.each do |src, dst|
  163. node.vm.synced_folder src, dst
  164. end
  165. else
  166. node.vm.synced_folder ".", "/vagrant", disabled: false, type: "rsync", rsync__args: ['--verbose', '--archive', '--delete', '-z'] , rsync__exclude: ['.git','venv']
  167. $shared_folders.each do |src, dst|
  168. node.vm.synced_folder src, dst, type: "rsync", rsync__args: ['--verbose', '--archive', '--delete', '-z']
  169. end
  170. end
  171. ip = "#{$subnet}.#{i+100}"
  172. node.vm.network :private_network, ip: ip,
  173. :libvirt__guest_ipv6 => 'yes',
  174. :libvirt__ipv6_address => "#{$subnet_ipv6}::#{i+100}",
  175. :libvirt__ipv6_prefix => "64",
  176. :libvirt__forward_mode => "none",
  177. :libvirt__dhcp_enabled => false
  178. # Disable swap for each vm
  179. node.vm.provision "shell", inline: "swapoff -a"
  180. # ubuntu1804 and ubuntu2004 have IPv6 explicitly disabled. This undoes that.
  181. if ["ubuntu1804", "ubuntu2004"].include? $os
  182. node.vm.provision "shell", inline: "rm -f /etc/modprobe.d/local.conf"
  183. node.vm.provision "shell", inline: "sed -i '/net.ipv6.conf.all.disable_ipv6/d' /etc/sysctl.d/99-sysctl.conf /etc/sysctl.conf"
  184. end
  185. # Disable firewalld on oraclelinux/redhat vms
  186. if ["oraclelinux","oraclelinux8","rhel7","rhel8"].include? $os
  187. node.vm.provision "shell", inline: "systemctl stop firewalld; systemctl disable firewalld"
  188. end
  189. host_vars[vm_name] = {
  190. "ip": ip,
  191. "flannel_interface": "eth1",
  192. "kube_network_plugin": $network_plugin,
  193. "kube_network_plugin_multus": $multi_networking,
  194. "download_run_once": $download_run_once,
  195. "download_localhost": "False",
  196. "download_cache_dir": ENV['HOME'] + "/kubespray_cache",
  197. # Make kubespray cache even when download_run_once is false
  198. "download_force_cache": $download_force_cache,
  199. # Keeping the cache on the nodes can improve provisioning speed while debugging kubespray
  200. "download_keep_remote_cache": "False",
  201. "docker_rpm_keepcache": "1",
  202. # These two settings will put kubectl and admin.config in $inventory/artifacts
  203. "kubeconfig_localhost": "True",
  204. "kubectl_localhost": "True",
  205. "local_path_provisioner_enabled": "#{$local_path_provisioner_enabled}",
  206. "local_path_provisioner_claim_root": "#{$local_path_provisioner_claim_root}",
  207. "ansible_ssh_user": SUPPORTED_OS[$os][:user]
  208. }
  209. # Only execute the Ansible provisioner once, when all the machines are up and ready.
  210. # And limit the action to gathering facts, the full playbook is going to be ran by testcases_run.sh
  211. if i == $num_instances
  212. node.vm.provision "ansible" do |ansible|
  213. ansible.playbook = $playbook
  214. ansible.verbose = $ansible_verbosity
  215. $ansible_inventory_path = File.join( $inventory, "hosts.ini")
  216. if File.exist?($ansible_inventory_path)
  217. ansible.inventory_path = $ansible_inventory_path
  218. end
  219. ansible.become = true
  220. ansible.limit = "all,localhost"
  221. ansible.host_key_checking = false
  222. ansible.raw_arguments = ["--forks=#{$num_instances}", "--flush-cache", "-e ansible_become_pass=vagrant"]
  223. ansible.host_vars = host_vars
  224. ansible.tags = ['facts']
  225. ansible.groups = {
  226. "etcd" => ["#{$instance_name_prefix}-[1:#{$etcd_instances}]"],
  227. "kube_control_plane" => ["#{$instance_name_prefix}-[1:#{$kube_master_instances}]"],
  228. "kube_node" => ["#{$instance_name_prefix}-[1:#{$kube_node_instances}]"],
  229. "k8s_cluster:children" => ["kube_control_plane", "kube_node"],
  230. }
  231. end
  232. end
  233. end
  234. end
  235. end