Sha256: b7946b04ba1a1c2c6b527de40bef82511bd7c99cbf457e37f1e22d7f1c3f385e

Contents?: true

Size: 369 Bytes

Versions: 57

Compression:

Stored size: 369 Bytes

Contents

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

57 entries across 57 versions & 3 rubygems

Version Path
awspec-1.15.1 lib/awspec/helper/finder/kinesis.rb
awspec-1.15.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.14.1 lib/awspec/helper/finder/kinesis.rb
awspec-1.14.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.13.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.7 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.6 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.5 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.4 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.3 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.2 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.1 lib/awspec/helper/finder/kinesis.rb
awspec-1.12.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.11.1 lib/awspec/helper/finder/kinesis.rb
awspec-1.11.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.10.0 lib/awspec/helper/finder/kinesis.rb
awspec-1.9.0 lib/awspec/helper/finder/kinesis.rb