class RubyMemcached::Client
Attributes
host[R]
port[R]
Public Class Methods
new(host, port)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 12 def initialize(host, port) @host = host @port = port @server = TCPSocket.new(host, port) end
Public Instance Methods
add(key, flags, exptime, bytes, data)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 86 def add(key, flags, exptime, bytes, data) @server.puts(Commands.add % [ key, flags, exptime, bytes, '', data ]) return Responses.to_h[Responses.key @server.gets()] end
append(key, bytes, data)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 112 def append(key, bytes, data) @server.puts(Commands.append % [ key, bytes, '', data ]) return Responses.to_h[Responses.key @server.gets()] end
cas(key, flags, exptime, bytes, cas_id, data)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 134 def cas(key, flags, exptime, bytes, cas_id, data) @server.puts(Commands.cas % [ key, flags, exptime, bytes, cas_id, '', data ]) return Responses.to_h[Responses.key @server.gets()] end
delete(key)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 148 def delete(key) @server.puts(Commands.delete % key) return Responses.to_h[Responses.key @server.gets()] end
end()
click to toggle source
# File lib/ruby-memcached/Client.rb, line 153 def end() @server.puts(Commands.end) end
get(keys)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 18 def get(keys) keys_string = keys.reduce { |ss, s| ss + ' ' + s } @server.puts(Commands.get % keys_string) items = [] loop do case @server.gets() when ResponsesRegex.get key = $~['key'] flags = $~['flags'].to_i() bytes = $~['bytes'].to_i() data = @server.read(bytes + 1).chomp() items << Memcached::Item.new(key, data, flags, 0, bytes, nil) when ResponsesRegex.end break when /.*ERROR.*/ break end end return items end
gets(keys)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 45 def gets(keys) keys_string = keys.reduce { |ss, s| ss + ' ' + s } @server.puts(Commands.gets % keys_string) items = [] loop do case @server.gets() when ResponsesRegex.gets key = $~['key'] flags = $~['flags'].to_i() bytes = $~['bytes'].to_i() cas_id = $~['cas_id'].to_i() data = @server.read(bytes + 1).chomp() items << Memcached::Item.new(key, data, flags, 0, bytes, cas_id) when ResponsesRegex.end break when /.*ERROR.*/ break end end return items end
prepend(key, bytes, data)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 123 def prepend(key, bytes, data) @server.puts(Commands._prepend % [ key, bytes, '', data ]) return Responses.to_h[Responses.key @server.gets()] end
reconnect()
click to toggle source
# File lib/ruby-memcached/Client.rb, line 157 def reconnect() @server = TCPSocket.new(@host, @port) end
replace(key, flags, exptime, bytes, data)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 99 def replace(key, flags, exptime, bytes, data) @server.puts(Commands.replace % [ key, flags, exptime, bytes, '', data ]) return Responses.to_h[Responses.key @server.gets()] end
set(key, flags, exptime, bytes, data)
click to toggle source
# File lib/ruby-memcached/Client.rb, line 73 def set(key, flags, exptime, bytes, data) @server.puts(Commands.set % [ key, flags, exptime, bytes, '', data ]) return Responses.to_h[Responses.key @server.gets()] end