Module: CassandraObject::Consistency::ClassMethods

Defined in:
lib/cassandra_object/consistency.rb

Constant Summary collapse

THRIFT_LEVELS = 
{
  :one    => Cassandra::Consistency::ONE,
  :quorum => Cassandra::Consistency::QUORUM,
  :local_quorum => Cassandra::Consistency::LOCAL_QUORUM,
  :all    => Cassandra::Consistency::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 



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

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 



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

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

#thrift_write_consistency ⇒ Object 



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

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