Class: Nucleon::Action::Node::Upload
- Inherits:
-
Object
- Object
- Nucleon::Action::Node::Upload
- Defined in:
- lib/nucleon/action/node/upload.rb
Class Method Summary collapse
-
.describe ⇒ Object
—————————————————————————– Info.
Instance Method Summary collapse
- #arguments ⇒ Object
-
#configure ⇒ Object
—————————————————————————– Settings.
-
#execute ⇒ Object
—————————————————————————– Operations.
-
#ignore ⇒ Object
—.
Class Method Details
.describe ⇒ Object
Info
10 11 12 |
# File 'lib/nucleon/action/node/upload.rb', line 10 def self.describe super(:node, :upload, 500) end |
Instance Method Details
#arguments ⇒ Object
53 54 55 |
# File 'lib/nucleon/action/node/upload.rb', line 53 def arguments [ :local_path, :remote_path, :upload_nodes ] end |
#configure ⇒ Object
Settings
17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/nucleon/action/node/upload.rb', line 17 def configure super do register_str :local_path, nil register_str :remote_path, nil register_str :file_mode, '0755' register_bool :progress, true register_array :upload_nodes, nil do |values| if values.nil? warn('upload_nodes_empty') next false end node_plugins = CORL.loaded_plugins(:CORL, :node) success = true values.each do |value| if info = CORL.plugin_class(:CORL, :node).translate_reference(value) if ! node_plugins.keys.include?(info[:provider].to_sym) || info[:name].empty? warn('upload_nodes', { :value => value, :node_provider => info[:provider], :name => info[:name] }) success = false end end end success end end end |
#execute ⇒ Object
Operations
60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 |
# File 'lib/nucleon/action/node/upload.rb', line 60 def execute super do |local_node| ensure_network do batch_success = network.batch(settings[:upload_nodes], settings[:node_provider], settings[:parallel]) do |node| = { :id => node.id, :hostname => node.hostname, :local_path => settings[:local_path], :remote_path => settings[:remote_path] } info('start', ) success = node.send_files(settings[:local_path], settings[:remote_path], nil, settings[:file_mode], { :progress => settings[:progress] }) if success success('complete', ) else error('failure', ) end success end myself.status = code.batch_error unless batch_success end end end |
#ignore ⇒ Object
49 50 51 |
# File 'lib/nucleon/action/node/upload.rb', line 49 def ignore [ :nodes ] end |