Class: Rearview::MonitorSupervisor

Inherits:
Celluloid::SupervisionGroup
  • Object
show all
Includes:
Logger
Defined in:
lib/rearview/monitor_supervisor.rb

Defined Under Namespace

Classes: MonitorSupervisorError

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Logger

#logger

Class Method Details

.task_sym(job) ⇒ Object 



46
47
48
 
# File 'lib/rearview/monitor_supervisor.rb', line 46

def self.task_sym(job)
  "job_#{job.id}".to_sym
end

Instance Method Details

#add_tasks(jobs) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
 
# File 'lib/rearview/monitor_supervisor.rb', line 6

def add_tasks(jobs)
  if jobs.present?
    dist_jobs = Rearview::Distribute.by_delay(jobs)
    logger.debug Rearview::Distribute.inspect(dist_jobs)
    dist_jobs.each do |dj|
      job = dj.first
      meta = dj.last
      add(Rearview::MonitorTask,as: MonitorSupervisor.task_sym(job), args: [job,meta[:initial_delay]])
    end
  end
end

#all_tasks ⇒ Object 



32
33
34
 
# File 'lib/rearview/monitor_supervisor.rb', line 32

def all_tasks
  actors
end

#remove_all_tasks ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/rearview/monitor_supervisor.rb', line 35

def remove_all_tasks
  actors.each do |a|
    begin
      unlink(a)
      a.terminate
    rescue DeadActorError, MailboxError
      warn "#{self} error while terminating #{a}: #{$!}\n#{$@}"
    end
  end
  @members = []
end

#remove_tasks(jobs) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/rearview/monitor_supervisor.rb', line 17

def remove_tasks(jobs)
  if jobs.present?
    jobs.each do |j|
      logger.debug "#{self} removing job:#{j.id}"
      member = @members.find { |m| m.actor.job == j }
      if !member.present?
        warn "#{self} remove job:#{j.id} failed because it is not present"
      else
        @members.reject! { |m| m == member }
        unlink(member.actor)
        member.actor.terminate
      end
    end
  end
end