class Albacore::Tools::FluentMigrator::BatchMigrateTask

Attributes

args[R]

Public Class Methods

new(*args) click to toggle source
# File lib/albacore/tools/fluent_migrator.rb, line 149
def initialize *args
  @args = Map.options args 
  @args.apply :direction => 'migrate:up',
              :silent    => true
  raise ArgumentError, 'Passed nil file' if @args.get(:file).nil?
  raise ArgumentError, "Could not find file '#{@args.get(:file)}'" unless File.exists? @args.get(:file)
end

Public Instance Methods

execute() click to toggle source
# File lib/albacore/tools/fluent_migrator.rb, line 157
def execute
  File.open(args[:file], "r") do |file_handle|
    file_handle.each_line do |server|
      server = server.chomp
      unless server.nil? or server.empty?
        info ''
        info " ********** Starting '#{server}' ************ " 
        info ''
        ::Albacore::Tools::FluentMigrator::Cmd.new(@args.set(:conn => server)).execute
        info ''
        info " ********** Finished '#{server}' ************ " 
        info ''
      end
    end
  end
end