Module: ZQ

Defined in:
lib/zq.rb,
lib/zq/cli.rb,
lib/zq/version.rb,
lib/zq/orchestra.rb,
lib/zq/sources/io.rb,
lib/zq/composers/io.rb,
lib/zq/sources/redis.rb,
lib/zq/composers/json.rb,
lib/zq/sources/mixins.rb,
lib/zq/composers/redis.rb,
lib/zq/composers/uuid4.rb

Defined Under Namespace

Modules: Composer, Orchestra, Sources Classes: CLI

Constant Summary collapse

VERSION = 
'0.2.0'
@@live_orchestras = 
[]
@@_all_known_orchestras = 
[]
@@autoregister = 
true

Class Method Summary collapse

Class Method Details

.autoregister_orchestra(orc) ⇒ Object 



15
16
17
18
 
# File 'lib/zq/orchestra.rb', line 15

def self.autoregister_orchestra(orc)
  register_orchestra(orc) if autoregister_orchestra?
  @@_all_known_orchestras = @@_all_known_orchestras.push(orc)
end

.autoregister_orchestra! ⇒ Object 



40
41
42
 
# File 'lib/zq/orchestra.rb', line 40

def self.autoregister_orchestra!
  @@autoregister = true
end

.autoregister_orchestra? ⇒ Boolean

Returns:

  • (Boolean) 


44
45
46
 
# File 'lib/zq/orchestra.rb', line 44

def self.autoregister_orchestra?
  @@autoregister
end

.create_orchestra(&block) ⇒ Object 



6
7
8
9
10
11
12
13
 
# File 'lib/zq/orchestra.rb', line 6

def self.create_orchestra(&block)
  klass = Class.new
  klass.class_exec do
    include ZQ::Orchestra
  end
  klass.class_exec(&block) if block_given?
  klass
end

.deregister_orchestra(orc) ⇒ Object 



24
25
26
 
# File 'lib/zq/orchestra.rb', line 24

def self.deregister_orchestra(orc)
  @@live_orchestras.reject! { |o| o == orc }
end

.find_live_orchestra(orc_name) ⇒ Object 



32
33
34
 
# File 'lib/zq/orchestra.rb', line 32

def self.find_live_orchestra(orc_name)
  live_orchestras.detect { |o| o.name == orc_name  }
end

.live_orchestras ⇒ Object 



28
29
30
 
# File 'lib/zq/orchestra.rb', line 28

def self.live_orchestras
  @@live_orchestras
end

.register_orchestra(orc) ⇒ Object 



20
21
22
 
# File 'lib/zq/orchestra.rb', line 20

def self.register_orchestra(orc)
  @@live_orchestras = @@live_orchestras.push orc
end

.stop_autoregister_orchestra! ⇒ Object 



36
37
38
 
# File 'lib/zq/orchestra.rb', line 36

def self.stop_autoregister_orchestra!
  @@autoregister = false
end