Contents

require 'thinking_sphinx/deltas/resque_delta'

class FlyingSphinx::ResqueDelta < ThinkingSphinx::Deltas::ResqueDelta
  def self.job_types
    [
      FlyingSphinx::ResqueDelta::DeltaJob,
      FlyingSphinx::ResqueDelta::FlagAsDeletedJob
    ]
  end
  
  def self.job_prefix
    'fs-delta'
  end
  
  def index(model, instance = nil)
    return true if skip?(instance)
    
    model.delta_index_names.each do |delta|
      next if self.class.locked?(delta)
      
      Resque.enqueue(
        FlyingSphinx::ResqueDelta::DeltaJob,
        [delta]
      )
    end
    
    Resque.enqueue(
      FlyingSphinx::ResqueDelta::FlagAsDeletedJob,
      model.core_index_names,
      instance.sphinx_document_id
    ) if instance
    
    true
  end
end

require 'flying_sphinx/resque_delta/delta_job'
require 'flying_sphinx/resque_delta/flag_as_deleted_job'

Version data entries

13 entries across 13 versions & 2 rubygems

Version	Path
ts-resque-delta-1.2.1	lib/flying_sphinx/resque_delta.rb
ts-resque-delta-1.2.0	lib/flying_sphinx/resque_delta.rb
ryansch-ts-resque-delta-1.1.5.4	lib/flying_sphinx/resque_delta.rb
ryansch-ts-resque-delta-1.1.5.4.dev	lib/flying_sphinx/resque_delta.rb
ryansch-ts-resque-delta-1.1.5.3	lib/flying_sphinx/resque_delta.rb
ryansch-ts-resque-delta-1.1.5.2	lib/flying_sphinx/resque_delta.rb
ryansch-ts-resque-delta-1.1.5.1	lib/flying_sphinx/resque_delta.rb
ts-resque-delta-1.1.5	lib/flying_sphinx/resque_delta.rb
ts-resque-delta-1.1.4	lib/flying_sphinx/resque_delta.rb
ts-resque-delta-1.1.3	lib/flying_sphinx/resque_delta.rb
ts-resque-delta-1.1.2	lib/flying_sphinx/resque_delta.rb
ts-resque-delta-1.1.1	lib/flying_sphinx/resque_delta.rb
ts-resque-delta-1.1.0	lib/flying_sphinx/resque_delta.rb