Class: Java::ComHazelcastClient::MapClientProxy

Inherits:
Object
  • Object
show all
Defined in:
lib/hazelcast-client/map.rb

Instance Method Summary collapse

Instance Method Details

#[](key) ⇒ Object 



57
58
59
 
# File 'lib/hazelcast-client/map.rb', line 57

def [](key)
  get key.to_s
end

#[]=(key, value) ⇒ Object 



61
62
63
 
# File 'lib/hazelcast-client/map.rb', line 61

def []=(key, value)
  put key.to_s, value
end

#keys(predicate = nil) ⇒ Object 



65
66
67
68
 
# File 'lib/hazelcast-client/map.rb', line 65

def keys(predicate = nil)
  predicate = prepare_predicate(predicate) unless predicate.is_a?(SqlPredicate)
  key_set(predicate).map
end

#on_entry_added(key = nil, include_value = true, &blk) ⇒ Object 



101
102
103
104
105
106
107
108
109
110
 
# File 'lib/hazelcast-client/map.rb', line 101

def on_entry_added(key = nil, include_value = true, &blk)
  klass = Class.new
  klass.send :include, EntryListener
  klass.send :define_method, :entryAdded, &blk
  klass.send :define_method, :method_missing do |name, *params|
    puts "method_missing : (#{name.class.name}) #{name} : #{params.inspect}"
    true
  end
  key ? add_entry_listener(klass.new, key, include_value) : add_entry_listener(klass.new, include_value)
end

#on_entry_evicted(key = nil, include_value = true, &blk) ⇒ Object 



134
135
136
137
138
139
140
141
142
143
 
# File 'lib/hazelcast-client/map.rb', line 134

def on_entry_evicted(key = nil, include_value = true, &blk)
  klass = Class.new
  klass.send :include, EntryListener
  klass.send :define_method, :entryEvicted, &blk
  klass.send :define_method, :method_missing do |name, *params|
    puts "method_missing : (#{name.class.name}) #{name} : #{params.inspect}"
    true
  end
  key ? add_entry_listener(klass.new, key, include_value) : add_entry_listener(klass.new, include_value)
end

#on_entry_removed(key = nil, include_value = true, &blk) ⇒ Object 



112
113
114
115
116
117
118
119
120
121
 
# File 'lib/hazelcast-client/map.rb', line 112

def on_entry_removed(key = nil, include_value = true, &blk)
  klass = Class.new
  klass.send :include, EntryListener
  klass.send :define_method, :entryRemoved, &blk
  klass.send :define_method, :method_missing do |name, *params|
    puts "method_missing : (#{name.class.name}) #{name} : #{params.inspect}"
    true
  end
  key ? add_entry_listener(klass.new(), key, include_value) : add_entry_listener(klass.new, include_value)
end

#on_entry_updated(key = nil, include_value = true, &blk) ⇒ Object 



123
124
125
126
127
128
129
130
131
132
 
# File 'lib/hazelcast-client/map.rb', line 123

def on_entry_updated(key = nil, include_value = true, &blk)
  klass = Class.new
  klass.send :include, EntryListener
  klass.send :define_method, :entryUpdated, &blk
  klass.send :define_method, :method_missing do |name, *params|
    puts "method_missing : (#{name.class.name}) #{name} : #{params.inspect}"
    true
  end
  key ? add_entry_listener(klass.new, key, include_value) : add_entry_listener(klass.new, include_value)
end

#prepare_predicate(predicate) ⇒ Object 



79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/hazelcast-client/map.rb', line 79

def prepare_predicate(predicate)
  return if predicate.nil?
  case predicate
    when String
      SqlPredicate.new predicate
    when Hash
      query = predicate.map do |field, value|
        cmp = '='
        if value.is_a?(String)
          value = "'" + value + "'"
          cmp = 'LIKE' if value.index('%')
        end
        "#{field} #{cmp} #{value}"
      end.join(' AND ')
      SqlPredicate.new query
    else
      raise 'Unknown predicate type'
  end
end

#unlearned_values ⇒ Object 



70
 
# File 'lib/hazelcast-client/map.rb', line 70

alias_method :unlearned_values, :values

#values(predicate = nil) ⇒ Object Also known as: find 



72
73
74
75
 
# File 'lib/hazelcast-client/map.rb', line 72

def values(predicate = nil)
  predicate = prepare_predicate(predicate) unless predicate.is_a?(SqlPredicate)
  unlearned_values(predicate).map
end