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