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.



24
25
26
 
# File 'app/models/fluentd/agent/common.rb', line 24

def extra_options
  @extra_options
end

Class Method Details

.included(base) ⇒ Object 



26
27
28
 
# File 'app/models/fluentd/agent/common.rb', line 26

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

Instance Method Details

#backup_files ⇒ Object 



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

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

#backup_files_in_new_order ⇒ Object 



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

def backup_files_in_new_order
  backup_files_in_old_order.reverse
end

#backup_files_in_old_order ⇒ Object 



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

def backup_files_in_old_order
  backup_files.sort
end

#config ⇒ Object

– config



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

def config
  File.read(config_file)
end

#config_append(content) ⇒ Object 



69
70
71
72
73
74
75
 
# File 'app/models/fluentd/agent/common.rb', line 69

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



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

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

#config_file ⇒ Object 



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

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

#config_write(content) ⇒ Object 



62
63
64
65
66
67
 
# File 'app/models/fluentd/agent/common.rb', line 62

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

#configuration ⇒ Object 



77
78
79
80
81
 
# File 'app/models/fluentd/agent/common.rb', line 77

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

#initialize(options = {}) ⇒ Object 



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

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

#log ⇒ Object 



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

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

#log_file ⇒ Object 



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

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

#pid_file ⇒ Object 



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

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

#running_config_backup_dir ⇒ Object 



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

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 



108
109
110
 
# File 'app/models/fluentd/agent/common.rb', line 108

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