Module: Fluentd::Agent::Common

Included in:
FluentdGem, TdAgent
Defined in:
app/models/fluentd/agent/common.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#extra_options ⇒ Object (readonly)

Returns the value of attribute extra_options.



20
21
22
 
# File 'app/models/fluentd/agent/common.rb', line 20

def extra_options
  @extra_options
end

Class Method Details

.included(base) ⇒ Object 



22
23
24
 
# File 'app/models/fluentd/agent/common.rb', line 22

def self.included(base)
  base.send(:include, Fluentd::Agent::ProcessOperation)
end

Instance Method Details

#backup_files ⇒ Object 



86
87
88
 
# File 'app/models/fluentd/agent/common.rb', line 86

def backup_files
  Dir.glob(File.join("#{config_backup_dir}", "*.conf"))
end

#backup_files_in_new_order ⇒ Object 



94
95
96
 
# File 'app/models/fluentd/agent/common.rb', line 94

def backup_files_in_new_order
  backup_files_in_old_order.reverse
end

#backup_files_in_old_order ⇒ Object 



90
91
92
 
# File 'app/models/fluentd/agent/common.rb', line 90

def backup_files_in_old_order
  backup_files.sort
end

#config ⇒ Object

– config



54
55
56
 
# File 'app/models/fluentd/agent/common.rb', line 54

def config
  File.read(config_file)
end

#config_append(content) ⇒ Object 



65
66
67
68
69
70
71
 
# File 'app/models/fluentd/agent/common.rb', line 65

def config_append(content)
  backup_config
  File.open(config_file, "a") do |f|
    f.write "\n"
    f.write content
  end
end

#config_backup_dir ⇒ Object

– backup methods



80
81
82
83
84
 
# File 'app/models/fluentd/agent/common.rb', line 80

def config_backup_dir
  dir = File.join(FluentdUI.data_dir, "#{Rails.env}_confg_backups")
  FileUtils.mkdir_p(dir)
  dir
end

#config_file ⇒ Object 



49
50
51
 
# File 'app/models/fluentd/agent/common.rb', line 49

def config_file
  extra_options[:config_file] || self.class.default_options[:config_file]
end

#config_write(content) ⇒ Object 



58
59
60
61
62
63
 
# File 'app/models/fluentd/agent/common.rb', line 58

def config_write(content)
  backup_config
  File.open(config_file, "w") do |f|
    f.write content
  end
end

#configuration ⇒ Object 



73
74
75
76
77
 
# File 'app/models/fluentd/agent/common.rb', line 73

def configuration
  if File.exists? config_file
    ::Fluentd::Agent::Configuration.new(config_file)
  end
end

#initialize(options = {}) ⇒ Object 



33
34
35
 
# File 'app/models/fluentd/agent/common.rb', line 33

def initialize(options = {})
  @extra_options = options
end

#log ⇒ Object 



45
46
47
 
# File 'app/models/fluentd/agent/common.rb', line 45

def log
  @log ||= FluentdLog.new(log_file)
end

#log_file ⇒ Object 



41
42
43
 
# File 'app/models/fluentd/agent/common.rb', line 41

def log_file
  extra_options[:log_file] || self.class.default_options[:log_file]
end

#pid_file ⇒ Object 



37
38
39
 
# File 'app/models/fluentd/agent/common.rb', line 37

def pid_file
  extra_options[:pid_file] || self.class.default_options[:pid_file]
end

#running_config_backup_dir ⇒ Object 



98
99
100
101
102
 
# File 'app/models/fluentd/agent/common.rb', line 98

def running_config_backup_dir
  dir = File.join(FluentdUI.data_dir, "#{Rails.env}_running_confg_backup")
  FileUtils.mkdir_p(dir)
  dir
end

#running_config_backup_file ⇒ Object 



104
105
106
 
# File 'app/models/fluentd/agent/common.rb', line 104

def running_config_backup_file
  File.join(running_config_backup_dir, "running.conf")
end