class FlowConfig
This class holds the base config
Public Class Methods
config()
click to toggle source
# File lib/manband/flowconfig.rb, line 126 def self.config url ||= (ENV["AMQP_URL"] || "amqp://guest:guest@localhost/") uri = URI.parse(url) { :vhost => uri.path, :host => uri.host, :user => uri.user, :port => (uri.port || 5672), :pass => uri.password, :heartbeat => 0 } rescue Object => e raise("invalid AMQP_URL: #{uri.inspect} (#{e})") end
getjobdir(workflowdir = nil)
click to toggle source
Returns a work directory for a job. Directory is based on a unique identifier.
# File lib/manband/flowconfig.rb, line 117 def self.getjobdir(workflowdir = nil) uuid = UUID.new if workflowdir == nil return @@workdir+"/"+uuid.generate.to_s else return workflowdir+"/"+uuid.generate.to_s end end
s3host()
click to toggle source
# File lib/manband/flowconfig.rb, line 77 def self.s3host return @@s3host end
s3path()
click to toggle source
# File lib/manband/flowconfig.rb, line 94 def self.s3path return @@s3path end
s3port()
click to toggle source
# File lib/manband/flowconfig.rb, line 90 def self.s3port return @@s3port end
sets3(host,port= '8773',path='/services/Walrus')
click to toggle source
Sets S3 storage parameters
Parameters can be set in user config fiel under s3 parameter
# File lib/manband/flowconfig.rb, line 84 def self.sets3(host,port= '8773',path='/services/Walrus') @@s3host = host @@s3port = port @@s3path = path end
setsudo(dosudo)
click to toggle source
Sets sudo mode If sudo is set, job commands are run with a sudo on user id. User
must exists on the system.
Can be set in user config file with sudo: true
# File lib/manband/flowconfig.rb, line 69 def self.setsudo(dosudo) @@sudo = dosudo end
setuploaddir(directory)
click to toggle source
defines upload directory for webband It must be accessible by the handlers
# File lib/manband/flowconfig.rb, line 104 def self.setuploaddir(directory) @@uploaddir = directory end
setworkdir(directory)
click to toggle source
Defines the work directory. It must be shared between job and workflow handlers.
# File lib/manband/flowconfig.rb, line 110 def self.setworkdir(directory) @@workdir=directory end
sudo()
click to toggle source
# File lib/manband/flowconfig.rb, line 60 def self.sudo return @@sudo end
uploaddir()
click to toggle source
# File lib/manband/flowconfig.rb, line 73 def self.uploaddir return @@uploaddir end
workdir()
click to toggle source
# File lib/manband/flowconfig.rb, line 98 def self.workdir return @@workdir end