Module: AwsExtensions::Kinesis::StreamDescription

Defined in:

lib/aws_extensions/kinesis/StreamDescription.rb

Instance Method Summary

• #sorted_shards ⇒ Object

  Public: Get the list of open shards sorted by hash key range, ascending.

Instance Method Details

#sorted_shards ⇒ Object

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