logstash-core/lib/logstash/pipeline.rb
# perform filters flush and yield flushed event to the passed block
# @param options [Hash]
# @option options [Boolean] :final => true to signal a final shutdown flush
perform filters flush and yield flushed event to the passed block
perform filters flush and yield flushed event to the passed block
def flush_filters(options = {}, &block)
    flushers = options[:final] ? @shutdown_flushers : @periodic_flushers
    flushers.each do |flusher|
      return if @force_shutdown.true?
      flusher.call(options, &block)
    end
  end
def flush_filters ( options = { } , & block ) flushers = options [ :final ] ? @shutdown_flushers : @periodic_flushers flushers . each do | flusher | return if @force_shutdown . true? flusher . call ( options , & block ) end end
perform filters flush and yield flushed event to the passed block
perform filters flush and yield flushed event to the passed block
options
:final => true to signal a final shutdown flush
: final = > true to signal a final shutdown flush
block
None