Skip to content

C
CONF
Commit afb495a3 authored by Spiros Koulouzis's avatar Spiros Koulouzis
Browse files
Options

Added nice yml format for converter

parent f1c6b279
Hide whitespace changes
Inline Side-by-side
Showing with 1534 additions and 794 deletions
docs/apidocs/apidocs/downloads.html
View file @ afb495a3
......@@ -72,7 +72,7 @@
<h1 class="page-header">Files and Libraries</h1>
<h3 id="artifact_gwt_json_overlay">GWT JSON Overlay</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p> <p>
The <a href="http://code.google.com/webtoolkit/">Google Web Toolkit</a> JSON Overlay library provides the JSON Overlays that
can be used to access the Web service API for this application.
......@@ -91,13 +91,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-gwt-json-overlay.jar">
<td><span class="downloadfile-name">drip-api-gwt-json-overlay.jar</span></td>
<td><span class="downloadfile-size">14.46K</span></td>
<td><span class="downloadfile-size">14.45K</span></td>
<td><span class="downloadfile-description">The sources for the GWT JSON overlay.</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_java_json_client_library">Java JSON Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The Java client-side library is used to provide the set of Java objects that can be serialized
to/from JSON using <a href="http://jackson.codehaus.org/">Jackson</a>. This is useful for accessing the
......@@ -127,7 +127,7 @@
</tbody>
</table>
<h3 id="artifact_java_xml_client_library">Java XML Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The Java client-side library is used to access the Web service API for this application using Java.
</p>
......@@ -155,7 +155,7 @@
</tbody>
</table>
<h3 id="artifact_js_client_library">JavaScript Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The JavaScript client-side library defines classes that can be (de)serialized to/from JSON.
This is useful for accessing the resources that are published by this application, but only
......@@ -184,13 +184,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-js.zip">
<td><span class="downloadfile-name">drip-api-js.zip</span></td>
<td><span class="downloadfile-size">5.92K</span></td>
<td><span class="downloadfile-size">6.04K</span></td>
<td><span class="downloadfile-description">&nbsp;</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_php_json_client_library">PHP JSON Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The PHP JSON client-side library defines the PHP classes that can be (de)serialized to/from JSON.
This is useful for accessing the resources that are published by this application, but only
......@@ -213,13 +213,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-php.zip">
<td><span class="downloadfile-name">drip-api-php.zip</span></td>
<td><span class="downloadfile-size">6.67K</span></td>
<td><span class="downloadfile-size">6.74K</span></td>
<td><span class="downloadfile-description">&nbsp;</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_php_xml_client_library">PHP XML Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The PHP client-side library defines the PHP classes that can be (de)serialized to/from XML.
This is useful for accessing the resources that are published by this application, but only
......@@ -245,13 +245,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-php.zip">
<td><span class="downloadfile-name">drip-api-php.zip</span></td>
<td><span class="downloadfile-size">9.61K</span></td>
<td><span class="downloadfile-size">9.62K</span></td>
<td><span class="downloadfile-description">&nbsp;</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_ruby_json_client_library">Ruby JSON Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The Ruby JSON client-side library defines the Ruby classes that can be (de)serialized to/from JSON.
This is useful for accessing the REST endpoints that are published by this application, but only
......
docs/apidocs/apidocs/drip-api.rb
View file @ afb495a3
......@@ -93,92 +93,208 @@ module V1
module External
module Ansible
# (no documentation provided)
class DeployParameter
class AnsibleResult
# the IP
attr_accessor :IP
# the user
attr_accessor :user
# the role
attr_accessor :role
# (no documentation provided)
attr_accessor :msg
# (no documentation provided)
attr_accessor :changed
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :stdout
# (no documentation provided)
attr_accessor :cmd
# (no documentation provided)
attr_accessor :start
# (no documentation provided)
attr_accessor :stderr
# (no documentation provided)
attr_accessor :delta
# the json hash for this DeployParameter
# the json hash for this AnsibleResult
def to_jaxb_json_hash
_h = {}
_h['IP'] = IP.to_jaxb_json_hash unless IP.nil?
_h['user'] = user.to_jaxb_json_hash unless user.nil?
_h['role'] = role.to_jaxb_json_hash unless role.nil?
_h['msg'] = msg.to_jaxb_json_hash unless msg.nil?
_h['changed'] = changed.to_jaxb_json_hash unless changed.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['stdout'] = stdout.to_jaxb_json_hash unless stdout.nil?
if !cmd.nil?
_ha = Array.new
cmd.each { | _item | _ha.push _item.to_jaxb_json_hash }
_h['cmd'] = _ha
end
_h['start'] = start.to_jaxb_json_hash unless start.nil?
_h['stderr'] = stderr.to_jaxb_json_hash unless stderr.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
return _h
end
# the json (string form) for this DeployParameter
# the json (string form) for this AnsibleResult
def to_json
to_jaxb_json_hash.to_json
end
#initializes this DeployParameter with a json hash
#initializes this AnsibleResult with a json hash
def init_jaxb_json_hash(_o)
if !_o['IP'].nil?
_oa = _o['IP']
if !_o['msg'].nil?
_oa = _o['msg']
if(_oa.is_a? Hash)
@IP = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@IP = String.from_json(_oa) unless _oa['@class']
@msg = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@msg = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@IP = Array.new
@msg = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@IP.push String.from_json(_item)
@msg.push String.from_json(_item)
else
@IP.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@msg.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@IP = _oa
@msg = _oa
end
end
if !_o['user'].nil?
_oa = _o['user']
if !_o['changed'].nil?
_oa = _o['changed']
if(_oa.is_a? Hash)
@user = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@user = String.from_json(_oa) unless _oa['@class']
@changed = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@changed = Boolean.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@user = Array.new
@changed = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@user.push String.from_json(_item)
@changed.push Boolean.from_json(_item)
else
@user.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@changed.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@user = _oa
@changed = _oa
end
end
if !_o['role'].nil?
_oa = _o['role']
if !_o['end'].nil?
_oa = _o['end']
if(_oa.is_a? Hash)
@role = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@role = String.from_json(_oa) unless _oa['@class']
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@role = Array.new
@end = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@role.push String.from_json(_item)
@end.push Time.from_json(_item)
else
@role.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@role = _oa
@end = _oa
end
end
if !_o['stdout'].nil?
_oa = _o['stdout']
if(_oa.is_a? Hash)
@stdout = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stdout = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stdout = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stdout.push String.from_json(_item)
else
@stdout.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stdout = _oa
end
end
if !_o['cmd'].nil?
_oa = _o['cmd']
if(_oa.is_a? Hash)
@cmd = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cmd = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cmd = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cmd.push String.from_json(_item)
else
@cmd.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cmd = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
end
end
if !_o['stderr'].nil?
_oa = _o['stderr']
if(_oa.is_a? Hash)
@stderr = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stderr = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stderr = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stderr.push String.from_json(_item)
else
@stderr.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stderr = _oa
end
end
if !_o['delta'].nil?
_oa = _o['delta']
if(_oa.is_a? Hash)
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@delta = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@delta.push Time.from_json(_item)
else
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@delta = _oa
end
end
end
# constructs a DeployParameter from a (parsed) JSON hash
# constructs a AnsibleResult from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -208,6 +324,8 @@ end
end
end
module Nl
module Uva
......@@ -359,208 +477,92 @@ module V1
module External
module Ansible
# (no documentation provided)
class AnsibleResult
class DeployParameter
# (no documentation provided)
attr_accessor :msg
# (no documentation provided)
attr_accessor :changed
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :stdout
# (no documentation provided)
attr_accessor :cmd
# (no documentation provided)
attr_accessor :start
# (no documentation provided)
attr_accessor :stderr
# (no documentation provided)
attr_accessor :delta
# the IP
attr_accessor :IP
# the user
attr_accessor :user
# the role
attr_accessor :role
# the json hash for this AnsibleResult
# the json hash for this DeployParameter
def to_jaxb_json_hash
_h = {}
_h['msg'] = msg.to_jaxb_json_hash unless msg.nil?
_h['changed'] = changed.to_jaxb_json_hash unless changed.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['stdout'] = stdout.to_jaxb_json_hash unless stdout.nil?
if !cmd.nil?
_ha = Array.new
cmd.each { | _item | _ha.push _item.to_jaxb_json_hash }
_h['cmd'] = _ha
end
_h['start'] = start.to_jaxb_json_hash unless start.nil?
_h['stderr'] = stderr.to_jaxb_json_hash unless stderr.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
_h['IP'] = IP.to_jaxb_json_hash unless IP.nil?
_h['user'] = user.to_jaxb_json_hash unless user.nil?
_h['role'] = role.to_jaxb_json_hash unless role.nil?
return _h
end
# the json (string form) for this AnsibleResult
# the json (string form) for this DeployParameter
def to_json
to_jaxb_json_hash.to_json
end
#initializes this AnsibleResult with a json hash
#initializes this DeployParameter with a json hash
def init_jaxb_json_hash(_o)
if !_o['msg'].nil?
_oa = _o['msg']
if(_oa.is_a? Hash)
@msg = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@msg = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@msg = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@msg.push String.from_json(_item)
else
@msg.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@msg = _oa
end
end
if !_o['changed'].nil?
_oa = _o['changed']
if(_oa.is_a? Hash)
@changed = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@changed = Boolean.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@changed = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@changed.push Boolean.from_json(_item)
else
@changed.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@changed = _oa
end
end
if !_o['end'].nil?
_oa = _o['end']
if(_oa.is_a? Hash)
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@end = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@end.push Time.from_json(_item)
else
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@end = _oa
end
end
if !_o['stdout'].nil?
_oa = _o['stdout']
if(_oa.is_a? Hash)
@stdout = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stdout = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stdout = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stdout.push String.from_json(_item)
else
@stdout.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stdout = _oa
end
end
if !_o['cmd'].nil?
_oa = _o['cmd']
if(_oa.is_a? Hash)
@cmd = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cmd = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cmd = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cmd.push String.from_json(_item)
else
@cmd.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cmd = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if !_o['IP'].nil?
_oa = _o['IP']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
@IP = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@IP = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
@IP = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
@IP.push String.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@IP.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
@IP = _oa
end
end
if !_o['stderr'].nil?
_oa = _o['stderr']
if !_o['user'].nil?
_oa = _o['user']
if(_oa.is_a? Hash)
@stderr = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stderr = String.from_json(_oa) unless _oa['@class']
@user = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@user = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stderr = Array.new
@user = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stderr.push String.from_json(_item)
@user.push String.from_json(_item)
else
@stderr.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@user.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stderr = _oa
@user = _oa
end
end
if !_o['delta'].nil?
_oa = _o['delta']
if !_o['role'].nil?
_oa = _o['role']
if(_oa.is_a? Hash)
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
@role = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@role = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@delta = Array.new
@role = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@delta.push Time.from_json(_item)
@role.push String.from_json(_item)
else
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@role.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@delta = _oa
@role = _oa
end
end
end
# constructs a AnsibleResult from a (parsed) JSON hash
# constructs a DeployParameter from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -590,8 +592,6 @@ end
end
end
module Nl
module Uva
......@@ -1211,156 +1211,110 @@ module V1
module External
module Ansible
# (no documentation provided)
class BenchmarkResult < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
class CloudCredentials < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
# (no documentation provided)
attr_accessor :cloudDeploymentDomain
# (no documentation provided)
attr_accessor :host
# (no documentation provided)
attr_accessor :delta
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :start
# (no documentation provided)
attr_accessor :vmType
# the secret key
attr_accessor :secretKey
# the cloudProviderName
attr_accessor :cloudProviderName
# the accessKeyId
attr_accessor :accessKeyId
# the attributes
attr_accessor :attributes
# the json hash for this BenchmarkResult
# the json hash for this CloudCredentials
def to_jaxb_json_hash
_h = super
_h['cloudDeploymentDomain'] = cloudDeploymentDomain.to_jaxb_json_hash unless cloudDeploymentDomain.nil?
_h['host'] = host.to_jaxb_json_hash unless host.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['start'] = start.to_jaxb_json_hash unless start.nil?
_h['vmType'] = vmType.to_jaxb_json_hash unless vmType.nil?
_h['secretKey'] = secretKey.to_jaxb_json_hash unless secretKey.nil?
_h['cloudProviderName'] = cloudProviderName.to_jaxb_json_hash unless cloudProviderName.nil?
_h['accessKeyId'] = accessKeyId.to_jaxb_json_hash unless accessKeyId.nil?
_h['attributes'] = attributes.to_jaxb_json_hash unless attributes.nil?
return _h
end
#initializes this BenchmarkResult with a json hash
#initializes this CloudCredentials with a json hash
def init_jaxb_json_hash(_o)
super _o
if !_o['cloudDeploymentDomain'].nil?
_oa = _o['cloudDeploymentDomain']
if(_oa.is_a? Hash)
@cloudDeploymentDomain = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudDeploymentDomain = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cloudDeploymentDomain = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cloudDeploymentDomain.push String.from_json(_item)
else
@cloudDeploymentDomain.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cloudDeploymentDomain = _oa
end
end
if !_o['host'].nil?
_oa = _o['host']
if(_oa.is_a? Hash)
@host = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@host = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@host = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@host.push String.from_json(_item)
else
@host.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@host = _oa
end
end
if !_o['delta'].nil?
_oa = _o['delta']
if !_o['secretKey'].nil?
_oa = _o['secretKey']
if(_oa.is_a? Hash)
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
@secretKey = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@secretKey = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@delta = Array.new
@secretKey = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@delta.push Time.from_json(_item)
@secretKey.push String.from_json(_item)
else
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@secretKey.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@delta = _oa
@secretKey = _oa
end
end
if !_o['end'].nil?
_oa = _o['end']
if !_o['cloudProviderName'].nil?
_oa = _o['cloudProviderName']
if(_oa.is_a? Hash)
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
@cloudProviderName = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudProviderName = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@end = Array.new
@cloudProviderName = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@end.push Time.from_json(_item)
@cloudProviderName.push String.from_json(_item)
else
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@cloudProviderName.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@end = _oa
@cloudProviderName = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if !_o['accessKeyId'].nil?
_oa = _o['accessKeyId']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
@accessKeyId = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@accessKeyId = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
@accessKeyId = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
@accessKeyId.push String.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@accessKeyId.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
@accessKeyId = _oa
end
end
if !_o['vmType'].nil?
_oa = _o['vmType']
if !_o['attributes'].nil?
_oa = _o['attributes']
if(_oa.is_a? Hash)
@vmType = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@vmType = String.from_json(_oa) unless _oa['@class']
@attributes = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@attributes = Hash.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@vmType = Array.new
@attributes = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@vmType.push String.from_json(_item)
@attributes.push Hash.from_json(_item)
else
@vmType.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@attributes.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@vmType = _oa
@attributes = _oa
end
end
end
# constructs a BenchmarkResult from a (parsed) JSON hash
# constructs a CloudCredentials from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -1390,8 +1344,6 @@ end
end
end
module Nl
module Uva
......@@ -2189,110 +2141,156 @@ module V1
module External
module Ansible
# (no documentation provided)
class CloudCredentials < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
class BenchmarkResult < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
# the secret key
attr_accessor :secretKey
# the cloudProviderName
attr_accessor :cloudProviderName
# the accessKeyId
attr_accessor :accessKeyId
# the attributes
attr_accessor :attributes
# (no documentation provided)
attr_accessor :host
# (no documentation provided)
attr_accessor :vmType
# (no documentation provided)
attr_accessor :cloudDeploymentDomain
# (no documentation provided)
attr_accessor :delta
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :start
# the json hash for this CloudCredentials
# the json hash for this BenchmarkResult
def to_jaxb_json_hash
_h = super
_h['secretKey'] = secretKey.to_jaxb_json_hash unless secretKey.nil?
_h['cloudProviderName'] = cloudProviderName.to_jaxb_json_hash unless cloudProviderName.nil?
_h['accessKeyId'] = accessKeyId.to_jaxb_json_hash unless accessKeyId.nil?
_h['attributes'] = attributes.to_jaxb_json_hash unless attributes.nil?
_h['host'] = host.to_jaxb_json_hash unless host.nil?
_h['vmType'] = vmType.to_jaxb_json_hash unless vmType.nil?
_h['cloudDeploymentDomain'] = cloudDeploymentDomain.to_jaxb_json_hash unless cloudDeploymentDomain.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['start'] = start.to_jaxb_json_hash unless start.nil?
return _h
end
#initializes this CloudCredentials with a json hash
#initializes this BenchmarkResult with a json hash
def init_jaxb_json_hash(_o)
super _o
if !_o['secretKey'].nil?
_oa = _o['secretKey']
if !_o['host'].nil?
_oa = _o['host']
if(_oa.is_a? Hash)
@secretKey = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@secretKey = String.from_json(_oa) unless _oa['@class']
@host = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@host = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@secretKey = Array.new
@host = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@secretKey.push String.from_json(_item)
@host.push String.from_json(_item)
else
@secretKey.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@host.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@secretKey = _oa
@host = _oa
end
end
if !_o['cloudProviderName'].nil?
_oa = _o['cloudProviderName']
if !_o['vmType'].nil?
_oa = _o['vmType']
if(_oa.is_a? Hash)
@cloudProviderName = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudProviderName = String.from_json(_oa) unless _oa['@class']
@vmType = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@vmType = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cloudProviderName = Array.new
@vmType = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cloudProviderName.push String.from_json(_item)
@vmType.push String.from_json(_item)
else
@cloudProviderName.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@vmType.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cloudProviderName = _oa
@vmType = _oa
end
end
if !_o['accessKeyId'].nil?
_oa = _o['accessKeyId']
if !_o['cloudDeploymentDomain'].nil?
_oa = _o['cloudDeploymentDomain']
if(_oa.is_a? Hash)
@accessKeyId = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@accessKeyId = String.from_json(_oa) unless _oa['@class']
@cloudDeploymentDomain = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudDeploymentDomain = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@accessKeyId = Array.new
@cloudDeploymentDomain = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@accessKeyId.push String.from_json(_item)
@cloudDeploymentDomain.push String.from_json(_item)
else
@accessKeyId.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@cloudDeploymentDomain.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@accessKeyId = _oa
@cloudDeploymentDomain = _oa
end
end
if !_o['attributes'].nil?
_oa = _o['attributes']
if !_o['delta'].nil?
_oa = _o['delta']
if(_oa.is_a? Hash)
@attributes = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@attributes = Hash.from_json(_oa) unless _oa['@class']
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@attributes = Array.new
@delta = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@attributes.push Hash.from_json(_item)
@delta.push Time.from_json(_item)
else
@attributes.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@attributes = _oa
@delta = _oa
end
end
if !_o['end'].nil?
_oa = _o['end']
if(_oa.is_a? Hash)
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@end = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@end.push Time.from_json(_item)
else
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@end = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
end
end
end
# constructs a CloudCredentials from a (parsed) JSON hash
# constructs a BenchmarkResult from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -2322,6 +2320,8 @@ end
end
end
module Nl
module Uva
......
docs/apidocs/apidocs/json_BenchmarkResult.html
View file @ afb495a3
......@@ -81,25 +81,25 @@ class</p>
</thead>
<tbody>
<tr>
<td> <span class="property-name">start</span>
<td> <span class="property-name">host</span>
</td>
<td> <span class="datatype-reference">number
<td> <span class="datatype-reference">string
</span>
</td>
<td> <span class="property-description"></span>
</td>
</tr>
<tr>
<td> <span class="property-name">cloudDeploymentDomain</span>
<td> <span class="property-name">delta</span>
</td>
<td> <span class="datatype-reference">string
<td> <span class="datatype-reference">number
</span>
</td>
<td> <span class="property-description"></span>
</td>
</tr>
<tr>
<td> <span class="property-name">vmType</span>
<td> <span class="property-name">cloudDeploymentDomain</span>
</td>
<td> <span class="datatype-reference">string
</span>
......@@ -108,7 +108,7 @@ class</p>
</td>
</tr>
<tr>
<td> <span class="property-name">delta</span>
<td> <span class="property-name">end</span>
</td>
<td> <span class="datatype-reference">number
</span>
......@@ -117,7 +117,7 @@ class</p>
</td>
</tr>
<tr>
<td> <span class="property-name">end</span>
<td> <span class="property-name">start</span>
</td>
<td> <span class="datatype-reference">number
</span>
......@@ -126,7 +126,7 @@ class</p>
</td>
</tr>
<tr>
<td> <span class="property-name">host</span>
<td> <span class="property-name">vmType</span>
</td>
<td> <span class="datatype-reference">string
</span>
......@@ -167,12 +167,12 @@ No need to set during a POST</span></td>
<p class="lead">Example</p>
<pre class="prettyprint language-js example">{
&quot;start&quot; : 12345,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;vmType&quot; : &quot;...&quot;,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;delta&quot; : 12345,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;end&quot; : 12345,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;start&quot; : 12345,
&quot;vmType&quot; : &quot;...&quot;,
&quot;owner&quot; : &quot;user1&quot;,
&quot;id&quot; : &quot;58e3946e0fb4f562d84ba1ad&quot;,
&quot;timestamp&quot; : 1499793079011
......
docs/apidocs/apidocs/json_OwnedObject.html
View file @ afb495a3
......@@ -69,7 +69,7 @@ class</p>
<dl class="dl-horizontal">
<dt>Subtypes</dt>
<dd><a href="json_KeyPair.html">KeyPair</a>, <a href="json_ScaleRequest.html">ScaleRequest</a>, <a href="json_AnsibleOutput.html">AnsibleOutput</a>, <a href="json_BenchmarkResult.html">BenchmarkResult</a>, <a href="json_CloudCredentials.html">CloudCredentials</a>, <a href="json_DeployResponse.html">DeployResponse</a>, <a href="json_DRIPLogRecord.html">DRIPLogRecord</a>, <a href="json_ProvisionRequest.html">ProvisionRequest</a>, <a href="json_Script.html">Script</a>, <a href="json_KeyValueHolder.html">KeyValueHolder</a>, <a href="json_DeployRequest.html">DeployRequest</a>, <a href="json_MonitorringMessage.html">MonitorringMessage</a>, <a href="json_ProvisionResponse.html">ProvisionResponse</a></dd>
<dd><a href="json_KeyPair.html">KeyPair</a>, <a href="json_AnsibleOutput.html">AnsibleOutput</a>, <a href="json_ScaleRequest.html">ScaleRequest</a>, <a href="json_CloudCredentials.html">CloudCredentials</a>, <a href="json_BenchmarkResult.html">BenchmarkResult</a>, <a href="json_DeployResponse.html">DeployResponse</a>, <a href="json_DRIPLogRecord.html">DRIPLogRecord</a>, <a href="json_ProvisionRequest.html">ProvisionRequest</a>, <a href="json_Script.html">Script</a>, <a href="json_KeyValueHolder.html">KeyValueHolder</a>, <a href="json_DeployRequest.html">DeployRequest</a>, <a href="json_MonitorringMessage.html">MonitorringMessage</a>, <a href="json_ProvisionResponse.html">ProvisionResponse</a></dd>
</dl>
<table class="table datatype-properties">
......
docs/apidocs/apidocs/ns0.xsd
View file @ afb495a3
......@@ -821,18 +821,18 @@ class]]>
<xs:complexContent>
<xs:extension base="ownedObject">
<xs:sequence>
<xs:element name="vmType" type="xs:string" minOccurs="0">
</xs:element>
<xs:element name="host" type="xs:string" minOccurs="0">
<xs:element name="end" type="xs:dateTime" minOccurs="0">
</xs:element>
<xs:element name="cloudDeploymentDomain" type="xs:string" minOccurs="0">
</xs:element>
<xs:element name="end" type="xs:dateTime" minOccurs="0">
</xs:element>
<xs:element name="delta" type="xs:dateTime" minOccurs="0">
</xs:element>
<xs:element name="start" type="xs:dateTime" minOccurs="0">
</xs:element>
<xs:element name="host" type="xs:string" minOccurs="0">
</xs:element>
<xs:element name="vmType" type="xs:string" minOccurs="0">
</xs:element>
</xs:sequence>
</xs:extension>
</xs:complexContent>
......
docs/apidocs/apidocs/resource_BenchmarkController.html
View file @ afb495a3
......@@ -144,12 +144,12 @@ Content-Type: application/json
<code class="prettyprint language-js">
[ {
&quot;start&quot; : 12345,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;vmType&quot; : &quot;...&quot;,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;delta&quot; : 12345,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;end&quot; : 12345,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;start&quot; : 12345,
&quot;vmType&quot; : &quot;...&quot;,
&quot;owner&quot; : &quot;user1&quot;,
&quot;id&quot; : &quot;58e3946e0fb4f562d84ba1ad&quot;,
&quot;timestamp&quot; : 1499793079011
......@@ -514,12 +514,12 @@ Content-Type: application/json
<code class="prettyprint language-js">
{
&quot;start&quot; : 12345,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;vmType&quot; : &quot;...&quot;,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;delta&quot; : 12345,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;end&quot; : 12345,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;start&quot; : 12345,
&quot;vmType&quot; : &quot;...&quot;,
&quot;owner&quot; : &quot;user1&quot;,
&quot;id&quot; : &quot;58e3946e0fb4f562d84ba1ad&quot;,
&quot;timestamp&quot; : 1499793079011
......
docs/apidocs/apidocs/xml_ns0_benchmarkResult.html
View file @ afb495a3
......@@ -220,12 +220,12 @@ It is created automatically. No need to set during a POST</span></td>
<p class="lead">Example</p>
<pre class="prettyprint language-xml example">&lt;b-----&gt;
&lt;vmType&gt;...&lt;/vmType&gt;
&lt;host&gt;147.228.242.58&lt;/host&gt;
&lt;cloudDeploymentDomain&gt;us-east-1&lt;/cloudDeploymentDomain&gt;
&lt;end&gt;...&lt;/end&gt;
&lt;cloudDeploymentDomain&gt;us-east-1&lt;/cloudDeploymentDomain&gt;
&lt;delta&gt;...&lt;/delta&gt;
&lt;start&gt;...&lt;/start&gt;
&lt;host&gt;147.228.242.58&lt;/host&gt;
&lt;vmType&gt;...&lt;/vmType&gt;
&lt;owner&gt;user1&lt;/owner&gt;
&lt;/b-----&gt;
</pre>
......
docs/apidocs/downloads.html
View file @ afb495a3
......@@ -72,7 +72,7 @@
<h1 class="page-header">Files and Libraries</h1>
<h3 id="artifact_gwt_json_overlay">GWT JSON Overlay</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p> <p>
The <a href="http://code.google.com/webtoolkit/">Google Web Toolkit</a> JSON Overlay library provides the JSON Overlays that
can be used to access the Web service API for this application.
......@@ -91,13 +91,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-gwt-json-overlay.jar">
<td><span class="downloadfile-name">drip-api-gwt-json-overlay.jar</span></td>
<td><span class="downloadfile-size">14.46K</span></td>
<td><span class="downloadfile-size">14.45K</span></td>
<td><span class="downloadfile-description">The sources for the GWT JSON overlay.</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_java_json_client_library">Java JSON Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The Java client-side library is used to provide the set of Java objects that can be serialized
to/from JSON using <a href="http://jackson.codehaus.org/">Jackson</a>. This is useful for accessing the
......@@ -127,7 +127,7 @@
</tbody>
</table>
<h3 id="artifact_java_xml_client_library">Java XML Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The Java client-side library is used to access the Web service API for this application using Java.
</p>
......@@ -155,7 +155,7 @@
</tbody>
</table>
<h3 id="artifact_js_client_library">JavaScript Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The JavaScript client-side library defines classes that can be (de)serialized to/from JSON.
This is useful for accessing the resources that are published by this application, but only
......@@ -184,13 +184,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-js.zip">
<td><span class="downloadfile-name">drip-api-js.zip</span></td>
<td><span class="downloadfile-size">5.92K</span></td>
<td><span class="downloadfile-size">6.04K</span></td>
<td><span class="downloadfile-description">&nbsp;</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_php_json_client_library">PHP JSON Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The PHP JSON client-side library defines the PHP classes that can be (de)serialized to/from JSON.
This is useful for accessing the resources that are published by this application, but only
......@@ -213,13 +213,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-php.zip">
<td><span class="downloadfile-name">drip-api-php.zip</span></td>
<td><span class="downloadfile-size">6.67K</span></td>
<td><span class="downloadfile-size">6.74K</span></td>
<td><span class="downloadfile-description">&nbsp;</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_php_xml_client_library">PHP XML Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The PHP client-side library defines the PHP classes that can be (de)serialized to/from XML.
This is useful for accessing the resources that are published by this application, but only
......@@ -245,13 +245,13 @@
<tbody data-link="row" class="rowlink">
<tr class="clickable-row" data-href="drip-api-php.zip">
<td><span class="downloadfile-name">drip-api-php.zip</span></td>
<td><span class="downloadfile-size">9.61K</span></td>
<td><span class="downloadfile-size">9.62K</span></td>
<td><span class="downloadfile-description">&nbsp;</span></td>
</tr>
</tbody>
</table>
<h3 id="artifact_ruby_json_client_library">Ruby JSON Client Library</h3>
<p class="lead">Created November 4, 2017</p>
<p class="lead">Created November 7, 2017</p>
<p><p>
The Ruby JSON client-side library defines the Ruby classes that can be (de)serialized to/from JSON.
This is useful for accessing the REST endpoints that are published by this application, but only
......
docs/apidocs/drip-api.rb
View file @ afb495a3
......@@ -93,92 +93,208 @@ module V1
module External
module Ansible
# (no documentation provided)
class DeployParameter
class AnsibleResult
# the IP
attr_accessor :IP
# the user
attr_accessor :user
# the role
attr_accessor :role
# (no documentation provided)
attr_accessor :msg
# (no documentation provided)
attr_accessor :changed
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :stdout
# (no documentation provided)
attr_accessor :cmd
# (no documentation provided)
attr_accessor :start
# (no documentation provided)
attr_accessor :stderr
# (no documentation provided)
attr_accessor :delta
# the json hash for this DeployParameter
# the json hash for this AnsibleResult
def to_jaxb_json_hash
_h = {}
_h['IP'] = IP.to_jaxb_json_hash unless IP.nil?
_h['user'] = user.to_jaxb_json_hash unless user.nil?
_h['role'] = role.to_jaxb_json_hash unless role.nil?
_h['msg'] = msg.to_jaxb_json_hash unless msg.nil?
_h['changed'] = changed.to_jaxb_json_hash unless changed.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['stdout'] = stdout.to_jaxb_json_hash unless stdout.nil?
if !cmd.nil?
_ha = Array.new
cmd.each { | _item | _ha.push _item.to_jaxb_json_hash }
_h['cmd'] = _ha
end
_h['start'] = start.to_jaxb_json_hash unless start.nil?
_h['stderr'] = stderr.to_jaxb_json_hash unless stderr.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
return _h
end
# the json (string form) for this DeployParameter
# the json (string form) for this AnsibleResult
def to_json
to_jaxb_json_hash.to_json
end
#initializes this DeployParameter with a json hash
#initializes this AnsibleResult with a json hash
def init_jaxb_json_hash(_o)
if !_o['IP'].nil?
_oa = _o['IP']
if !_o['msg'].nil?
_oa = _o['msg']
if(_oa.is_a? Hash)
@IP = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@IP = String.from_json(_oa) unless _oa['@class']
@msg = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@msg = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@IP = Array.new
@msg = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@IP.push String.from_json(_item)
@msg.push String.from_json(_item)
else
@IP.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@msg.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@IP = _oa
@msg = _oa
end
end
if !_o['user'].nil?
_oa = _o['user']
if !_o['changed'].nil?
_oa = _o['changed']
if(_oa.is_a? Hash)
@user = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@user = String.from_json(_oa) unless _oa['@class']
@changed = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@changed = Boolean.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@user = Array.new
@changed = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@user.push String.from_json(_item)
@changed.push Boolean.from_json(_item)
else
@user.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@changed.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@user = _oa
@changed = _oa
end
end
if !_o['role'].nil?
_oa = _o['role']
if !_o['end'].nil?
_oa = _o['end']
if(_oa.is_a? Hash)
@role = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@role = String.from_json(_oa) unless _oa['@class']
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@role = Array.new
@end = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@role.push String.from_json(_item)
@end.push Time.from_json(_item)
else
@role.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@role = _oa
@end = _oa
end
end
if !_o['stdout'].nil?
_oa = _o['stdout']
if(_oa.is_a? Hash)
@stdout = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stdout = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stdout = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stdout.push String.from_json(_item)
else
@stdout.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stdout = _oa
end
end
if !_o['cmd'].nil?
_oa = _o['cmd']
if(_oa.is_a? Hash)
@cmd = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cmd = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cmd = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cmd.push String.from_json(_item)
else
@cmd.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cmd = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
end
end
if !_o['stderr'].nil?
_oa = _o['stderr']
if(_oa.is_a? Hash)
@stderr = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stderr = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stderr = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stderr.push String.from_json(_item)
else
@stderr.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stderr = _oa
end
end
if !_o['delta'].nil?
_oa = _o['delta']
if(_oa.is_a? Hash)
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@delta = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@delta.push Time.from_json(_item)
else
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@delta = _oa
end
end
end
# constructs a DeployParameter from a (parsed) JSON hash
# constructs a AnsibleResult from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -208,6 +324,8 @@ end
end
end
module Nl
module Uva
......@@ -359,208 +477,92 @@ module V1
module External
module Ansible
# (no documentation provided)
class AnsibleResult
class DeployParameter
# (no documentation provided)
attr_accessor :msg
# (no documentation provided)
attr_accessor :changed
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :stdout
# (no documentation provided)
attr_accessor :cmd
# (no documentation provided)
attr_accessor :start
# (no documentation provided)
attr_accessor :stderr
# (no documentation provided)
attr_accessor :delta
# the IP
attr_accessor :IP
# the user
attr_accessor :user
# the role
attr_accessor :role
# the json hash for this AnsibleResult
# the json hash for this DeployParameter
def to_jaxb_json_hash
_h = {}
_h['msg'] = msg.to_jaxb_json_hash unless msg.nil?
_h['changed'] = changed.to_jaxb_json_hash unless changed.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['stdout'] = stdout.to_jaxb_json_hash unless stdout.nil?
if !cmd.nil?
_ha = Array.new
cmd.each { | _item | _ha.push _item.to_jaxb_json_hash }
_h['cmd'] = _ha
end
_h['start'] = start.to_jaxb_json_hash unless start.nil?
_h['stderr'] = stderr.to_jaxb_json_hash unless stderr.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
_h['IP'] = IP.to_jaxb_json_hash unless IP.nil?
_h['user'] = user.to_jaxb_json_hash unless user.nil?
_h['role'] = role.to_jaxb_json_hash unless role.nil?
return _h
end
# the json (string form) for this AnsibleResult
# the json (string form) for this DeployParameter
def to_json
to_jaxb_json_hash.to_json
end
#initializes this AnsibleResult with a json hash
#initializes this DeployParameter with a json hash
def init_jaxb_json_hash(_o)
if !_o['msg'].nil?
_oa = _o['msg']
if(_oa.is_a? Hash)
@msg = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@msg = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@msg = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@msg.push String.from_json(_item)
else
@msg.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@msg = _oa
end
end
if !_o['changed'].nil?
_oa = _o['changed']
if(_oa.is_a? Hash)
@changed = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@changed = Boolean.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@changed = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@changed.push Boolean.from_json(_item)
else
@changed.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@changed = _oa
end
end
if !_o['end'].nil?
_oa = _o['end']
if(_oa.is_a? Hash)
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@end = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@end.push Time.from_json(_item)
else
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@end = _oa
end
end
if !_o['stdout'].nil?
_oa = _o['stdout']
if(_oa.is_a? Hash)
@stdout = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stdout = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stdout = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stdout.push String.from_json(_item)
else
@stdout.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stdout = _oa
end
end
if !_o['cmd'].nil?
_oa = _o['cmd']
if(_oa.is_a? Hash)
@cmd = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cmd = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cmd = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cmd.push String.from_json(_item)
else
@cmd.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cmd = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if !_o['IP'].nil?
_oa = _o['IP']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
@IP = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@IP = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
@IP = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
@IP.push String.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@IP.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
@IP = _oa
end
end
if !_o['stderr'].nil?
_oa = _o['stderr']
if !_o['user'].nil?
_oa = _o['user']
if(_oa.is_a? Hash)
@stderr = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@stderr = String.from_json(_oa) unless _oa['@class']
@user = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@user = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@stderr = Array.new
@user = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@stderr.push String.from_json(_item)
@user.push String.from_json(_item)
else
@stderr.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@user.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@stderr = _oa
@user = _oa
end
end
if !_o['delta'].nil?
_oa = _o['delta']
if !_o['role'].nil?
_oa = _o['role']
if(_oa.is_a? Hash)
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
@role = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@role = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@delta = Array.new
@role = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@delta.push Time.from_json(_item)
@role.push String.from_json(_item)
else
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@role.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@delta = _oa
@role = _oa
end
end
end
# constructs a AnsibleResult from a (parsed) JSON hash
# constructs a DeployParameter from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -590,8 +592,6 @@ end
end
end
module Nl
module Uva
......@@ -1211,156 +1211,110 @@ module V1
module External
module Ansible
# (no documentation provided)
class BenchmarkResult < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
class CloudCredentials < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
# (no documentation provided)
attr_accessor :cloudDeploymentDomain
# (no documentation provided)
attr_accessor :host
# (no documentation provided)
attr_accessor :delta
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :start
# (no documentation provided)
attr_accessor :vmType
# the secret key
attr_accessor :secretKey
# the cloudProviderName
attr_accessor :cloudProviderName
# the accessKeyId
attr_accessor :accessKeyId
# the attributes
attr_accessor :attributes
# the json hash for this BenchmarkResult
# the json hash for this CloudCredentials
def to_jaxb_json_hash
_h = super
_h['cloudDeploymentDomain'] = cloudDeploymentDomain.to_jaxb_json_hash unless cloudDeploymentDomain.nil?
_h['host'] = host.to_jaxb_json_hash unless host.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['start'] = start.to_jaxb_json_hash unless start.nil?
_h['vmType'] = vmType.to_jaxb_json_hash unless vmType.nil?
_h['secretKey'] = secretKey.to_jaxb_json_hash unless secretKey.nil?
_h['cloudProviderName'] = cloudProviderName.to_jaxb_json_hash unless cloudProviderName.nil?
_h['accessKeyId'] = accessKeyId.to_jaxb_json_hash unless accessKeyId.nil?
_h['attributes'] = attributes.to_jaxb_json_hash unless attributes.nil?
return _h
end
#initializes this BenchmarkResult with a json hash
#initializes this CloudCredentials with a json hash
def init_jaxb_json_hash(_o)
super _o
if !_o['cloudDeploymentDomain'].nil?
_oa = _o['cloudDeploymentDomain']
if(_oa.is_a? Hash)
@cloudDeploymentDomain = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudDeploymentDomain = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cloudDeploymentDomain = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cloudDeploymentDomain.push String.from_json(_item)
else
@cloudDeploymentDomain.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cloudDeploymentDomain = _oa
end
end
if !_o['host'].nil?
_oa = _o['host']
if(_oa.is_a? Hash)
@host = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@host = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@host = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@host.push String.from_json(_item)
else
@host.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@host = _oa
end
end
if !_o['delta'].nil?
_oa = _o['delta']
if !_o['secretKey'].nil?
_oa = _o['secretKey']
if(_oa.is_a? Hash)
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
@secretKey = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@secretKey = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@delta = Array.new
@secretKey = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@delta.push Time.from_json(_item)
@secretKey.push String.from_json(_item)
else
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@secretKey.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@delta = _oa
@secretKey = _oa
end
end
if !_o['end'].nil?
_oa = _o['end']
if !_o['cloudProviderName'].nil?
_oa = _o['cloudProviderName']
if(_oa.is_a? Hash)
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
@cloudProviderName = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudProviderName = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@end = Array.new
@cloudProviderName = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@end.push Time.from_json(_item)
@cloudProviderName.push String.from_json(_item)
else
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@cloudProviderName.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@end = _oa
@cloudProviderName = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if !_o['accessKeyId'].nil?
_oa = _o['accessKeyId']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
@accessKeyId = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@accessKeyId = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
@accessKeyId = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
@accessKeyId.push String.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@accessKeyId.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
@accessKeyId = _oa
end
end
if !_o['vmType'].nil?
_oa = _o['vmType']
if !_o['attributes'].nil?
_oa = _o['attributes']
if(_oa.is_a? Hash)
@vmType = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@vmType = String.from_json(_oa) unless _oa['@class']
@attributes = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@attributes = Hash.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@vmType = Array.new
@attributes = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@vmType.push String.from_json(_item)
@attributes.push Hash.from_json(_item)
else
@vmType.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@attributes.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@vmType = _oa
@attributes = _oa
end
end
end
# constructs a BenchmarkResult from a (parsed) JSON hash
# constructs a CloudCredentials from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -1390,8 +1344,6 @@ end
end
end
module Nl
module Uva
......@@ -2189,110 +2141,156 @@ module V1
module External
module Ansible
# (no documentation provided)
class CloudCredentials < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
class BenchmarkResult < Nl::Uva::Sne::Drip::Drip::Commons::Data::V1::External::OwnedObject
# the secret key
attr_accessor :secretKey
# the cloudProviderName
attr_accessor :cloudProviderName
# the accessKeyId
attr_accessor :accessKeyId
# the attributes
attr_accessor :attributes
# (no documentation provided)
attr_accessor :host
# (no documentation provided)
attr_accessor :vmType
# (no documentation provided)
attr_accessor :cloudDeploymentDomain
# (no documentation provided)
attr_accessor :delta
# (no documentation provided)
attr_accessor :end
# (no documentation provided)
attr_accessor :start
# the json hash for this CloudCredentials
# the json hash for this BenchmarkResult
def to_jaxb_json_hash
_h = super
_h['secretKey'] = secretKey.to_jaxb_json_hash unless secretKey.nil?
_h['cloudProviderName'] = cloudProviderName.to_jaxb_json_hash unless cloudProviderName.nil?
_h['accessKeyId'] = accessKeyId.to_jaxb_json_hash unless accessKeyId.nil?
_h['attributes'] = attributes.to_jaxb_json_hash unless attributes.nil?
_h['host'] = host.to_jaxb_json_hash unless host.nil?
_h['vmType'] = vmType.to_jaxb_json_hash unless vmType.nil?
_h['cloudDeploymentDomain'] = cloudDeploymentDomain.to_jaxb_json_hash unless cloudDeploymentDomain.nil?
_h['delta'] = delta.to_jaxb_json_hash unless delta.nil?
_h['end'] = end.to_jaxb_json_hash unless end.nil?
_h['start'] = start.to_jaxb_json_hash unless start.nil?
return _h
end
#initializes this CloudCredentials with a json hash
#initializes this BenchmarkResult with a json hash
def init_jaxb_json_hash(_o)
super _o
if !_o['secretKey'].nil?
_oa = _o['secretKey']
if !_o['host'].nil?
_oa = _o['host']
if(_oa.is_a? Hash)
@secretKey = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@secretKey = String.from_json(_oa) unless _oa['@class']
@host = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@host = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@secretKey = Array.new
@host = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@secretKey.push String.from_json(_item)
@host.push String.from_json(_item)
else
@secretKey.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@host.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@secretKey = _oa
@host = _oa
end
end
if !_o['cloudProviderName'].nil?
_oa = _o['cloudProviderName']
if !_o['vmType'].nil?
_oa = _o['vmType']
if(_oa.is_a? Hash)
@cloudProviderName = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudProviderName = String.from_json(_oa) unless _oa['@class']
@vmType = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@vmType = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@cloudProviderName = Array.new
@vmType = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@cloudProviderName.push String.from_json(_item)
@vmType.push String.from_json(_item)
else
@cloudProviderName.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@vmType.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@cloudProviderName = _oa
@vmType = _oa
end
end
if !_o['accessKeyId'].nil?
_oa = _o['accessKeyId']
if !_o['cloudDeploymentDomain'].nil?
_oa = _o['cloudDeploymentDomain']
if(_oa.is_a? Hash)
@accessKeyId = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@accessKeyId = String.from_json(_oa) unless _oa['@class']
@cloudDeploymentDomain = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@cloudDeploymentDomain = String.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@accessKeyId = Array.new
@cloudDeploymentDomain = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@accessKeyId.push String.from_json(_item)
@cloudDeploymentDomain.push String.from_json(_item)
else
@accessKeyId.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@cloudDeploymentDomain.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@accessKeyId = _oa
@cloudDeploymentDomain = _oa
end
end
if !_o['attributes'].nil?
_oa = _o['attributes']
if !_o['delta'].nil?
_oa = _o['delta']
if(_oa.is_a? Hash)
@attributes = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@attributes = Hash.from_json(_oa) unless _oa['@class']
@delta = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@delta = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@attributes = Array.new
@delta = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@attributes.push Hash.from_json(_item)
@delta.push Time.from_json(_item)
else
@attributes.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
@delta.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@attributes = _oa
@delta = _oa
end
end
if !_o['end'].nil?
_oa = _o['end']
if(_oa.is_a? Hash)
@end = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@end = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@end = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@end.push Time.from_json(_item)
else
@end.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@end = _oa
end
end
if !_o['start'].nil?
_oa = _o['start']
if(_oa.is_a? Hash)
@start = EnunciateHelpers::LAMB_CLASS_AWARE.call(_oa) if _oa['@class']
@start = Time.from_json(_oa) unless _oa['@class']
elsif (_oa.is_a? Array)
#an array(of hashes hopefully) or scalar
@start = Array.new
_oa.each { | _item |
if ((_item.nil? || _item['@class'].nil?)rescue true)
@start.push Time.from_json(_item)
else
@start.push EnunciateHelpers::LAMB_CLASS_AWARE.call(_item)
end
}
else
@start = _oa
end
end
end
# constructs a CloudCredentials from a (parsed) JSON hash
# constructs a BenchmarkResult from a (parsed) JSON hash
def self.from_json(o)
if o.nil?
return nil
......@@ -2322,6 +2320,8 @@ end
end
end
module Nl
module Uva
......
docs/apidocs/json_BenchmarkResult.html
View file @ afb495a3
......@@ -81,7 +81,7 @@ class</p>
</thead>
<tbody>
<tr>
<td> <span class="property-name">cloudDeploymentDomain</span>
<td> <span class="property-name">host</span>
</td>
<td> <span class="datatype-reference">string
</span>
......@@ -90,7 +90,7 @@ class</p>
</td>
</tr>
<tr>
<td> <span class="property-name">host</span>
<td> <span class="property-name">vmType</span>
</td>
<td> <span class="datatype-reference">string
</span>
......@@ -99,16 +99,16 @@ class</p>
</td>
</tr>
<tr>
<td> <span class="property-name">delta</span>
<td> <span class="property-name">cloudDeploymentDomain</span>
</td>
<td> <span class="datatype-reference">number
<td> <span class="datatype-reference">string
</span>
</td>
<td> <span class="property-description"></span>
</td>
</tr>
<tr>
<td> <span class="property-name">end</span>
<td> <span class="property-name">delta</span>
</td>
<td> <span class="datatype-reference">number
</span>
......@@ -117,7 +117,7 @@ class</p>
</td>
</tr>
<tr>
<td> <span class="property-name">start</span>
<td> <span class="property-name">end</span>
</td>
<td> <span class="datatype-reference">number
</span>
......@@ -126,9 +126,9 @@ class</p>
</td>
</tr>
<tr>
<td> <span class="property-name">vmType</span>
<td> <span class="property-name">start</span>
</td>
<td> <span class="datatype-reference">string
<td> <span class="datatype-reference">number
</span>
</td>
<td> <span class="property-description"></span>
......@@ -167,12 +167,12 @@ No need to set during a POST</span></td>
<p class="lead">Example</p>
<pre class="prettyprint language-js example">{
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;vmType&quot; : &quot;...&quot;,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;delta&quot; : 12345,
&quot;end&quot; : 12345,
&quot;start&quot; : 12345,
&quot;vmType&quot; : &quot;...&quot;,
&quot;owner&quot; : &quot;user1&quot;,
&quot;id&quot; : &quot;58e3946e0fb4f562d84ba1ad&quot;,
&quot;timestamp&quot; : 1499793079011
......
docs/apidocs/json_OwnedObject.html
View file @ afb495a3
......@@ -69,7 +69,7 @@ class</p>
<dl class="dl-horizontal">
<dt>Subtypes</dt>
<dd><a href="json_KeyPair.html">KeyPair</a>, <a href="json_ScaleRequest.html">ScaleRequest</a>, <a href="json_AnsibleOutput.html">AnsibleOutput</a>, <a href="json_CloudCredentials.html">CloudCredentials</a>, <a href="json_BenchmarkResult.html">BenchmarkResult</a>, <a href="json_DeployResponse.html">DeployResponse</a>, <a href="json_DRIPLogRecord.html">DRIPLogRecord</a>, <a href="json_ProvisionRequest.html">ProvisionRequest</a>, <a href="json_Script.html">Script</a>, <a href="json_KeyValueHolder.html">KeyValueHolder</a>, <a href="json_DeployRequest.html">DeployRequest</a>, <a href="json_MonitorringMessage.html">MonitorringMessage</a>, <a href="json_ProvisionResponse.html">ProvisionResponse</a></dd>
<dd><a href="json_KeyPair.html">KeyPair</a>, <a href="json_ScaleRequest.html">ScaleRequest</a>, <a href="json_AnsibleOutput.html">AnsibleOutput</a>, <a href="json_BenchmarkResult.html">BenchmarkResult</a>, <a href="json_CloudCredentials.html">CloudCredentials</a>, <a href="json_DeployResponse.html">DeployResponse</a>, <a href="json_DRIPLogRecord.html">DRIPLogRecord</a>, <a href="json_ProvisionRequest.html">ProvisionRequest</a>, <a href="json_Script.html">Script</a>, <a href="json_KeyValueHolder.html">KeyValueHolder</a>, <a href="json_DeployRequest.html">DeployRequest</a>, <a href="json_MonitorringMessage.html">MonitorringMessage</a>, <a href="json_ProvisionResponse.html">ProvisionResponse</a></dd>
</dl>
<table class="table datatype-properties">
......
docs/apidocs/ns0.xsd
View file @ afb495a3
......@@ -821,17 +821,17 @@ class]]>
<xs:complexContent>
<xs:extension base="ownedObject">
<xs:sequence>
<xs:element name="host" type="xs:string" minOccurs="0">
<xs:element name="end" type="xs:dateTime" minOccurs="0">
</xs:element>
<xs:element name="vmType" type="xs:string" minOccurs="0">
</xs:element>
<xs:element name="start" type="xs:dateTime" minOccurs="0">
<xs:element name="cloudDeploymentDomain" type="xs:string" minOccurs="0">
</xs:element>
<xs:element name="delta" type="xs:dateTime" minOccurs="0">
<xs:element name="host" type="xs:string" minOccurs="0">
</xs:element>
<xs:element name="cloudDeploymentDomain" type="xs:string" minOccurs="0">
<xs:element name="delta" type="xs:dateTime" minOccurs="0">
</xs:element>
<xs:element name="end" type="xs:dateTime" minOccurs="0">
<xs:element name="start" type="xs:dateTime" minOccurs="0">
</xs:element>
</xs:sequence>
</xs:extension>
......
docs/apidocs/resource_BenchmarkController.html
View file @ afb495a3
......@@ -144,12 +144,12 @@ Content-Type: application/json
<code class="prettyprint language-js">
[ {
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;vmType&quot; : &quot;...&quot;,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;delta&quot; : 12345,
&quot;end&quot; : 12345,
&quot;start&quot; : 12345,
&quot;vmType&quot; : &quot;...&quot;,
&quot;owner&quot; : &quot;user1&quot;,
&quot;id&quot; : &quot;58e3946e0fb4f562d84ba1ad&quot;,
&quot;timestamp&quot; : 1499793079011
......@@ -514,12 +514,12 @@ Content-Type: application/json
<code class="prettyprint language-js">
{
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;host&quot; : &quot;147.228.242.58&quot;,
&quot;vmType&quot; : &quot;...&quot;,
&quot;cloudDeploymentDomain&quot; : &quot;us-east-1&quot;,
&quot;delta&quot; : 12345,
&quot;end&quot; : 12345,
&quot;start&quot; : 12345,
&quot;vmType&quot; : &quot;...&quot;,
&quot;owner&quot; : &quot;user1&quot;,
&quot;id&quot; : &quot;58e3946e0fb4f562d84ba1ad&quot;,
&quot;timestamp&quot; : 1499793079011
......
docs/apidocs/xml_ns0_benchmarkResult.html
View file @ afb495a3
......@@ -220,12 +220,12 @@ It is created automatically. No need to set during a POST</span></td>
<p class="lead">Example</p>
<pre class="prettyprint language-xml example">&lt;b-----&gt;
&lt;host&gt;147.228.242.58&lt;/host&gt;
&lt;end&gt;...&lt;/end&gt;
&lt;vmType&gt;...&lt;/vmType&gt;
&lt;start&gt;...&lt;/start&gt;
&lt;delta&gt;...&lt;/delta&gt;
&lt;cloudDeploymentDomain&gt;us-east-1&lt;/cloudDeploymentDomain&gt;
&lt;end&gt;...&lt;/end&gt;
&lt;host&gt;147.228.242.58&lt;/host&gt;
&lt;delta&gt;...&lt;/delta&gt;
&lt;start&gt;...&lt;/start&gt;
&lt;owner&gt;user1&lt;/owner&gt;
&lt;/b-----&gt;
</pre>
......
drip-api/src/main/java/nl/uva/sne/drip/api/service/ProvisionService.java
View file @ afb495a3
......@@ -93,7 +93,7 @@ public class ProvisionService {
@Autowired
public ProvisionService(@Value("${message.broker.host}") String messageBrokerHost) throws IOException, TimeoutException {
logger = Logger.getLogger(DeployService.class.getName());
logger = Logger.getLogger(ProvisionService.class.getName());
logger.addHandler(new DRIPLogHandler(messageBrokerHost));
}
......
drip-api/src/main/java/nl/uva/sne/drip/api/v1/rest/ConfigurationController.java
View file @ afb495a3
......@@ -21,8 +21,6 @@ import nl.uva.sne.drip.drip.commons.data.v1.external.ConfigurationRepresentation
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.security.RolesAllowed;
import org.json.JSONException;
import org.springframework.beans.factory.annotation.Autowired;
......
drip-api/src/main/resources/log4j.properties
View file @ afb495a3
......@@ -4,20 +4,9 @@
# Set root logger level to DEBUG and its only appender to A1.
log4j.rootLogger=FINE, A1
log4j.category.org.apache.http=OFF
log4j.category.io.milton=OFF
log4j.category.org.apache.commons=OFF
log4j.category.org.globus=OFF
log4j.org.apache.axis=OFF
log4j.org.apache.http=OFF
log4j.org.apache.jackrabbit=OFF
log4j.logger.org.apache.jackrabbit=OFF
log4j.logger.httpclient.wire.header=OFF
log4j.logger.httpclient.wire.content=OFF
log4j.logger.org.globus=OFF
log4j.logger.io.milton=SEVERE
log4j.io.milton=SEVERE
# A1 is set to be a ConsoleAppender.
log4j.appender.A1=org.apache.log4j.ConsoleAppender
......
drip-commons/src/main/java/nl/uva/sne/drip/commons/utils/Converter.java
View file @ afb495a3
......@@ -37,6 +37,7 @@ import nl.uva.sne.drip.drip.commons.data.internal.Message;
import nl.uva.sne.drip.drip.commons.data.internal.MessageParameter;
import nl.uva.sne.drip.drip.commons.data.v0.external.Attribute;
import nl.uva.sne.drip.drip.commons.data.v1.external.PlanResponse;
import org.yaml.snakeyaml.DumperOptions;
/**
*
......@@ -138,7 +139,11 @@ public class Converter {
}
public static String json2Yml2(String jsonString) throws JSONException {
Yaml yaml = new Yaml();
DumperOptions options = new DumperOptions();
options.setDefaultFlowStyle(DumperOptions.FlowStyle.BLOCK);
options.setPrettyFlow(true);
options.setDefaultScalarStyle(DumperOptions.ScalarStyle.SINGLE_QUOTED);
Yaml yaml = new Yaml(options);
String yamlStr = yaml.dump(ymlString2Map(jsonString));
return yamlStr;
}
......
drip-commons/src/main/java/nl/uva/sne/drip/commons/utils/DRIPLogHandler.java
View file @ afb495a3
......@@ -32,6 +32,8 @@ import java.util.logging.StreamHandler;
import nl.uva.sne.drip.commons.utils.DRIPLogRecordFactory;
import nl.uva.sne.drip.drip.commons.data.v1.external.DRIPLogRecord;
import nl.uva.sne.drip.drip.commons.data.v1.external.User;
import org.springframework.security.core.Authentication;
import org.springframework.security.core.context.SecurityContext;
import org.springframework.security.core.context.SecurityContextHolder;
/**
......@@ -43,6 +45,7 @@ public class DRIPLogHandler extends StreamHandler {
private final String qeueName;
private final ObjectMapper mapper;
private final ConnectionFactory factory;
private String owner;
public DRIPLogHandler(String messageBrokerHost) throws IOException, TimeoutException {
factory = new ConnectionFactory();
......@@ -62,16 +65,21 @@ public class DRIPLogHandler extends StreamHandler {
try (Connection connection = factory.newConnection()) {
Channel channel = connection.createChannel();
User user = (User) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
String owner = user.getUsername();
SecurityContext ctx = SecurityContextHolder.getContext();
Authentication auth = ctx.getAuthentication();
if (auth != null) {
User user = (User) auth.getPrincipal();
setOwner(user.getUsername());
}
DRIPLogRecord dripLog = DRIPLogRecordFactory.create(record);
dripLog.setOwner(owner);
dripLog.setOwner(getOwner());
String jsonInString = mapper.writeValueAsString(dripLog);
// channel.basicPublish(qeueName, owner, null, jsonInString.getBytes());
// channel.basicPublish(qeueName, owner, MessageProperties.PERSISTENT_TEXT_PLAIN, jsonInString.getBytes("UTF-8"));
String qeueNameUser = qeueName + "_" + owner;
String qeueNameUser = qeueName + "_" + getOwner();
channel.queueDeclare(qeueNameUser, true, false, false, null);
channel.basicPublish("", qeueNameUser, MessageProperties.PERSISTENT_TEXT_PLAIN, jsonInString.getBytes("UTF-8"));
......@@ -97,4 +105,17 @@ public class DRIPLogHandler extends StreamHandler {
// }
// super.close();
// }
/**
* @return the owner
*/
public String getOwner() {
return owner;
}
/**
* @param owner the owner to set
*/
public void setOwner(String owner) {
this.owner = owner;
}
}
drip-deployer/docker_check.py
View file @ afb495a3
......@@ -25,6 +25,7 @@ import linecache
import sys
import ast
import re
from drip_logging.drip_logging_handler import *
logger = logging.getLogger(__name__)
if not getattr(logger, 'handler_set', None):
......@@ -140,7 +141,9 @@ def docker_check(vm, compose_name):
def run(vm_list, compose_name):
def run(vm_list, compose_name,rabbitmq_host,owner):
rabbit = DRIPLoggingHandler(host=rabbitmq_host, port=5672,user=owner)
logger.addHandler(rabbit)
for i in vm_list:
if i.role == "master":
ret = docker_check(i, compose_name)
......
drip-deployer/docker_compose.py
View file @ afb495a3
......@@ -20,6 +20,8 @@ __author__ = 'Yang Hu'
import paramiko, os
from vm_info import VmInfo
import logging
from drip_logging.drip_logging_handler import *
logger = logging.getLogger(__name__)
if not getattr(logger, 'handler_set', None):
......@@ -53,7 +55,9 @@ def deploy_compose(vm, compose_file, compose_name):
def run(vm_list, compose_file, compose_name):
def run(vm_list, compose_file, compose_name,rabbitmq_host,owner):
rabbit = DRIPLoggingHandler(host=rabbitmq_host, port=5672,user=owner)
logger.addHandler(rabbit)
for i in vm_list:
if i.role == "master":
ret = deploy_compose(i, compose_file, compose_name)
......
drip-deployer/docker_engine.py
View file @ afb495a3
......@@ -20,6 +20,7 @@ __author__ = 'Yang Hu'
import paramiko, os
import threading
import logging
from drip_logging.drip_logging_handler import *
logger = logging.getLogger(__name__)
if not getattr(logger, 'handler_set', None):
......@@ -58,8 +59,10 @@ def install_engine(vm):
ssh.close()
return "SUCCESS"
def run(vm_list):
for i in vm_list:
ret = install_engine(i)
if "ERROR" in ret: return ret
return "SUCCESS"
\ No newline at end of file
def run(vm_list,rabbitmq_host,owner):
rabbit = DRIPLoggingHandler(host=rabbitmq_host, port=5672,user=owner)
logger.addHandler(rabbit)
for i in vm_list:
ret = install_engine(i)
if "ERROR" in ret: return ret
return "SUCCESS"
\ No newline at end of file
drip-deployer/docker_swarm.py
View file @ afb495a3
......@@ -20,6 +20,7 @@ __author__ = 'Yang Hu'
import paramiko, os
from vm_info import VmInfo
import logging
from drip_logging.drip_logging_handler import *
logger = logging.getLogger(__name__)
......@@ -83,7 +84,9 @@ def install_worker(join_cmd, vm):
ssh.close()
return "SUCCESS"
def run(vm_list):
def run(vm_list,rabbitmq_host,owner):
rabbit = DRIPLoggingHandler(host=rabbitmq_host, port=5672,user=owner)
logger.addHandler(rabbit)
for i in vm_list:
if i.role == "master":
join_cmd = install_manager(i)
......
drip-deployer/drip_logging/drip_logging_handler.py 0 → 100644
View file @ afb495a3
import json
import logging
import pika
from python_logging_rabbitmq import RabbitMQHandler
class DRIPLoggingHandler(RabbitMQHandler):
def __init__(self, host='localhost', port=5672, username=None, password=None, user=None):
super(DRIPLoggingHandler, self).__init__(host=host, port=port, username=username, password=password)
self.user = user
def open_connection(self):
self.sequenceNumber = 0
"""
Connect to RabbitMQ.
"""
# Set logger for pika.
# See if something went wrong connecting to RabbitMQ.
handler = logging.StreamHandler()
handler.setFormatter(self.formatter)
rabbitmq_logger = logging.getLogger('pika')
rabbitmq_logger.addHandler(handler)
rabbitmq_logger.propagate = False
rabbitmq_logger.setLevel(logging.WARNING)
if not self.connection or self.connection.is_closed:
self.connection = pika.BlockingConnection(pika.ConnectionParameters(** self.connection_params))
if not self.channel or self.channel.is_closed:
self.channel = self.connection.channel()
self.channel.queue_declare(queue='log_qeue_' + self.user, durable=True)
# Manually remove logger to avoid shutdown message.
rabbitmq_logger.removeHandler(handler)
def emit(self, record):
self.acquire()
try:
if not self.connection or self.connection.is_closed or not self.channel or self.channel.is_closed:
self.open_connection()
self.channel.basic_publish(
exchange='',
routing_key='log_qeue_user',
body=self.format(record),
properties=pika.BasicProperties(
delivery_mode=2)
)
except Exception:
self.channel, self.connection = None, None
self.handleError(record)
finally:
if self.close_after_emit:
self.close_connection()
self.release()
def format(self, record):
drip_record = {}
drip_record['timestamp'] = record.created
drip_record['owner'] = 'user'
drip_record['level'] = record.levelname
drip_record['loggerName'] = record.module
drip_record['message'] = record.message
drip_record['millis'] = record.created
self.sequenceNumber += 1
drip_record['sequenceNumber'] = self.sequenceNumber
drip_record['sourceClassName'] = record.module
drip_record['sourceMethodName'] = record.funcName
return json.dumps(drip_record)
\ No newline at end of file
drip-deployer/monitoring_agent.log 0 → 100644
View file @ afb495a3
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | WARNING: USER DID NOT PROVIDE PUBLICALY ROUTABLE IP OF THE HOST MACHINE WHERE CONTAINER WILL RUN. TRYING TO FIND OUT THIS IP WITH https://api.apify.org!
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | WARINING: USER DID NOT PROVIDE MONITORING SERVER IP. DEFAULT VALUE WILL BE USED!
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | sed: -e expression #1, char 18: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | /root/start.sh: line 61: ./installer.sh: Permission denied
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | sed: -e expression #1, char 54: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Before
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | After
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | 147.228.242.130
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | WARNING: USER DID NOT PROVIDE PUBLICALY ROUTABLE IP OF THE HOST MACHINE WHERE CONTAINER WILL RUN. TRYING TO FIND OUT THIS IP WITH https://api.apify.org!
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | WARINING: USER DID NOT PROVIDE MONITORING SERVER IP. DEFAULT VALUE WILL BE USED!
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | sed: -e expression #1, char 18: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | /root/start.sh: line 61: ./installer.sh: Permission denied
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | WARNING: USER DID NOT PROVIDE PUBLICALY ROUTABLE IP OF THE HOST MACHINE WHERE CONTAINER WILL RUN. TRYING TO FIND OUT THIS IP WITH https://api.apify.org!
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | WARNING: USER DID NOT PROVIDE PUBLICALY ROUTABLE IP OF THE HOST MACHINE WHERE CONTAINER WILL RUN. TRYING TO FIND OUT THIS IP WITH https://api.apify.org!
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | WARINING: USER DID NOT PROVIDE MONITORING SERVER IP. DEFAULT VALUE WILL BE USED!
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Before
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | After
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | 147.228.242.130
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Before
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | After
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | 147.228.242.130
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Before
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | After
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | WARINING: USER DID NOT PROVIDE MONITORING SERVER IP. DEFAULT VALUE WILL BE USED!
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | 147.228.242.130
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:43 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent initLogging
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: JCatascopia-Agent: Created and Initialized
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: CPUProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | sed: -e expression #1, char 18: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | sed: -e expression #1, char 18: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | /root/start.sh: line 61: ./installer.sh: Permission denied
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | /root/start.sh: line 61: ./installer.sh: Permission denied
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: MemoryProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: DiskStatsProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: StaticInfoProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | WARNING: USER DID NOT PROVIDE PUBLICALY ROUTABLE IP OF THE HOST MACHINE WHERE CONTAINER WILL RUN. TRYING TO FIND OUT THIS IP WITH https://api.apify.org!
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | WARINING: USER DID NOT PROVIDE MONITORING SERVER IP. DEFAULT VALUE WILL BE USED!
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | sed: -e expression #1, char 18: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | /root/start.sh: line 61: ./installer.sh: Permission denied
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | sed: -e expression #1, char 54: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | sed: -e expression #1, char 54: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Before
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | After
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | 147.228.242.131
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Before
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | After
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | 147.228.242.131
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Before
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | After
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | 147.228.242.131
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Before
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | After
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | 147.228.242.131
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent initLogging
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: JCatascopia-Agent: Created and Initialized
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: CPUProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: MemoryProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: DiskStatsProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: StaticInfoProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: DiskProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: NetworkProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: CPUProbe: CPUProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: MemoryProbe: MemoryProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: DiskProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: NetworkProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: CPUProbe: CPUProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: MemoryProbe: MemoryProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | chmod: invalid mode: ‘x’
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Before
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | After
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | 147.228.242.127
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Before
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | After
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | 147.228.242.127
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Before
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | After
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | 147.228.242.127
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Before
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | After
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | 147.228.242.127
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent initLogging
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: JCatascopia-Agent: Created and Initialized
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: CPUProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: MemoryProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | sed: -e expression #1, char 54: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Try 'chmod --help' for more information.
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | sed: -e expression #1, char 54: unknown option to `s'
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent initLogging
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: JCatascopia-Agent: Created and Initialized
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: DiskStatsProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: StaticInfoProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: DiskProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: NetworkProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: CPUProbe: CPUProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: MemoryProbe: MemoryProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: DiskStatsProbe: DiskStatsProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: StaticInfoProbe: StaticInfoProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: DiskProbe: DiskProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: NetworkProbe: NetworkProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | Nov 07, 2017 3:24:52 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.p8nj8ebua24m@stoor127 | INFO: JCatascopia-Agent: Probes Activated: CPUProbe,MemoryProbe,DiskStatsProbe,StaticInfoProbe,DiskProbe,NetworkProbe
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: DiskStatsProbe: DiskStatsProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: StaticInfoProbe: StaticInfoProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: DiskProbe: DiskProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: NetworkProbe: NetworkProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:21:16 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | INFO: JCatascopia-Agent: Probes Activated: CPUProbe,MemoryProbe,DiskStatsProbe,StaticInfoProbe,DiskProbe,NetworkProbe
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | Nov 07, 2017 3:22:01 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.xngi87xtwbff@stoor131 | SEVERE: JCatascopia-Agent: FAILED to CONNECT to Monitoring Server at: 194.249.0.192
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: DiskStatsProbe: DiskStatsProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: StaticInfoProbe: StaticInfoProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: DiskProbe: DiskProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: NetworkProbe: NetworkProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:06:44 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | INFO: JCatascopia-Agent: Probes Activated: CPUProbe,MemoryProbe,DiskStatsProbe,StaticInfoProbe,DiskProbe,NetworkProbe
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | Nov 07, 2017 3:07:29 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.yp4hm3grdrft@stoor130 | SEVERE: JCatascopia-Agent: FAILED to CONNECT to Monitoring Server at: 194.249.0.192
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Before
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | After
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | 147.228.242.133
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:23:59 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent initLogging
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: CPUProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: JCatascopia-Agent: Created and Initialized
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: MemoryProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: CPUProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: DiskStatsProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: MemoryProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: DiskStatsProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: StaticInfoProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: StaticInfoProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: DiskProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: DiskProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: NetworkProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: NetworkProbe: Logging turned ON
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: CPUProbe: CPUProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: CPUProbe: CPUProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: MemoryProbe: MemoryProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: MemoryProbe: MemoryProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: DiskStatsProbe: DiskStatsProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: DiskStatsProbe: DiskStatsProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: StaticInfoProbe: StaticInfoProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: StaticInfoProbe: StaticInfoProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: DiskProbe: DiskProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: DiskProbe: DiskProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.probepack.Probe writeToProbeLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: NetworkProbe: NetworkProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: NetworkProbe: NetworkProbe: Probe Activated
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:00 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:06 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | INFO: JCatascopia-Agent: Probes Activated: CPUProbe,MemoryProbe,DiskStatsProbe,StaticInfoProbe,DiskProbe,NetworkProbe
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | Nov 07, 2017 3:24:45 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | INFO: JCatascopia-Agent: Probes Activated: CPUProbe,MemoryProbe,DiskStatsProbe,StaticInfoProbe,DiskProbe,NetworkProbe
5a01c48bfa965310b7421cca_agent.1.xoqm08m5nwug@stoor133 | SEVERE: JCatascopia-Agent: FAILED to CONNECT to Monitoring Server at: 194.249.0.192
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | Nov 07, 2017 3:23:51 PM eu.celarcloud.jcatascopia.agentpack.MonitoringAgent writeToLog
5a01c48bfa965310b7421cca_agent.1.vizydkndeq8z@stoor133 | SEVERE: JCatascopia-Agent: FAILED to CONNECT to Monitoring Server at: 194.249.0.192
\ No newline at end of file
drip-deployer/monitoring_server.log 0 → 100644
View file @ afb495a3
This source diff could not be displayed because it is too large. You can view the blob instead.
drip-deployer/rpc_server.py
View file @ afb495a3
......@@ -18,7 +18,7 @@ from time import sleep
import os.path
import logging
global rabbitmq_host
if len(sys.argv) > 1:
rabbitmq_host = sys.argv[1]
else:
......@@ -49,6 +49,7 @@ def threaded_function(args):
def handleDelivery(message):
parsed_json = json.loads(message)
owner = parsed_json['owner']
params = parsed_json["parameters"]
node_num = 0
vm_list = set()
......@@ -112,20 +113,20 @@ def handleDelivery(message):
ret = docker_kubernetes.run(vm_list)
return ret
elif manager_type == "swarm":
ret = docker_engine.run(vm_list)
ret = docker_engine.run(vm_list,rabbitmq_host,owner)
if "ERROR" in ret: return ret
ret = docker_swarm.run(vm_list)
ret = docker_swarm.run(vm_list,rabbitmq_host,owner)
if "ERROR" in ret: return ret
ret = docker_compose.run(vm_list, compose_file, compose_name)
ret = docker_compose.run(vm_list, compose_file, compose_name,rabbitmq_host,owner)
return ret
elif manager_type == "ansible":
ret = ansible_playbook.run(vm_list,playbook)
ret = ansible_playbook.run(vm_list,playbook,rabbitmq_host,owner)
return ret
elif manager_type == "scale":
ret = docker_service.run(vm_list, name_of_deployment, name_of_service, number_of_containers)
ret = docker_service.run(vm_list, name_of_deployment, name_of_service, number_of_containers,rabbitmq_host,owner)
return ret
elif manager_type == "swarm_info":
ret = docker_check.run(vm_list, compose_name)
ret = docker_check.run(vm_list, compose_name,rabbitmq_host,owner)
ret = '"'+json.dumps(ret)+'"'
return ret
else:
......
drip-deployer/stack.yml 0 → 100644
View file @ afb495a3
"version": "3"
"services":
"server":
"image": "salmant/ul_monitoring_server_container_image2"
"ports":
- "8080:8080"
- "4242:4242"
- "4245:4245"
- "7199:7199"
- "7000:7000"
- "7001:7001"
- "9160:9160"
- "9042:9042"
- "8012:8012"
- "61621:61621"
"environment":
- "MONITORING_SERVER=server"
"agent":
"image": "salmant/monitoring_agent"
"depends_on":
- "server"
drip-provisioner/src/main/java/nl/uva/sne/drip/drip/provisioner/RPCServer.java
View file @ afb495a3
......@@ -73,7 +73,7 @@ public class RPCServer {
if (PropertyValues.RPC_QUEUE_NAME.endsWith("v0")) {
c = new nl.uva.sne.drip.drip.provisioner.v0.Consumer(channel);
} else {
c = new nl.uva.sne.drip.drip.provisioner.v1.Consumer(channel);
c = new nl.uva.sne.drip.drip.provisioner.v1.Consumer(channel, PropertyValues.HOST);
}
//Start listening for messages
......
drip-provisioner/src/main/java/nl/uva/sne/drip/drip/provisioner/v1/Consumer.java
View file @ afb495a3
......@@ -34,9 +34,11 @@ import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeoutException;
import java.util.logging.Level;
import java.util.logging.Logger;
import nl.uva.sne.drip.commons.utils.Converter;
import nl.uva.sne.drip.commons.utils.DRIPLogHandler;
import nl.uva.sne.drip.drip.commons.data.internal.Message;
import nl.uva.sne.drip.drip.commons.data.internal.MessageParameter;
import nl.uva.sne.drip.drip.provisioner.utils.MessageParsing;
......@@ -74,10 +76,15 @@ public class Consumer extends DefaultConsumer {
private final Channel channel;
// Map<String, String> em = new HashMap<>();
private final Logger logger;
private final String messageBrokerHost;
public Consumer(Channel channel) throws IOException {
public Consumer(Channel channel, String messageBrokerHost) throws IOException, TimeoutException {
super(channel);
this.channel = channel;
this.messageBrokerHost = messageBrokerHost;
logger = Logger.getLogger(Consumer.class.getName());
}
@Override
......@@ -102,12 +109,18 @@ public class Consumer extends DefaultConsumer {
ObjectMapper mapper = new ObjectMapper();
mapper.configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true);
String owner = mapper.readValue(message, Message.class).getOwner();
DRIPLogHandler handler = new DRIPLogHandler(messageBrokerHost);
handler.setOwner(owner);
logger.addHandler(handler);
response = mapper.writeValueAsString(invokeProvisioner(message, tempInputDirPath));
} catch (Throwable ex) {
try {
response = generateExeptionResponse(ex);
Logger.getLogger(Consumer.class.getName()).log(Level.SEVERE, null, ex);
// Logger.getLogger(Consumer.class.getName())
logger.log(Level.SEVERE, null, ex);
} catch (JSONException ex1) {
response = "{\"creationDate\": " + System.currentTimeMillis()
+ ",\"parameters\": [{\"url\": null,\"encoding\": UTF-8,"
......@@ -115,7 +128,8 @@ public class Consumer extends DefaultConsumer {
+ ex.getClass().getName() + "\",\"attributes\": null}]}";
}
} finally {
Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Sending Response: {0}", response);
logger.fine("Sending Response: {0}" + response);
// Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Sending Response: {0}", response);
//We send the response back. No need to change anything here
channel.basicPublish("", properties.getReplyTo(), replyProps, response.getBytes("UTF-8"));
channel.basicAck(envelope.getDeliveryTag(), false);
......@@ -152,7 +166,8 @@ public class Consumer extends DefaultConsumer {
}
private Message startTopology(JSONArray parameters, String tempInputDirPath) throws Exception {
Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Starting topology");
// Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Starting topology");
logger.info("Starting topology");
TEngine tEngine = new TEngine();
TopologyAnalysisMain tam = null;
UserCredential userCredential = new UserCredential();
......@@ -167,7 +182,8 @@ public class Consumer extends DefaultConsumer {
// File secondaryTopologyFile = new File(tempInputDirPath + File.separator + lowLevelTopologyFile.getName() + ".yml");
// FileUtils.moveFile(lowLevelTopologyFile, secondaryTopologyFile);
// }
Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Saved topology file");
// Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Saved topology file");
logger.info("Saved topology file");
Map<String, Object> map = Converter.ymlStream2Map(new FileInputStream(topTopologyLoadingPath));
String userPublicKeyName = ((String) map.get("publicKeyPath"));
if (userPublicKeyName != null) {
......@@ -178,7 +194,8 @@ public class Consumer extends DefaultConsumer {
String cont = Converter.map2YmlString(map);
MessageParsing.writeValueToFile(cont, new File(topTopologyLoadingPath));
}
Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Generated id_rsa.pub");
logger.info("Generated id_rsa.pub");
String userPrivateName = FilenameUtils.removeExtension(userPublicKeyName);
List<File> sshKeys = MessageParsing.getSSHKeys(parameters, tempInputDirPath, userPublicKeyName, "user_ssh_key");
if (sshKeys == null || sshKeys.isEmpty()) {
......@@ -205,11 +222,11 @@ public class Consumer extends DefaultConsumer {
} else if (!userCredential.initial(sshKeyPairs, tam.wholeTopology)) {
throw new IOException("ssh key pair initilaziation error");
}
Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Generated ssh keys");
logger.info("Generated ssh keys");
userDatabase = getUserDB();
tEngine.provisionAll(tam.wholeTopology, userCredential, userDatabase);
Logger.getLogger(Consumer.class.getName()).log(Level.INFO, "Provisioned resources");
logger.info("Provisioned resources");
return buildTopologuResponse(tam, tempInputDirPath, userPublicKeyName, userPrivateName);
} catch (Throwable ex) {
......
drip-provisioner/src/main/resources/log4j.properties 0 → 100644
View file @ afb495a3
# LOG4J Configuration
# ===================
# Set root logger level to DEBUG and its only appender to A1.
log4j.rootLogger=FINE, A1
# A1 is set to be a ConsoleAppender.
log4j.appender.A1=org.apache.log4j.ConsoleAppender
# A1 uses PatternLayout.
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=%d{HH:mm:ss,SSS} (%t) %-5p [%c] - %m%n
\ No newline at end of file
drip-provisioner/src/main/resources/logging.properties 0 → 100644
View file @ afb495a3
handlers = java.util.logging.ConsoleHandler
nl.uva.cs.level = FINE
############################################################
# Handler specific properties.
# Describes specific configuration info for Handlers.
############################################################
java.util.logging.ConsoleHandler.level = FINE
java.util.logging.ConsoleHandler.formatter = java.util.logging.SimpleFormatter
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment