Contents

require "redis"

class Redis
  class Pipeline < Redis
    BUFFER_SIZE = 50_000
    
    def initialize(redis)
      @redis = redis
      @commands = []
    end
   
    def call_command(command)
      @commands << command
    end

    def execute
      @redis.call_command(@commands)
      @commands.clear
    end
    
  end
end

Version data entries

9 entries across 9 versions & 6 rubygems

Version	Path
adamwiggins-redis-rb-0.1.1	lib/pipeline.rb
defunkt-redis-0.2.1	lib/pipeline.rb
defunkt-redis-0.2.2	lib/pipeline.rb
defunkt-redis-0.2.3	lib/pipeline.rb
defunkt-redis-0.2	lib/pipeline.rb
ezmobius-redis-0.1	lib/pipeline.rb
ezmobius-redis-rb-0.1	lib/pipeline.rb
sliceofpi-redis-rb-0.1.1	lib/pipeline.rb
gandalf-0.0.3	lib/redis_ext/pipeline.rb