Sha256: d04bdd800296ebfca48364a2be8177f4f8df1a9ffa3d78a2e690406452f4e87f

Contents?: true

Size: 400 Bytes

Versions: 14

Compression:

Stored size: 400 Bytes

Contents

# frozen_string_literal: true

module Awspec::Helper
  module Finder
    module Kinesis
      def find_kinesis_by_stream_name(name)
        kinesis_client.list_streams.stream_names.each do |stream|
          if stream == name
            return kinesis_client.describe_stream_summary({ stream_name: name }).stream_description_summary
          end
        end
        nil
      end
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version Path
awspec-1.32.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.31.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.30.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.29.3 lib/awspec/helper/finder/kinesis.rb
awspec-1.29.2 lib/awspec/helper/finder/kinesis.rb
awspec-1.29.1 lib/awspec/helper/finder/kinesis.rb
awspec-1.29.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.28.2 lib/awspec/helper/finder/kinesis.rb
awspec-1.28.1 lib/awspec/helper/finder/kinesis.rb
awspec-1.28.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.27.1 lib/awspec/helper/finder/kinesis.rb
awspec-1.27.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.26.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.25.2 lib/awspec/helper/finder/kinesis.rb