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