module AwsExtensions::Kinesis::StreamDescription
Public Instance Methods
sorted_shards()
click to toggle source
Public: Get the list of open shards sorted by hash key range, ascending
# File lib/aws_extensions/kinesis/StreamDescription.rb, line 6 def sorted_shards self.shards.select { |shard| shard.sequence_number_range.ending_sequence_number.nil? } .sort_by { |shard| shard.hash_key_range.starting_hash_key.to_i } end