class DCell::Registry::CassandraAdapter::NodeRegistry
Public Class Methods
new(cass, cf)
click to toggle source
# File lib/dcell/registries/cassandra_adapter.rb, line 64 def initialize(cass, cf) @cass = cass @cf = cf end
Public Instance Methods
clear_all()
click to toggle source
# File lib/dcell/registries/cassandra_adapter.rb, line 85 def clear_all @cass.del @cf, "nodes" end
get(node_id)
click to toggle source
# File lib/dcell/registries/cassandra_adapter.rb, line 69 def get(node_id) @cass.get @cf, "nodes", node_id end
nodes()
click to toggle source
# File lib/dcell/registries/cassandra_adapter.rb, line 77 def nodes @cass.get(@cf, "nodes").keys end
remove(node)
click to toggle source
# File lib/dcell/registries/cassandra_adapter.rb, line 81 def remove(node) @cass.remove @cf, "nodes", { node_id => node } end
set(node_id, addr)
click to toggle source
# File lib/dcell/registries/cassandra_adapter.rb, line 73 def set(node_id, addr) @cass.insert @cf, "nodes", { node_id => addr } end