Module: Eye::Process::Config

Included in:
ChildProcess, Eye::Process
Defined in:
lib/eye/process/config.rb

Constant Summary collapse

DEFAULTS = 
{
  keep_alive: true, # restart when crashed
  check_alive_period: 5.seconds,

  check_identity: true,
  check_identity_period: 60.seconds,
  check_identity_grace: 60.seconds,

  start_timeout: 15.seconds,
  stop_timeout: 10.seconds,
  restart_timeout: 10.seconds,

  start_grace: 2.5.seconds,
  stop_grace: 0.5.seconds,
  restart_grace: 1.second,

  daemonize: false,
  auto_start: true, # auto start on monitor action

  children_update_period: 30.seconds,
  clear_pid: true, # by default clear pid on stop

  auto_update_pidfile_grace: 30.seconds,
  revert_fuckup_pidfile_grace: 120.seconds
}.freeze

Instance Method Summary collapse

Instance Method Details

#[](name) ⇒ Object 



58
59
60
 
# File 'lib/eye/process/config.rb', line 58

def [](name)
  @config[name]
end

#c(name) ⇒ Object 



54
55
56
 
# File 'lib/eye/process/config.rb', line 54

def c(name)
  @config[name]
end

#control_pid? ⇒ Boolean

is pid_file under Eye::Process control, or not

Returns:

  • (Boolean) 


84
85
86
 
# File 'lib/eye/process/config.rb', line 84

def control_pid?
  !!self[:daemonize]
end

#prepare_config(new_config) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/eye/process/config.rb', line 29

def prepare_config(new_config)
  h = DEFAULTS.merge(new_config)
  h[:pid_file_ex] = Eye::System.normalized_file(h[:pid_file], h[:working_dir]) if h[:pid_file]
  h[:checks] = {} if h[:checks].blank?
  h[:triggers] = {} if h[:triggers].blank?
  if upd = h.try(:[], :monitor_children).try(:[], :children_update_period)
    h[:children_update_period] = upd
  end

  # check speedy flapping by default
  if h[:triggers].blank? || !h[:triggers][:flapping]
    h[:triggers] ||= {}
    h[:triggers][:flapping] = { type: :flapping, times: 10, within: 10.seconds }
  end

  h[:stdout] = Eye::System.normalized_file(h[:stdout], h[:working_dir]) if h[:stdout]
  h[:stderr] = Eye::System.normalized_file(h[:stderr], h[:working_dir]) if h[:stderr]
  h[:stdall] = Eye::System.normalized_file(h[:stdall], h[:working_dir]) if h[:stdall]

  h[:environment] = Eye::System.prepare_env(h)
  h[:stop_signals] = [:TERM, 0.5, :KILL] unless h[:stop_command] || h[:stop_signals]

  h
end

#skip_group_action?(action) ⇒ Boolean

Returns:

  • (Boolean) 


88
89
90
91
92
93
94
95
96
97
 
# File 'lib/eye/process/config.rb', line 88

def skip_group_action?(action)
  if sga = self[:skip_group_actions]
    res = sga[action]
    if res == true
      res
    elsif res.is_a?(Array)
      res.include?(self.state_name)
    end
  end
end

#update_config(new_config = {}) ⇒ Object 



62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/eye/process/config.rb', line 62

def update_config(new_config = {})
  new_config = prepare_config(new_config)
  @config = new_config
  @full_name = nil
  @logger = nil

  debug { "updating config to: #{@config.inspect}" }

  remove_triggers
  add_triggers

  if up?
    # rebuild checks for this process
    remove_watchers
    remove_children

    add_watchers
    add_children
  end
end