Contents

require 'celluloid'

class Eye::ChildProcess

  include Celluloid

  # needs: kill_process
  include Eye::Process::Commands

  # easy config + defaults: prepare_config, c, []
  include Eye::Process::Config

  # conditional watchers: start_checkers
  include Eye::Process::Watchers

  # system methods: send_signal
  include Eye::Process::System

  # self_status_data
  include Eye::Process::Data

  # manage notify methods
  include Eye::Process::Notify

  # scheduler
  include Eye::Process::Scheduler

  attr_reader :pid, :name, :full_name, :config, :watchers, :parent

  def initialize(pid, config = {}, logger_prefix = nil, parent = nil)
    raise 'Empty pid' unless pid

    @pid = pid
    @parent = parent
    @config = prepare_config(config)
    @name = "child-#{pid}"
    @full_name = [logger_prefix, @name].join(':')

    @watchers = {}

    debug { "start monitoring CHILD config: #{@config.inspect}" }

    start_checkers
  end

  def logger_tag
    full_name
  end

  def state
    :up
  end

  def up?
    state == :up
  end

  def send_command(command, *args)
    schedule command, *args, Eye::Reason::User.new(command)
  end

  def start
  end

  def stop
    kill_process
  end

  def restart
    if self[:restart_command]
      execute_restart_command
    else
      stop
    end
  end

  def monitor
  end

  def unmonitor
  end

  def delete
  end

  def destroy
    remove_watchers
    terminate
  end

  def signal(sig)
    send_signal(sig) if pid
  end

  def status_data(opts = {})
    self_status_data(opts)
  end

  def prepare_command(command) # override
    super.gsub('{PARENT_PID}', @parent.pid.to_s)
  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
eye-0.8.1	lib/eye/child_process.rb
eye-0.8.celluloid15	lib/eye/child_process.rb
eye-0.8	lib/eye/child_process.rb
eye-0.8.rc	lib/eye/child_process.rb