Class: DCell::Registry::CassandraAdapter::NodeRegistry

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

Instance Method Summary collapse

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_allObject



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

#nodesObject



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