Contents

require 'oxblood/protocol'
require 'oxblood/commands'

module Oxblood
  # Redis pipeling class. Commands won't be send until {#sync} is called.
  # Error responses won't be raises and should be checked manually in the
  # responses array.
  # @see http://redis.io/topics/pipelining#redis-pipelining
  #
  # @example Basic workflow
  #   pipeline = Pipeline.new(connection)
  #   pipeline.echo('ping')
  #   pipeline.ping
  #   pipeline.echo('!')
  #   pipeline.sync # => ["ping", "PONG", "!"]
  class Pipeline
    include Oxblood::Commands

    attr_reader :connection

    def initialize(connection)
      @connection = connection
      @commands = Array.new
    end

    # Sends all commands at once and reads responses
    # @return [Array] of responses
    def sync
      serialized_commands = @commands.map do |c|
        Oxblood::Protocol.build_command(*c)
      end

      @connection.socket.write(serialized_commands.join)
      @connection.read_responses(@commands.size)
    ensure
      @commands.clear
    end

    private

    def run(*command)
      @commands << command
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
oxblood-0.1.0.dev10	lib/oxblood/pipeline.rb