Sha256: 814dabecd14885de1f1d90f27c8cc60962ba2b94d981cbe5530a5fac0f474937
Contents?: true
Size: 1 KB
Versions: 8
Compression:
Stored size: 1 KB
Contents
# frozen_string_literal: true
require_relative "../base"
module Fusuma
module Plugin
module Buffers
# buffer events and output
class Buffer < Base
def initialize(*args)
super()
@events = Array.new(*args)
end
attr_reader :events
# @return [String]
def type
@type ||= self.class.name.underscore.split("/").last.gsub("_buffer", "")
end
# @param event [Event]
def buffer(event)
return if event&.tag != source
@events.push(event)
end
# clear old events
# @param current_time [Time]
def clear_expired(current_time: Time.now)
end
# clear buffer
def clear
@events.clear
end
# Set source for tag from config.yml.
# DEFAULT_SOURCE is defined in each plugins.
def source
@source ||= config_params(:source) || self.class.const_get(:DEFAULT_SOURCE)
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems