Class: Bosh::Director::ProblemResolver

Inherits:
Object
  • Object
show all
Defined in:
lib/bosh/director/problem_resolver.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(deployment) ⇒ ProblemResolver

Returns a new instance of ProblemResolver.



6
7
8
9
10
11
12
13
 
# File 'lib/bosh/director/problem_resolver.rb', line 6

def initialize(deployment)
  @deployment = deployment
  @resolved_count = 0

  #temp
  @event_log = Config.event_log
  @logger = Config.logger
end

Instance Attribute Details

#event_log ⇒ Object (readonly)

Returns the value of attribute event_log.



4
5
6
 
# File 'lib/bosh/director/problem_resolver.rb', line 4

def event_log
  @event_log
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



4
5
6
 
# File 'lib/bosh/director/problem_resolver.rb', line 4

def logger
  @logger
end

Instance Method Details

#apply_resolutions(resolutions) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/bosh/director/problem_resolver.rb', line 27

def apply_resolutions(resolutions)
  @resolutions = resolutions
  problems = Models::DeploymentProblem.where(id: resolutions.keys)

  begin_stage('Applying problem resolutions', problems.count)

  problems.each do |problem|
    if problem.state != 'open'
      reason = "state is '#{problem.state}'"
      track_and_log("Ignoring problem #{problem.id} (#{reason})")
    elsif problem.deployment_id != @deployment.id
      reason = 'not a part of this deployment'
      track_and_log("Ignoring problem #{problem.id} (#{reason})")

    else
      apply_resolution(problem)
    end
  end
  @resolved_count
end

#begin_stage(stage_name, n_steps) ⇒ Object 



15
16
17
18
 
# File 'lib/bosh/director/problem_resolver.rb', line 15

def begin_stage(stage_name, n_steps)
  event_log.begin_stage(stage_name, n_steps)
  logger.info(stage_name)
end

#track_and_log(task, log = true) ⇒ Object 



20
21
22
23
24
25
 
# File 'lib/bosh/director/problem_resolver.rb', line 20

def track_and_log(task, log = true)
  event_log.track(task) do |ticker|
    logger.info(task) if log
    yield ticker if block_given?
  end
end