Module: BusinessFlow::ClusterLock

Defined in:
lib/business_flow/cluster_lock.rb

Overview

Mixin for business flow to acquire and retain a cluster lock.

Defined Under Namespace

Modules: ClassMethods

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.default_servers ⇒ Object 



32
33
34
 
# File 'lib/business_flow/cluster_lock.rb', line 32

def self.default_servers
  @default_servers ||= proc { nil }
end

.default_servers=(servers) ⇒ Object 



22
23
24
25
26
27
28
29
30
 
# File 'lib/business_flow/cluster_lock.rb', line 22

def self.default_servers=(servers)
  if servers.is_a?(String)
    @default_servers = proc { servers }
  elsif servers
    @default_servers = Callable.new(servers)
  else
    @default_servers = nil
  end
end

.disable! ⇒ Object 



10
11
12
 
# File 'lib/business_flow/cluster_lock.rb', line 10

def self.disable!
  @disabled = true
end

.disabled? ⇒ Boolean

Returns:

  • (Boolean) 


18
19
20
 
# File 'lib/business_flow/cluster_lock.rb', line 18

def self.disabled?
  !!@disabled
end

.enable! ⇒ Object 



14
15
16
 
# File 'lib/business_flow/cluster_lock.rb', line 14

def self.enable!
  @disabled = false
end

.included(klass) ⇒ Object 



6
7
8
 
# File 'lib/business_flow/cluster_lock.rb', line 6

def self.included(klass)
  klass.extend(ClassMethods)
end

Instance Method Details

#assert_cluster_lock! ⇒ Object 



36
37
38
39
40
41
 
# File 'lib/business_flow/cluster_lock.rb', line 36

def assert_cluster_lock!
  @_business_flow_cluster_lock.assert! if !BusinessFlow::ClusterLock.disabled?
rescue ZK::Exceptions::ZKError => exc
  errors.add(:cluster_lock, :assert_failed, message: exc.message)
  raise
end

#read_attribute_for_validation(key) ⇒ Object 



43
44
45
46
47
48
49
 
# File 'lib/business_flow/cluster_lock.rb', line 43

def read_attribute_for_validation(key)
  if key == :cluster_lock
    ClassMethods.lock_name(self)
  else
    super(key)
  end
end