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 



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

def clear_globals;			@global_registry.clear end

#clear_nodes ⇒ Object

This is now self maintaining hence no op



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

def clear_nodes;				end

#get_global(key) ⇒ Object 



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

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

#get_node(node_id) ⇒ Object 



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

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

#global_keys ⇒ Object 



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

def global_keys;			@global_registry.global_keys end

#nodes ⇒ Object 



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

def nodes;						@node_registry.nodes end

#set_global(key, value) ⇒ Object 



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

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

#set_node(node_id, addr) ⇒ Object 



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

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