Class: Fluent::Supervisor::LoggerInitializer

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/supervisor.rb

Instance Method Summary collapse

Constructor Details

#initialize(path, level, chuser, chgroup, opts, log_rotate_age: nil, log_rotate_size: nil) ⇒ LoggerInitializer

Returns a new instance of LoggerInitializer.



318
319
320
321
322
323
324
325
326
 
# File 'lib/fluent/supervisor.rb', line 318

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

Instance Method Details

#apply_options(opts) ⇒ Object 



367
368
369
370
 
# File 'lib/fluent/supervisor.rb', line 367

def apply_options(opts)
  $log.format = opts[:format] if opts[:format]
  $log.time_format = opts[:time_format] if opts[:time_format]
end

#init(process_type, worker_id) ⇒ Object 



328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
 
# File 'lib/fluent/supervisor.rb', line 328

def init(process_type, worker_id)
  @opts[:process_type] = process_type
  @opts[:worker_id] = worker_id

  if @path && @path != "-"
    @logdev = if @log_rotate_age || @log_rotate_size
               Fluent::LogDeviceIO.new(@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
  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) ⇒ Object 



372
373
374
375
 
# File 'lib/fluent/supervisor.rb', line 372

def level=(level)
  @level = level
  $log.level = level
end

#reopen! ⇒ Object 



360
361
362
363
364
365
 
# File 'lib/fluent/supervisor.rb', line 360

def reopen!
  if @path && @path != "-"
    @logdev.reopen(@path, "a")
  end
  self
end

#stdout? ⇒ Boolean

Returns:

  • (Boolean) 


356
357
358
 
# File 'lib/fluent/supervisor.rb', line 356

def stdout?
  @logdev == STDOUT
end