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