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