Class: Moneta::Adapters::Cassandra

Inherits:
Object
  • Object
show all
Includes:
Defaults, ExpiresSupport
Defined in:
lib/moneta/adapters/cassandra.rb

Overview

Cassandra backend

Instance Attribute Summary

Attributes included from ExpiresSupport

#default_expires

Instance Method Summary collapse

Methods included from Defaults

#[], #[]=, #close, #decrement, #fetch, #increment

Methods included from OptionSupport

#expires, #prefix, #raw, #with

Constructor Details

#initialize(options = {}) ⇒ Cassandra

Returns a new instance of Cassandra

Parameters:

  • options (Hash) (defaults to: {})

Options Hash (options):

  • :keyspace (String) — default: 'moneta'

    Cassandra keyspace

  • :column_family (String) — default: 'moneta'

    Cassandra column family

  • :host (String) — default: '127.0.0.1'

    Server host name

  • :port (Integer) — default: 9160

    Server port

  • :expires (Integer)

    Default expiration time


20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
# File 'lib/moneta/adapters/cassandra.rb', line 20

def initialize(options = {})
  options[:host] ||= '127.0.0.1'
  options[:port] ||=  9160
  self.default_expires = options[:expires]
  keyspace = (options[:keyspace] ||= 'moneta')
  @cf = (options[:column_family] || 'moneta').to_sym
  @client = ::Cassandra.new('system', "#{options[:host]}:#{options[:port]}")
  unless @client.keyspaces.include?(keyspace)
    cf_def = ::Cassandra::ColumnFamily.new(:keyspace => keyspace, :name => @cf.to_s)
    ks_def = ::Cassandra::Keyspace.new(:name => keyspace,
                                       :strategy_class => 'SimpleStrategy',
                                       :strategy_options => { 'replication_factor' => '1' },
                                       :replication_factor => 1,
                                       :cf_defs => [cf_def])
    # Wait for keyspace to be created (issue #24)
    10.times do
      begin
        @client.add_keyspace(ks_def)
      rescue Exception => ex
        warn "Cassandra: #{ex.message}"
      end
      break if @client.keyspaces.include?(keyspace)
      sleep 0.1
    end
  end
  @client.keyspace = keyspace
end

Instance Method Details

#clear(options = {}) ⇒ void

This method returns an undefined value.

Clear all keys in this store

Parameters:

  • options (Hash) (defaults to: {})

83
84
85
86
87
88
# File 'lib/moneta/adapters/cassandra.rb', line 83

def clear(options = {})
  @client.each_key(@cf) do |key|
    delete(key)
  end
  self
end

#delete(key, options = {}) ⇒ Object

Delete the key from the store and return the current value

Parameters:

  • key (Object)
  • options (Hash) (defaults to: {})

Options Hash (options):

  • :raw (Boolean)

    Raw access without value transformation (See `Moneta::Transformer`)

  • :prefix (String)

    Prefix key (See `Moneta::Transformer`)

  • Other (Object)

    options as defined by the adapters or middleware

Returns:

  • (Object)

    current value


75
76
77
78
79
80
# File 'lib/moneta/adapters/cassandra.rb', line 75

def delete(key, options = {})
  if value = load(key, options)
    @client.remove(@cf, key)
    value
  end
end

#key?(key, options = {}) ⇒ Boolean

Exists the value with key

Parameters:

  • key (Object)
  • options (Hash) (defaults to: {})

Options Hash (options):

  • :expires (Integer)

    Update expiration time (See `Moneta::Expires`)

  • :prefix (String)

    Prefix key (See `Moneta::Transformer`)

  • Other (Object)

    options as defined by the adapters or middleware

Returns:

  • (Boolean)

49
50
51
52
53
54
55
56
# File 'lib/moneta/adapters/cassandra.rb', line 49

def key?(key, options = {})
  if @client.exists?(@cf, key)
    load(key, options) if options.include?(:expires)
    true
  else
    false
  end
end

#load(key, options = {}) ⇒ Object

Fetch value with key. Return nil if the key doesn't exist

Parameters:

  • key (Object)
  • options (Hash) (defaults to: {})

Options Hash (options):

  • :expires (Integer)

    Update expiration time (See `Moneta::Expires`)

  • :raw (Boolean)

    Raw access without value transformation (See `Moneta::Transformer`)

  • :prefix (String)

    Prefix key (See `Moneta::Transformer`)

  • Other (Object)

    options as defined by the adapters or middleware

Returns:

  • (Object)

    value


59
60
61
62
63
64
65
66
# File 'lib/moneta/adapters/cassandra.rb', line 59

def load(key, options = {})
  value = @client.get(@cf, key)
  if value
    expires = expires_value(options, nil)
    @client.insert(@cf, key, {'value' => value['value'] }, :ttl => expires || nil) if expires != nil
    value['value']
  end
end

#store(key, value, options = {}) ⇒ Object

Store value with key

Parameters:

  • key (Object)
  • value (Object)
  • options (Hash) (defaults to: {})

Options Hash (options):

  • :expires (Integer)

    Set expiration time (See `Moneta::Expires`)

  • :raw (Boolean)

    Raw access without value transformation (See `Moneta::Transformer`)

  • :prefix (String)

    Prefix key (See `Moneta::Transformer`)

  • Other (Object)

    options as defined by the adapters or middleware

Returns:

  • value


69
70
71
72
# File 'lib/moneta/adapters/cassandra.rb', line 69

def store(key, value, options = {})
  @client.insert(@cf, key, {'value' => value}, :ttl => expires_value(options) || nil)
  value
end