Class: Fluent::Input

Inherits:

Object

• Object
• Fluent::Input

Includes:

Configurable, PluginId, PluginLoggerMixin

Defined in:

lib/fluent/input.rb

Direct Known Subclasses

DebugAgentInput, DummyInput, ExecInput, ForwardInput, GCStatInput, HttpInput, MonitorAgentInput, NewTailInput, ObjectSpaceInput, SocketUtil::BaseInput, StatusInput, StreamInput, SyslogInput, TailInput

Constant Summary

Constants included from Configurable

Configurable::CONFIG_TYPE_REGISTRY

Instance Attribute Summary

• #router ⇒ Object

  Returns the value of attribute router.

Attributes included from PluginLoggerMixin

#log

Instance Method Summary

• #configure(conf) ⇒ Object
• #initialize ⇒ Input constructor

  A new instance of Input.

• #shutdown ⇒ Object
• #start ⇒ Object

Methods included from PluginLoggerMixin

included

Methods included from PluginId

#plugin_id

Methods included from Configurable

#config, included, lookup_type, register_type

Constructor Details

#initialize ⇒ Input

Returns a new instance of Input.

# File 'lib/fluent/input.rb', line 30

def initialize
  super
end

Instance Attribute Details

#router ⇒ Object

Returns the value of attribute router.

# File 'lib/fluent/input.rb', line 28

def router
  @router
end

Instance Method Details

#configure(conf) ⇒ Object

# File 'lib/fluent/input.rb', line 34

def configure(conf)
  super

  if label_name = conf['@label']
    label = Engine.root_agent.find_label(label_name)
    @router = label.event_router
  elsif @router.nil?
    @router = Engine.root_agent.event_router
  end
end

#shutdown ⇒ Object

# File 'lib/fluent/input.rb', line 48

def shutdown
end

#start ⇒ Object

# File 'lib/fluent/input.rb', line 45

def start
end