Class: DCell::Registry::MongodbAdapter

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

Defined Under Namespace

Classes: DCellGlobal, DCellNode, Proxy

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ MongodbAdapter

Setup connection to mongodb config: path to mongoid configuration file env: mongoid environment to use



9
10
11
12
13
14
15
16
17
18
# File 'lib/dcell/registries/mongodb_adapter.rb', line 9

def initialize(options)
  if options[:config]
    Mongoid.load! options[:config], options[:env]
  elsif options[:db]
    Mongoid.connect_to options[:db]
  end
  if options[:options]
    Mongoid.options = options[:options]
  end
end

Instance Method Details

#clear_all_nodesObject



76
# File 'lib/dcell/registries/mongodb_adapter.rb', line 76

def clear_all_nodes;         Proxy.clear_all(DCellNode) end

#clear_globalsObject



81
# File 'lib/dcell/registries/mongodb_adapter.rb', line 81

def clear_globals;           Proxy.clear_all(DCellGlobal) end

#get_global(key) ⇒ Object



78
# File 'lib/dcell/registries/mongodb_adapter.rb', line 78

def get_global(key);         Proxy.get(DCellGlobal, key) end

#get_node(node_id) ⇒ Object



72
# File 'lib/dcell/registries/mongodb_adapter.rb', line 72

def get_node(node_id);       Proxy.get(DCellNode, node_id) end

#global_keysObject



80
# File 'lib/dcell/registries/mongodb_adapter.rb', line 80

def global_keys;             Proxy.all(DCellGlobal) end

#nodesObject



74
# File 'lib/dcell/registries/mongodb_adapter.rb', line 74

def nodes;                   Proxy.all(DCellNode) end

#remove_node(node_id) ⇒ Object



75
# File 'lib/dcell/registries/mongodb_adapter.rb', line 75

def remove_node(node_id);    Proxy.remove(DCellNode, node_id) end

#set_global(key, value) ⇒ Object



79
# File 'lib/dcell/registries/mongodb_adapter.rb', line 79

def set_global(key, value);  Proxy.set(DCellGlobal, key, value) end

#set_node(node_id, addr) ⇒ Object



73
# File 'lib/dcell/registries/mongodb_adapter.rb', line 73

def set_node(node_id, addr); Proxy.set(DCellNode, node_id, addr) end