Sha256: 69f1b397af4fb4161b7eac27d635b0debfea53711800a1aea78b252d80ff084b

Contents?: true

Size: 702 Bytes

Versions: 6

Compression:

Stored size: 702 Bytes

Contents

# A simple job class that processes a given index.
# 
class ThinkingSphinx::Deltas::DeltaJob
  attr_accessor :indexes
  
  # Initialises the object with an index name.
  # 
  # @param [String] index the name of the Sphinx index
  # 
  def initialize(indexes)
    @indexes = indexes
  end
  
  # Runs Sphinx's indexer tool to process the index. Currently assumes Sphinx is
  # running.
  # 
  # @return [Boolean] true
  # 
  def perform
    config = ThinkingSphinx::Configuration.instance
    
    output = `#{config.bin_path}#{config.indexer_binary_name} --config #{config.config_file} --rotate #{indexes.join(' ')}`
    puts output unless ThinkingSphinx.suppress_delta_output?
    
    true
  end
end

Version data entries

6 entries across 6 versions & 3 rubygems

Version Path
ts-delayed-delta-1.0.3 lib/thinking_sphinx/deltas/delayed_delta/delta_job.rb
namxam-ts-delayed-delta-1.0.3 lib/thinking_sphinx/deltas/delayed_delta/delta_job.rb
warp-ts-delayed-delta-1.0.3 lib/thinking_sphinx/deltas/delayed_delta/delta_job.rb
warp-ts-delayed-delta-1.0.2 lib/thinking_sphinx/deltas/delayed_delta/delta_job.rb
ts-delayed-delta-1.0.2 lib/thinking_sphinx/deltas/delayed_delta/delta_job.rb
ts-delayed-delta-1.0.1 lib/thinking_sphinx/deltas/delayed_delta/delta_job.rb