class Bosh::Director::DeploymentPlan::InstanceRepository
Public Class Methods
new(network_reservation_repostory, logger)
click to toggle source
# File lib/bosh/director/deployment_plan/instance_repository.rb, line 3 def initialize(network_reservation_repostory, logger) @network_reservation_repository = network_reservation_repostory @logger = logger end
Public Instance Methods
create(desired_instance, index)
click to toggle source
# File lib/bosh/director/deployment_plan/instance_repository.rb, line 22 def create(desired_instance, index) @logger.debug("Creating new desired instance for: #{desired_instance.inspect}") instance = Instance.create_from_job(desired_instance.job, index, 'started', desired_instance.deployment.model, nil, desired_instance.az, @logger) instance.bind_new_instance_model instance end
fetch_existing(existing_instance_model, existing_instance_state, job, index, deployment)
click to toggle source
# File lib/bosh/director/deployment_plan/instance_repository.rb, line 8 def fetch_existing(existing_instance_model, existing_instance_state, job, index, deployment) @logger.debug("Fetching existing instance for: #{existing_instance_model.inspect}") # if state was not specified in manifest, use saved state job_state = job.state_for_instance(existing_instance_model) || existing_instance_model.state @logger.debug("Job instance states: #{job.instance_states}, found: #{job.state_for_instance(existing_instance_model)}, state: #{job_state}") instance = Instance.create_from_job(job, index, job_state, deployment.model, existing_instance_state, existing_instance_model.availability_zone, @logger) instance.bind_existing_instance_model(existing_instance_model) existing_network_reservations = @network_reservation_repository.fetch_network_reservations(existing_instance_model, existing_instance_state) instance.bind_existing_reservations(existing_network_reservations) instance end