Contents

class FlyingSphinx::ResqueDelta::DeltaJob < ThinkingSphinx::Deltas::ResqueDelta::DeltaJob
  @queue = :fs_delta

  # Runs Sphinx's indexer tool to process the index. Currently assumes Sphinx
  # is running.
  #
  # @param [String] index the name of the Sphinx index
  #
  def self.perform(indices)
    return if skip?(indices)

    FlyingSphinx::IndexRequest.new([indices]).perform
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
ts-resque-delta-1.2.4	lib/flying_sphinx/resque_delta/delta_job.rb
ts-resque-delta-1.2.3	lib/flying_sphinx/resque_delta/delta_job.rb
ts-resque-delta-1.2.2	lib/flying_sphinx/resque_delta/delta_job.rb