Contents

module Fluent
  require 'fluent/agent'

  class Label < Agent
    def initialize(name, opts = {})
      super(opts)

      @context = name
      @root_agent = nil
    end

    attr_accessor :root_agent

    def handle_emits_error(tag, es, e)
      @root_agent.handle_emits_error(tag, es, e)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
fluentd-0.12.0.pre.2	lib/fluent/label.rb
fluentd-0.12.0.pre.1	lib/fluent/label.rb