Sha256: 9e3d9671ce5a32c2eda492bdb882f6e4a39824ce0005c026ec140b7b5af09901

Contents?: true

Size: 829 Bytes

Versions: 11

Compression:

Stored size: 829 Bytes

Contents

# frozen_string_literal: true

require 'phobos'
require 'phobos/cli'

namespace :deimos do
  desc 'Starts Deimos in the rails environment'
  task start: :environment do
    Deimos.configure do |config|
      config.publish_backend = :kafka_sync if config.publish_backend == :kafka_async
    end
    ENV['DEIMOS_RAKE_TASK'] = 'true'
    STDOUT.sync = true
    Rails.logger.info('Running deimos:start rake task.')
    Phobos::CLI::Commands.start(%w(start --skip_config))
  end

  desc 'Starts the Deimos database producer'
  task db_producer: :environment do
    ENV['DEIMOS_RAKE_TASK'] = 'true'
    STDOUT.sync = true
    Rails.logger.info('Running deimos:db_producer rake task.')
    thread_count = ENV['THREAD_COUNT'].to_i.zero? ? 1 : ENV['THREAD_COUNT'].to_i
    Deimos.start_db_backend!(thread_count: thread_count)
  end

end

Version data entries

11 entries across 11 versions & 1 rubygems

Version Path
deimos-ruby-1.3.0.pre.beta3 lib/tasks/deimos.rake
deimos-ruby-1.3.0.pre.beta2 lib/tasks/deimos.rake
deimos-ruby-1.3.0.pre.beta1 lib/tasks/deimos.rake
deimos-ruby-1.2.0.pre.beta1 lib/tasks/deimos.rake
deimos-ruby-1.1.0.pre.beta2 lib/tasks/deimos.rake
deimos-ruby-1.1.0.pre.beta1 lib/tasks/deimos.rake
deimos-ruby-1.0.0 lib/tasks/deimos.rake
deimos-ruby-1.0.0.pre.beta26 lib/tasks/deimos.rake
deimos-ruby-1.0.0.pre.beta25 lib/tasks/deimos.rake
deimos-ruby-1.0.0.pre.beta24 lib/tasks/deimos.rake
deimos-ruby-1.0.0.pre.beta23 lib/tasks/deimos.rake