Sha256: 55c4d1604459e1eabaca2d16facca1398b977da2f25c097cba5ba24197f4fa90
Contents?: true
Size: 1.48 KB
Versions: 7
Compression:
Stored size: 1.48 KB
Contents
# frozen_string_literal: true
require_relative "executor"
module Fusuma
module Plugin
module Executors
# Exector plugin
class CommandExecutor < Executor
# Executor parameter on config.yml
# @return [Array<Symbol>]
def execute_keys
[:command]
end
def execute(event)
command = search_command(event)
MultiLogger.info(command: command, args: event.record.args)
accel = args_accel(event)
additional_env = event.record.args
.deep_transform_keys(&:to_s)
.deep_transform_values { |v| (v * accel).to_s }
pid = Process.spawn(additional_env, command.to_s)
Process.detach(pid)
rescue SystemCallError => e
MultiLogger.error("#{event.record.index.keys}": e.message.to_s)
end
def executable?(event)
event.tag.end_with?("_detector") &&
event.record.type == :index &&
search_command(event)
end
# @param event [Event]
# @return [String]
def search_command(event)
command_index = Config::Index.new([*event.record.index.keys, :command])
Config.instance.search(command_index)
end
# @param event [Event]
# @return [Float]
def args_accel(event)
accel_index = Config::Index.new([*event.record.index.keys, :accel])
(Config.instance.search(accel_index) || 1).to_f
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems