Sha256: a1f3f114105aa5fbd87551ae6ac0e2c0c1764965aac2e2ae1515e27c782e26fd
Contents?: true
Size: 1.13 KB
Versions: 13
Compression:
Stored size: 1.13 KB
Contents
# frozen_string_literal: true
require_relative "../base"
module Fusuma
module Plugin
module Parsers
# Parser change record and tag in event
# Inherite this base class
class Parser < Base
# Parse Event and convert Record and Tag
# if `#parse_record` return nil, this method will return original event
# @param event [Event]
# @return [Event]
def parse(event)
return event if event.tag != source
new_record = parse_record(event.record)
return event if new_record.nil?
event.record = new_record
event.tag = tag
event
end
# Set source for tag from config.yml.
# DEFAULT_SOURCE is defined in each Parser plugins.
def source
@source ||= config_params(:source) || self.class.const_get(:DEFAULT_SOURCE)
end
def tag
@tag ||= self.class.name.split("::").last.underscore
end
# parse Record object
# @param _record [Record]
# @return [Record, nil]
def parse_record(_record)
nil
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems