Contents

module Oxblood
  module Command
    class << self
      def hdel(key, fields)
        serialize([:HDEL, key, fields])
      end

      def hexists(key, field)
        serialize([:HEXISTS, key, field])
      end

      def hmset(key, *args)
        serialize(args.unshift(:HMSET, key))
      end

      def hget(key, field)
        serialize([:HGET, key, field])
      end

      def hmget(key, *fields)
        serialize(fields.unshift(:HMGET, key))
      end

      def hgetall(key)
        serialize([:HGETALL, key])
      end

      # ------------------ Strings ---------------------

      # ------------------ Connection ---------------------

      def ping(message = nil)
        command = [:PING]
        command << message if message

        serialize(command)
      end

      # ------------------ Server ---------------------

      def info(section = nil)
        command = [:INFO]
        command << section if section

        serialize(command)
      end

      # ------------------ Keys ------------------------

      def del(*keys)
        serialize(keys.unshift(:DEL))
      end

      def keys(pattern)
        serialize([:KEYS, pattern])
      end

      def expire(key, seconds)
        serialize([:EXPIRE, key, seconds])
      end

      # ------------------ Sets ------------------------

      def sadd(key, *members)
        serialize(members.unshift(:SADD, key))
      end

      def sunion(*keys)
        serialize(keys.unshift(:SUNION))
      end

      # ------------------ Sorted Sets -----------------

      def zadd(key, *args)
        serialize(args.unshift(:ZADD, key))
      end

      # @todo Support optional args (WITHSCORES/LIMIT)
      def zrangebyscore(key, min, max)
        serialize([:ZRANGEBYSCORE, key, min, max])
      end

      private

      def serialize(command)
        Protocol.build_command(command)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
oxblood-0.1.0.dev1	lib/oxblood/command.rb