class Pipely::Actions::ListLivePipelines

List currently deployed pipelines

Public Class Methods

new(options) click to toggle source
# File lib/pipely/actions/list_live_pipelines.rb, line 8
def initialize(options)
  @options = options
end

Public Instance Methods

execute() click to toggle source
# File lib/pipely/actions/list_live_pipelines.rb, line 12
def execute
  if @options.json_output
    $stdout.puts pipeline_ids.to_json
  else
    $stdout.puts pipeline_ids.map { |pipeline|
      [ pipeline.name, pipeline.id ].join("\t")
    }
  end
end

Private Instance Methods

pipeline_ids() click to toggle source
# File lib/pipely/actions/list_live_pipelines.rb, line 24
def pipeline_ids
  ids = []

  data_pipeline = Aws::DataPipeline::Client.new


  marker = nil
  begin
    result = data_pipeline.list_pipelines(
      marker: marker,
    )
    ids += result.pipeline_id_list
    marker = result.marker
  end while (result.has_more_results && marker)

  ids
end