Class: Central::Cli::Services::CreateCommand

Inherits:
Clamp::Command
  • Object
show all
Includes:
Common, ServicesHelper, Central::Cli::StackOptions
Defined in:
lib/central/cli/services/create_command.rb

Instance Method Summary collapse

Methods included from ServicesHelper

#create_service, #delete_service, #deploy_service, #get_service, #int_to_filesize, #parse_image, #parse_links, #parse_log_opts, #parse_memory, #parse_ports, #parse_relative_time, #parse_secrets, #parse_service_id, #restart_service, #scale_service, #show_service, #start_service, #stop_service, #update_service, #wait_for_deploy_to_finish

Methods included from Common

#access_token=, #add_master, #api_url, #api_url=, #clear_current_stack, #client, #current_master, #current_master=, #current_master_index, #current_stack, #current_stack=, #ensure_custom_ssl_ca, #require_api_url, #require_current_stack, #require_token, #reset_client, #save_settings, #settings, #settings_filename

Methods included from Central::Cli::StackOptions

included

Instance Method Details

#execute ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/central/cli/services/create_command.rb', line 38

def execute
  require_api_url
  token = require_token
  data = {
    name: name,
    image: image,
    stateful: stateful?
  }
  data.merge!(parse_service_data_from_options)
  create_service(token, current_stack, data)
end

#parse_service_data_from_options ⇒ Hash

parse given options to hash

Returns:

  • (Hash) 


53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/central/cli/services/create_command.rb', line 53

def parse_service_data_from_options
  data = {}
  data[:ports] = parse_ports(ports_list) unless ports_list.empty?
  data[:links] = parse_links(link_list) unless link_list.empty?
  data[:volumes] = volume_list unless volume_list.empty?
  data[:volumes_from] = volumes_from_list unless volumes_from_list.empty?
  data[:memory] = parse_memory(memory) if memory
  data[:memory_swap] = parse_memory(memory_swap) if memory_swap
  data[:cpu_shares] = cpu_shares if cpu_shares
  data[:affinity] = affinity_list unless affinity_list.empty?
  data[:env] = env_list unless env_list.empty?
  data[:secrets] = parse_secrets(secret_list)
  data[:container_count] = instances if instances
  data[:cmd] = cmd.split(' ') if cmd
  data[:user] = user if user
  data[:image] = parse_image(image) if image
  data[:privileged] = privileged?
  data[:cap_add] = cap_add_list unless cap_add_list.empty?
  data[:cap_drop] = cap_drop_list unless cap_drop_list.empty?
  data[:net] = net if net
  data[:log_driver] = log_driver if log_driver
  data[:log_opts] = parse_log_opts(log_opt_list)
  data[:strategy] = deploy_strategy if deploy_strategy
  data[:deploy_opts] = {}
  if deploy_min_health
    data[:deploy_opts][:min_health] = deploy_min_health.to_f
  end
  if deploy_wait_for_port
    data[:deploy_opts][:wait_for_port] = deploy_wait_for_port.to_i
  end
  if deploy_interval
    data[:deploy_opts][:interval] = parse_relative_time(deploy_interval)
  end
  data[:pid] = pid if pid
  data
end