Class: DCell::Registry::CassandraAdapter::NodeRegistry
- Inherits:
-
Object
- Object
- DCell::Registry::CassandraAdapter::NodeRegistry
- Defined in:
- lib/dcell/registries/cassandra_adapter.rb
Instance Method Summary collapse
- #clear_all ⇒ Object
- #get(node_id) ⇒ Object
-
#initialize(cass, cf) ⇒ NodeRegistry
constructor
A new instance of NodeRegistry.
- #nodes ⇒ Object
- #remove(node) ⇒ Object
- #set(node_id, addr) ⇒ Object
Constructor Details
#initialize(cass, cf) ⇒ NodeRegistry
Returns a new instance of NodeRegistry.
64 65 66 67 |
# File 'lib/dcell/registries/cassandra_adapter.rb', line 64 def initialize(cass, cf) @cass = cass @cf = cf end |
Instance Method Details
#clear_all ⇒ Object
85 86 87 |
# File 'lib/dcell/registries/cassandra_adapter.rb', line 85 def clear_all @cass.del @cf, "nodes" end |
#get(node_id) ⇒ Object
69 70 71 |
# File 'lib/dcell/registries/cassandra_adapter.rb', line 69 def get(node_id) @cass.get @cf, "nodes", node_id end |
#nodes ⇒ Object
77 78 79 |
# File 'lib/dcell/registries/cassandra_adapter.rb', line 77 def nodes @cass.get(@cf, "nodes").keys end |
#remove(node) ⇒ Object
81 82 83 |
# File 'lib/dcell/registries/cassandra_adapter.rb', line 81 def remove(node) @cass.remove @cf, "nodes", { node_id => node } end |
#set(node_id, addr) ⇒ Object
73 74 75 |
# File 'lib/dcell/registries/cassandra_adapter.rb', line 73 def set(node_id, addr) @cass.insert @cf, "nodes", { node_id => addr } end |