Module: CassandraObject::Consistency::ClassMethods

Defined in:
lib/cassandra_object/consistency.rb

Constant Summary collapse

THRIFT_LEVELS = 
{
  :one    => :one,
  :quorum => :quorum,
  :local_quorum => :local_quorum,
  :each_quorum => :each_quorum,
  :all    => :all
}
DEFAULT_OPTIONS = 
{
  :read_default => :quorum,
  :write_default => :quorum,
}
@@default_read_consistency = 
DEFAULT_OPTIONS[:read_default]
@@default_write_consistency = 
DEFAULT_OPTIONS[:write_default]

Instance Method Summary collapse

Instance Method Details

#set_default_consistencies(config) ⇒ Object 



26
27
28
29
30
 
# File 'lib/cassandra_object/consistency.rb', line 26

def set_default_consistencies(config)
  config = (config[:consistency] || {}).reverse_merge(DEFAULT_OPTIONS)
  @@default_read_consistency = config[:read_default].to_sym
  @@default_write_consistency = config[:write_default].to_sym
end

#thrift_read_consistency ⇒ Object 



32
33
34
35
 
# File 'lib/cassandra_object/consistency.rb', line 32

def thrift_read_consistency
  consistency = read_consistency || @@default_read_consistency
  THRIFT_LEVELS[consistency] || (raise "Invalid consistency level #{consistency}")
end

#thrift_write_consistency ⇒ Object 



37
38
39
40
 
# File 'lib/cassandra_object/consistency.rb', line 37

def thrift_write_consistency
  consistency = write_consistency || @@default_write_consistency
  THRIFT_LEVELS[consistency] || (raise "Invalid consistency level #{consistency}")
end