Module: Gush

Defined in:
lib/gush.rb,
lib/gush/cli.rb,
lib/gush/job.rb,
lib/gush/json.rb,
lib/gush/graph.rb,
lib/gush/client.rb,
lib/gush/errors.rb,
lib/gush/worker.rb,
lib/gush/workflow.rb,
lib/gush/cli/overview.rb,
lib/gush/configuration.rb

Defined Under Namespace

Classes: CLI, Client, Configuration, DependencyLevelTooDeep, Graph, JSON, Job, Worker, Workflow, WorkflowNotFound

Class Method Summary collapse

Class Method Details

.configuration ⇒ Object 



31
32
33
 
# File 'lib/gush.rb', line 31

def self.configuration
  @configuration ||= Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:



35
36
37
38
 
# File 'lib/gush.rb', line 35

def self.configure
  yield configuration
  reconfigure_sidekiq
end

.gushfile ⇒ Object 



23
24
25
 
# File 'lib/gush.rb', line 23

def self.gushfile
  configuration.gushfile
end

.reconfigure_sidekiq ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/gush.rb', line 40

def self.reconfigure_sidekiq
  #puts "^^^^^^^^ reconfigure_sidekiq ^^^"
  Sidekiq.configure_server do |config|
    #config.redis = { url: configuration.redis_url, queue: configuration.namespace}

    opts = { url: configuration.redis_url, namespace: configuration.redis_prefix, queue: configuration.sidekiq_queue }
    #puts "sidekiq server opts: #{opts}"
    config.redis = { url: configuration.redis_url, namespace: configuration.redis_prefix, queue: configuration.sidekiq_queue }
  end

  Sidekiq.configure_client do |config|
    #config.redis = { url: configuration.redis_url, queue: configuration.namespace}

    opts = { url: configuration.redis_url, namespace: configuration.redis_prefix, queue: configuration.sidekiq_queue }
    #puts "sidekiq client opts: #{opts}"

    config.redis = { url: configuration.redis_url, namespace: configuration.redis_prefix, queue: configuration.sidekiq_queue }
  end
end

.root ⇒ Object 



27
28
29
 
# File 'lib/gush.rb', line 27

def self.root
  Pathname.new(__FILE__).parent.parent
end