Class: Fusuma::Plugin::Inputs::Input Abstract
- Defined in:
- lib/fusuma/plugin/inputs/input.rb
Overview
This class is abstract.
Subclass and override #io to implement
Inherite this base
Direct Known Subclasses
Class Method Summary collapse
-
.select(inputs) ⇒ Event
Wait multiple inputs until it becomes readable and read lines with nonblock.
Instance Method Summary collapse
Methods inherited from Base
#config_index, #config_param_types, #config_params, inherited, plugins
Methods included from CustomProcess
Class Method Details
.select(inputs) ⇒ Event
Wait multiple inputs until it becomes readable and read lines with nonblock
16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/fusuma/plugin/inputs/input.rb', line 16 def self.select(inputs) ios = IO.select(inputs.map(&:io)) io = ios&.first&.first input = inputs.find { |i| i.io == io } begin line = io.readline_nonblock("\n").chomp rescue EOFError => e warn "#{input.class.name}: #{e}" warn 'Send SIGKILL to fusuma processes' inputs.reject { |i| i == input }.each do |i| warn "stop process: #{i.class.name.underscore}" Process.kill(:SIGKILL, i.pid) end exit 1 rescue StandardError => e warn "#{input.class.name}: #{e}" exit 1 end input.create_event(record: line) end |
Instance Method Details
#create_event(record: 'dummy input') ⇒ Event
51 52 53 54 55 |
# File 'lib/fusuma/plugin/inputs/input.rb', line 51 def create_event(record: 'dummy input') e = Events::Event.new(tag: tag, record: record) MultiLogger.debug(input_event: e) e end |
#io ⇒ IO
46 47 48 |
# File 'lib/fusuma/plugin/inputs/input.rb', line 46 def io raise NotImplementedError, "override #{self.class.name}##{__method__}" end |
#pid ⇒ Integer
41 42 43 |
# File 'lib/fusuma/plugin/inputs/input.rb', line 41 def pid raise NotImplementedError, "override #{self.class.name}##{__method__}" end |
#tag ⇒ Object
57 58 59 |
# File 'lib/fusuma/plugin/inputs/input.rb', line 57 def tag self.class.name.split('Inputs::').last.underscore end |