Sha256: fb7a535f95d34fa814f2316c1cf7796b9d0f4e879424c6f346a890d5a48b357b
Contents?: true
Size: 1.5 KB
Versions: 7
Compression:
Stored size: 1.5 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.search(command_index)
end
# @param event [Event]
# @return [Float]
def args_accel(event)
accel_index = Config::Index.new([*event.record.index.keys, :accel])
(Config.search(accel_index) || 1).to_f
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems