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