Class: DCell::Registry::ZkPresenceAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/dcell/registries/zk_presence_adapter.rb

Defined Under Namespace

Classes: GlobalRegistry, NodeRegistry

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ ZkPresenceAdapter

Returns a new instance of ZkPresenceAdapter.



7
8
9
10
11
12
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 7

def initialize(options)       
  Celluloid::Presence::ZkService.init options
  
  @node_registry = NodeRegistry.new(options)
  @global_registry = GlobalRegistry.new(:zk_service, options)
end

Instance Method Details

#clear_globals ⇒ Object 



146
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 146

def clear_globals;      @global_registry.clear end

#clear_nodes ⇒ Object

This is now self maintaining hence no op



94
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 94

def clear_nodes;        end

#get_global(key) ⇒ Object 



147
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 147

def get_global(key);    @global_registry.get(key) end

#get_node(node_id) ⇒ Object 



95
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 95

def get_node(node_id);      @node_registry.get(node_id) end

#global_keys ⇒ Object 



149
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 149

def global_keys;      @global_registry.global_keys end

#nodes ⇒ Object 



96
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 96

def nodes;            @node_registry.nodes end

#set_global(key, value) ⇒ Object 



148
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 148

def set_global(key, value); @global_registry.set(key, value) end

#set_node(node_id, addr) ⇒ Object 



97
 
# File 'lib/dcell/registries/zk_presence_adapter.rb', line 97

def set_node(node_id, addr);  @node_registry.set(node_id, addr) end