Contents

module Internals

  module Query

    # Combinations are a number of Combination-s.
    #
    # They are the core of an allocation.
    # An allocation consists of a number of combinations.
    #
    module Combinations # :nodoc:all
    
      # Redis Combinations contain specific methods for
      # calculating score and ids in memory.
      #
      class Redis < Base
      
        # TODO Err… yeah. Wrap in Picky specific wrapper.
        #
        def initialize combinations
          super combinations
        
          @@redis ||= ::Redis.new :db => 15
        end
      
        # Returns the result ids for the allocation.
        #
        def ids amount, offset
          return [] if @combinations.empty?
        
          identifiers = @combinations.inject([]) do |identifiers, combination|
            identifiers << "#{combination.identifier}"
          end
        
          result_id = generate_intermediate_result_id
          
          # Intersect and store.
          #
          @@redis.zinterstore result_id, identifiers
        
          # Get the stored result.
          #
          results = @@redis.zrange result_id, offset, (offset + amount)
          
          # Delete the stored result as it was only for temporary purposes.
          #
          @@redis.del result_id
          
          results
        end
      
        # Generate a multiple host/process safe result id.
        #
        require 'socket'
        @@host = Socket.gethostname
        define_method :host do
          @@host
        end
        # Use the host and pid (generated lazily in child processes) for the result.
        #
        def generate_intermediate_result_id
          :"#{host}:#{@pid ||= Process.pid}:picky:result"
        end
      
      end
    
    end
  
  end
  
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
picky-2.0.0.pre2	lib/picky/internals/query/combinations/redis.rb
picky-2.0.0.pre1	lib/picky/internals/query/combinations/redis.rb
picky-1.5.4	lib/picky/internals/query/combinations/redis.rb
picky-1.5.3	lib/picky/internals/query/combinations/redis.rb