class InsightsCloud::Generators::PlaybookProgressGenerator

Attributes

correlation_id[R]

Public Class Methods

new(correlation_id) click to toggle source
# File lib/insights_cloud/generators/playbook_progress_generator.rb, line 5
def initialize(correlation_id)
  @messages = []
  @correlation_id = correlation_id
end

Public Instance Methods

generate() click to toggle source
# File lib/insights_cloud/generators/playbook_progress_generator.rb, line 42
def generate
  @messages.map do |message|
    message.to_json
  end.join("\n")
end
host_finished_message(host_name, exit_code) click to toggle source
# File lib/insights_cloud/generators/playbook_progress_generator.rb, line 21
def host_finished_message(host_name, exit_code)
  @messages << {
    "type": "playbook_run_finished",
    "version": 3,
    "correlation_id": correlation_id,
    "host": host_name,
    "status": exit_code == 0 ? 'success' : 'failure',
    "connection_code": 0,
    "execution_code": exit_code,
  }
end
host_progress_message(host_name, output, sequence) click to toggle source
# File lib/insights_cloud/generators/playbook_progress_generator.rb, line 10
def host_progress_message(host_name, output, sequence)
  @messages << {
    "type": "playbook_run_update",
    "version": 3,
    "correlation_id": correlation_id,
    "sequence": sequence,
    "host": host_name,
    "console": output,
  }
end
job_finished_message(success) click to toggle source
# File lib/insights_cloud/generators/playbook_progress_generator.rb, line 33
def job_finished_message(success)
  @messages << {
    "type": "playbook_run_completed",
    "version": 3,
    "correlation_id": correlation_id,
    "status": success ? 'success' : 'failure',
  }
end