Module: Service
- Defined in:
- lib/opennebula/oneflow_client.rb
Defined Under Namespace
Classes: Client
Constant Summary collapse
- STATE =
{ 'PENDING' => 0, 'DEPLOYING' => 1, 'RUNNING' => 2, 'UNDEPLOYING' => 3, 'WARNING' => 4, 'DONE' => 5, 'FAILED_UNDEPLOYING' => 6, 'FAILED_DEPLOYING' => 7, 'SCALING' => 8, 'FAILED_SCALING' => 9, 'COOLDOWN' => 10 }
- STATE_STR =
[ 'PENDING', 'DEPLOYING', 'RUNNING', 'UNDEPLOYING', 'WARNING', 'DONE', 'FAILED_UNDEPLOYING', 'FAILED_DEPLOYING', 'SCALING', 'FAILED_SCALING', 'COOLDOWN' ]
- DEFAULT_OPTIONS =
CLI options
[ ENDPOINT = { :name => "server", :short => "-s url", :large => "--server url", :format => String, :description => "Service endpoint" }, USERNAME={ :name => "username", :short => "-u name", :large => "--username name", :format => String, :description => "User name" }, PASSWORD={ :name => "password", :short => "-p pass", :large => "--password pass", :format => String, :description => "User password" } ]
- JSON_FORMAT =
{ :name => "json", :short => "-j", :large => "--json", :description => "Print the resource in JSON" }
- TOP =
{ :name => "top", :short => "-t", :large => "--top", :description => "Top for the command" }
- PERIOD =
{ :name => "period", :short => "-p x", :large => "--period x", :format => Integer, :description => "Seconds between each group of actions" }
- NUMBER =
{ :name => "number", :short => "-n x", :large => "--number x", :format => Integer, :description => "Number of VMs to apply the action to each period" }
- FORCE =
{ :name => "force", :short => "-f", :large => "--force", :description => "Force the new cardinality even if it is outside the limits" }
Class Method Summary collapse
-
.build_json_action(perform, params = nil) ⇒ String
Build a json specifying an action.
- .list_to_id(names, poolname) ⇒ Object
- .list_to_id_desc(poolname) ⇒ Object
- .name_to_id(name, pool, ename) ⇒ Object
-
.perform_actions(ids, &block) ⇒ Integer
Perform an action on several resources.
-
.rname_to_id(name, poolname) ⇒ Object
def self.rname_to_id(name, poolname, options).
- .rname_to_id_desc(poolname) ⇒ Object
-
.state_str(state_number) ⇒ Object
Returns the string representation of the service state.
Class Method Details
.build_json_action(perform, params = nil) ⇒ String
Build a json specifying an action
121 122 123 124 125 126 127 128 129 130 |
# File 'lib/opennebula/oneflow_client.rb', line 121 def self.build_json_action(perform, params=nil) body = Hash.new body['perform'] = perform body['params'] = params if params action = Hash.new action['action'] = body JSON.pretty_generate action end |
.list_to_id(names, poolname) ⇒ Object
243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 |
# File 'lib/opennebula/oneflow_client.rb', line 243 def self.list_to_id(names, poolname) client = Service::Client.new() resource_path = case poolname when "SERVICE" then "/service" when "SERVICE TEMPLATE" then "/service_template" end response = client.get(resource_path) if CloudClient::is_error?(response) return -1, "OpenNebula #{poolname} name not found," << " use the ID instead" end pool = JSON.parse(response.body) result = names.split(',').collect { |name| if name.match(/^[0123456789]+$/) name.to_i else rc = name_to_id(name, pool, poolname) if rc.first == -1 return rc[0], rc[1] end rc[1] end } return 0, result end |
.list_to_id_desc(poolname) ⇒ Object
278 279 280 |
# File 'lib/opennebula/oneflow_client.rb', line 278 def self.list_to_id_desc(poolname) "Comma-separated list of OpenNebula #{poolname} names or ids" end |
.name_to_id(name, pool, ename) ⇒ Object
223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 |
# File 'lib/opennebula/oneflow_client.rb', line 223 def self.name_to_id(name, pool, ename) if pool['DOCUMENT_POOL']['DOCUMENT'].nil? return -1, "#{ename} named #{name} not found." end objects = pool['DOCUMENT_POOL']['DOCUMENT'].select {|object| object['NAME'] == name } if objects.length>0 if objects.length>1 return -1, "There are multiple #{ename}s with name #{name}." else result = objects.first['ID'] end else return -1, "#{ename} named #{name} not found." end return 0, result end |
.perform_actions(ids, &block) ⇒ Integer
Perform an action on several resources
286 287 288 289 290 291 292 293 294 295 296 297 298 299 |
# File 'lib/opennebula/oneflow_client.rb', line 286 def self.perform_actions(ids, &block) exit_code = 0 ids.each do |id| response = block.call(id) if CloudClient::is_error?(response) puts response.to_s exit_code = response.code.to_i end end exit_code end |
.rname_to_id(name, poolname) ⇒ Object
def self.rname_to_id(name, poolname, options)
198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 |
# File 'lib/opennebula/oneflow_client.rb', line 198 def self.rname_to_id(name, poolname) return 0, name.to_i if name.match(/^[0123456789]+$/) client = Service::Client.new() resource_path = case poolname when "SERVICE" then "/service" when "SERVICE TEMPLATE" then "/service_template" end response = client.get(resource_path) if CloudClient::is_error?(response) return -1, "OpenNebula #{poolname} name not found," << " use the ID instead" end pool = JSON.parse(response.body) name_to_id(name, pool, poolname) end |
.rname_to_id_desc(poolname) ⇒ Object
219 220 221 |
# File 'lib/opennebula/oneflow_client.rb', line 219 def self.rname_to_id_desc(poolname) "OpenNebula #{poolname} name or id" end |
.state_str(state_number) ⇒ Object
Returns the string representation of the service state
113 114 115 |
# File 'lib/opennebula/oneflow_client.rb', line 113 def self.state_str(state_number) return STATE_STR[state_number.to_i] end |