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