module Fluent::ParseMap::Mixin

Constants

MMAP_MAX_NUM

Public Instance Methods

check_mmap_range(conf) click to toggle source
# File lib/fluent/plugin/parse_map_mixin.rb, line 48
def check_mmap_range(conf)
  invalid_mmap = conf.keys.select { |k|
    m = k.match(/^mmap(\d+)$/)
    m ? !((1..MMAP_MAX_NUM).include?(m[1].to_i)) : false
  }
  unless invalid_mmap.empty?
    raise Fluent::ConfigError, "Invalid mmapN found. N should be 1 - #{MMAP_MAX_NUM}: " + invalid_mmap.join(",")
  end
end
parse_map() click to toggle source
# File lib/fluent/plugin/parse_map_mixin.rb, line 23
def parse_map()
  if @multi
    @map
  else
    "[#{@map}]"
  end
end
parse_multimap(conf) click to toggle source
# File lib/fluent/plugin/parse_map_mixin.rb, line 31
def parse_multimap(conf)
  check_mmap_range(conf)

  prev_mmap = nil
  result_mmaps = (1..MMAP_MAX_NUM).map { |i|
    mmap = conf["mmap#{i}"]
    if (i > 1) && prev_mmap.nil? && !mmap.nil?
      raise Fluent::ConfigError, "Jump of mmap index found. mmap#{i - 1} is missing."
    end
    prev_mmap = mmap
    next if mmap.nil?

    mmap
  }.compact.join(',')
  "[#{result_mmaps}]"
end