Sha256: a7d853cfe41296e51a68eb6ef5a694ae9b7e0432791939fd97e0a0900c9b1af1
Contents?: true
Size: 1.5 KB
Versions: 1
Compression:
Stored size: 1.5 KB
Contents
class KuberKit::Actions::ServiceDeployer include KuberKit::Import[ "actions.image_compiler", "service_deployer.service_list_resolver", "core.service_store", "shell.local_shell", "tools.logger", "ui", service_deployer: "service_deployer.action_handler", ] Contract KeywordArgs[ services: Maybe[ArrayOf[String]], tags: Maybe[ArrayOf[String]], ] => Any def call(services:, tags:) service_names = service_list_resolver.resolve( services: services || [], tags: tags || [] ) unless service_names.any? ui.print_warning "WARNING", "No service found with given options, nothing will be deployed." end services = service_names.map do |service_name| service_store.get_service(service_name.to_sym) end images_names = services.map(&:images).flatten.uniq compile_images(images_names) deploy_services(service_names) end def deploy_services(service_names) task_group = ui.create_task_group service_names.each do |service_name| logger.info("Started deploying: #{service_name.to_s.green}") task_group.add("Deploying #{service_name.to_s.yellow}") do |task| service_deployer.call(local_shell, service_name.to_sym) task.update_title("Deployed #{service_name.to_s.green}") logger.info("Finished deploying: #{service_name.to_s.green}") end end task_group.wait end def compile_images(images_names) image_compiler.call(images_names, {}) if images_names.any? end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
kuber_kit-0.1.7 | lib/kuber_kit/actions/service_deployer.rb |