event_loop helper managers event loops.

Here is the code example with event_loop helper:

require 'fluent/plugin/input'
​
module Fluent::Plugin
  class ExampleInput < Input
    Fluent::Plugin.register_input('example', self)
​
    # 1. load event_loop_helper
    helpers :event_loop
​
    # omit configure, shutdown and other plugin API
​
    def start
      super
​
      # 2. attach watcher
      watcher = Coolio::TCPServer.new(...)
      event_loop_attach(watcher)
    end
  end
end

Attached watcher is managed by the plugin. No need watcher detach code in plugin's shutdown. The plugin shutdowns attached watchers automatically.

Methods

event_loop_attach(watcher)

This method attaches watcher to event loop

• watcher: Coolio::Watcher instances

event_loop used plugins

• ​HTTP input​

• ​Tail input​

If this article is incorrect or outdated, or omits critical information, please let us know. Fluentd is a open source project under Cloud Native Computing Foundation (CNCF). All components are available under the Apache 2 License.