class Fluent::Supervisor::LoggerInitializer

Public Class Methods

new(path, level, chuser, chgroup, opts, log_rotate_age: nil, log_rotate_size: nil) click to toggle source
# File lib/fluent/supervisor.rb, line 477
def initialize(path, level, chuser, chgroup, opts, log_rotate_age: nil, log_rotate_size: nil)
  @path = path
  @level = level
  @chuser = chuser
  @chgroup = chgroup
  @opts = opts
  @log_rotate_age = log_rotate_age
  @log_rotate_size = log_rotate_size
end

Public Instance Methods

apply_options(format: nil, time_format: nil, log_dir_perm: nil, ignore_repeated_log_interval: nil, ignore_same_log_interval: nil) click to toggle source
# File lib/fluent/supervisor.rb, line 540
def apply_options(format: nil, time_format: nil, log_dir_perm: nil, ignore_repeated_log_interval: nil, ignore_same_log_interval: nil)
  $log.format = format if format
  $log.time_format = time_format if time_format
  $log.ignore_repeated_log_interval = ignore_repeated_log_interval if ignore_repeated_log_interval
  $log.ignore_same_log_interval = ignore_same_log_interval if ignore_same_log_interval

  if @path && log_dir_perm
    File.chmod(log_dir_perm || Fluent::DEFAULT_DIR_PERMISSION, File.dirname(@path))
  end
end
init(process_type, worker_id) click to toggle source
# File lib/fluent/supervisor.rb, line 493
def init(process_type, worker_id)
  @opts[:process_type] = process_type
  @opts[:worker_id] = worker_id

  if @path && @path != "-"
    unless File.exist?(@path)
      FileUtils.mkdir_p(File.dirname(@path))
    end

    @logdev = if @log_rotate_age || @log_rotate_size
               Fluent::LogDeviceIO.new(Fluent.windows? ?
                                         worker_id_suffixed_path(worker_id, @path) : @path,
                                       shift_age: @log_rotate_age, shift_size: @log_rotate_size)
             else
               File.open(@path, "a")
             end
    if @chuser || @chgroup
      chuid = @chuser ? ServerEngine::Privilege.get_etc_passwd(@chuser).uid : nil
      chgid = @chgroup ? ServerEngine::Privilege.get_etc_group(@chgroup).gid : nil
      File.chown(chuid, chgid, @path)
    end
  else
    @logdev = STDOUT
  end

  dl_opts = {}
  # subtract 1 to match serverengine daemon logger side logging severity.
  dl_opts[:log_level] = @level - 1
  dl_opts[:log_rotate_age] = @log_rotate_age if @log_rotate_age
  dl_opts[:log_rotate_size] = @log_rotate_size if @log_rotate_size
  logger = ServerEngine::DaemonLogger.new(@logdev, dl_opts)
  $log = Fluent::Log.new(logger, @opts)
  $log.enable_color(false) if @path
  $log.enable_debug if @level <= Fluent::Log::LEVEL_DEBUG
end
level=(level) click to toggle source
# File lib/fluent/supervisor.rb, line 551
def level=(level)
  @level = level
  $log.level = level
end
reopen!() click to toggle source
# File lib/fluent/supervisor.rb, line 533
def reopen!
  if @path && @path != "-"
    @logdev.reopen(@path, "a")
  end
  self
end
stdout?() click to toggle source
# File lib/fluent/supervisor.rb, line 529
def stdout?
  @logdev == STDOUT
end
worker_id_suffixed_path(worker_id, path) click to toggle source
# File lib/fluent/supervisor.rb, line 487
def worker_id_suffixed_path(worker_id, path)
  require 'pathname'

  Pathname(path).sub_ext("-#{worker_id}#{Pathname(path).extname}").to_s
end