class Fluent::Registry

Attributes

kind[R]

Public Class Methods

new(kind, search_prefix) click to toggle source
# File lib/fluent/registry.rb, line 21
def initialize(kind, search_prefix)
  @kind = kind
  @search_prefix = search_prefix
  @map = {}
end

Public Instance Methods

lookup(type) click to toggle source
# File lib/fluent/registry.rb, line 34
def lookup(type)
  type = type.to_sym
  if value = @map[type]
    return value
  end
  search(type)
  if value = @map[type]
    return value
  end
  raise ConfigError, "Unknown #{@kind} plugin '#{type}'. Run 'gem search -rd fluentd-plugin' to find plugins"  # TODO error class
end
register(type, value) click to toggle source
# File lib/fluent/registry.rb, line 29
def register(type, value)
  type = type.to_sym
  @map[type] = value
end