Class: ActiveColumn::Tasks::Keyspace
- Inherits:
-
Object
- Object
- ActiveColumn::Tasks::Keyspace
- Defined in:
- lib/active_column/tasks/keyspace.rb
Instance Method Summary collapse
- #clear ⇒ Object
- #create(name, options = {}) ⇒ Object
- #drop(name) ⇒ Object
- #exists?(name) ⇒ Boolean
- #get ⇒ Object
-
#initialize ⇒ Keyspace
constructor
A new instance of Keyspace.
- #set(name) ⇒ Object
Constructor Details
#initialize ⇒ Keyspace
Returns a new instance of Keyspace.
7 8 9 10 |
# File 'lib/active_column/tasks/keyspace.rb', line 7 def initialize c = ActiveColumn.connection @cassandra = Cassandra.new('system', c.servers, c.) end |
Instance Method Details
#clear ⇒ Object
38 39 40 41 42 |
# File 'lib/active_column/tasks/keyspace.rb', line 38 def clear return puts 'Cannot clear system keyspace' if @cassandra.keyspace == 'system' @cassandra.clear_keyspace! end |
#create(name, options = {}) ⇒ Object
16 17 18 19 20 21 22 23 24 |
# File 'lib/active_column/tasks/keyspace.rb', line 16 def create(name, = {}) opts = { :name => name.to_s, :strategy_class => 'org.apache.cassandra.locator.LocalStrategy', :replication_factor => 1, :cf_defs => [] }.merge() ks = Cassandra::Keyspace.new.with_fields(opts) @cassandra.add_keyspace ks end |
#drop(name) ⇒ Object
26 27 28 |
# File 'lib/active_column/tasks/keyspace.rb', line 26 def drop(name) @cassandra.drop_keyspace name.to_s end |
#exists?(name) ⇒ Boolean
12 13 14 |
# File 'lib/active_column/tasks/keyspace.rb', line 12 def exists?(name) @cassandra.keyspaces.include? name.to_s end |
#get ⇒ Object
34 35 36 |
# File 'lib/active_column/tasks/keyspace.rb', line 34 def get @cassandra.keyspace end |
#set(name) ⇒ Object
30 31 32 |
# File 'lib/active_column/tasks/keyspace.rb', line 30 def set(name) @cassandra.keyspace = name.to_s end |