module Fluent::PluginId
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin_id.rb, line 24 def initialize super @_plugin_id_variable_store = nil @_plugin_root_dir = nil @id = nil end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin_id.rb, line 32 def configure(conf) @_plugin_id_variable_store = Fluent::VariableStore.fetch_or_build(:pluing_id, default_value: Set.new) @id = conf['@id'] @_id_configured = !!@id # plugin id is explicitly configured by users (or not) if @id @id = @id.to_s if @_plugin_id_variable_store.include?(@id) && !plugin_id_for_test? raise Fluent::ConfigError, "Duplicated plugin id `#{@id}`. Check whole configuration and fix it." end @_plugin_id_variable_store.add(@id) end super end
plugin_id()
click to toggle source
# File lib/fluent/plugin_id.rb, line 65 def plugin_id if instance_variable_defined?("@id") @id || "object:#{object_id.to_s(16)}" else "object:#{object_id.to_s(16)}" end end
plugin_id_configured?()
click to toggle source
# File lib/fluent/plugin_id.rb, line 59 def plugin_id_configured? if instance_variable_defined?("@_id_configured") @_id_configured end end
plugin_id_for_test?()
click to toggle source
# File lib/fluent/plugin_id.rb, line 47 def plugin_id_for_test? caller_locations.each do |location| # Thread::Backtrace::Location#path returns base filename or absolute path. # #absolute_path returns absolute_path always. # https://bugs.ruby-lang.org/issues/12159 if /\/test_[^\/]+\.rb$/.match?(location.absolute_path) # location.path =~ /test_.+\.rb$/ return true end end false end
plugin_root_dir()
click to toggle source
# File lib/fluent/plugin_id.rb, line 73 def plugin_root_dir return @_plugin_root_dir if @_plugin_root_dir return nil unless system_config.root_dir return nil unless plugin_id_configured? # Fluent::Plugin::Base#fluentd_worker_id dir = File.join(system_config.root_dir, "worker#{fluentd_worker_id}", plugin_id) FileUtils.mkdir_p(dir, mode: system_config.dir_permission || Fluent::DEFAULT_DIR_PERMISSION) unless Dir.exist?(dir) @_plugin_root_dir = dir.freeze dir end
stop()
click to toggle source
Calls superclass method
# File lib/fluent/plugin_id.rb, line 85 def stop if @_plugin_id_variable_store @_plugin_id_variable_store.delete(@id) end super end