Sha256: 01fcf8a53ac654aa57e6e301e98a46069b47964c21b6e3d8546ff0245574eef5

Contents?: true

Size: 623 Bytes

Versions: 19

Compression:

Stored size: 623 Bytes

Contents

# frozen_string_literal: true

require_relative '../base.rb'
require_relative '../events/event.rb'

module Fusuma
  module Plugin
    # input class
    module Inputs
      # Inherite this base
      class Input < Base
        def run
          raise NotImplementedError, "override #{self.class.name}##{__method__}"
        end

        def event(record: 'dummy input')
          Events::Event.new(tag: tag, record: record).tap do |e|
            MultiLogger.debug(input_event: e)
          end
        end

        def tag
          self.class.name.split('Inputs::').last.underscore
        end
      end
    end
  end
end

Version data entries

19 entries across 19 versions & 1 rubygems

Version Path
fusuma-1.11.1 lib/fusuma/plugin/inputs/input.rb
fusuma-1.10.2 lib/fusuma/plugin/inputs/input.rb
fusuma-1.10.1 lib/fusuma/plugin/inputs/input.rb
fusuma-1.10.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.9.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.8.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.7.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.6.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.5.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.4.1 lib/fusuma/plugin/inputs/input.rb
fusuma-1.4.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.3.3 lib/fusuma/plugin/inputs/input.rb
fusuma-1.3.2 lib/fusuma/plugin/inputs/input.rb
fusuma-1.3.1 lib/fusuma/plugin/inputs/input.rb
fusuma-1.3.0 lib/fusuma/plugin/inputs/input.rb
fusuma-1.2.1 lib/fusuma/plugin/inputs/input.rb
fusuma-1.2 lib/fusuma/plugin/inputs/input.rb
fusuma-1.1 lib/fusuma/plugin/inputs/input.rb
fusuma-1.0 lib/fusuma/plugin/inputs/input.rb