class Fusuma::Plugin::Filters::Filter

Filter to keep/discard events from input plugin

def filter(event)

Returns:
  • (NilClass) - when discarding record
  • (Event) - when keeping event

Parameters:
  • event (Event) -- 
def filter(event)
  return event if event.tag !~ /#{source}/
  return event if keep?(event.record)
  nil
end

def keep?(record)

Returns:
  • (False) - when discarding record
  • (True) - when keeping record

Parameters:
  • record (String) --

Other tags:
    Abstract: - override `#keep?` to implement 
def keep?(record)
  true if record
end

def source

DEFAULT_SOURCE is defined in each Filter plugins.
Set source for tag from config.yml. 
def source
  @source ||= config_params(:source) || self.class.const_get('DEFAULT_SOURCE')
end