class Amazonite::Kinesis::Shard

Overview

A uniquely identified group of data records in a Kinesis data stream.

Included Modules

Defined in:

kinesis/shard.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(shard_id : String, hash_key_range : HashKeyRange, sequence_number_range : SequenceNumberRange, parent_shard_id : String | Nil = nil, adjacent_parent_shard_id : String | Nil = nil) #

[View source]
def self.new(pull : JSON::PullParser) #

[View source]

Instance Method Detail

def ==(other : self) #
Description copied from class Reference

Returns true if this reference is the same as other. Invokes same?.


def adjacent_parent_shard_id : String | Nil #

The shard ID of the shard adjacent to the shard's parent.


[View source]
def adjacent_parent_shard_id=(adjacent_parent_shard_id : String | Nil) #

The shard ID of the shard adjacent to the shard's parent.


[View source]
def hash(hasher) #
Description copied from class Reference

See Object#hash(hasher)


def hash_key_range : HashKeyRange #

The range of possible hash key values for the shard, which is a set of ordered contiguous positive integers.


[View source]
def hash_key_range=(hash_key_range : HashKeyRange) #

The range of possible hash key values for the shard, which is a set of ordered contiguous positive integers.


[View source]
def parent_shard_id : String | Nil #

The shard ID of the shard's parent.


[View source]
def parent_shard_id=(parent_shard_id : String | Nil) #

The shard ID of the shard's parent.


[View source]
def sequence_number_range : SequenceNumberRange #

The range of possible sequence numbers for the shard.


[View source]
def sequence_number_range=(sequence_number_range : SequenceNumberRange) #

The range of possible sequence numbers for the shard.


[View source]
def shard_id : String #

The unique identifier of the shard within the stream.


[View source]
def shard_id=(shard_id : String) #

The unique identifier of the shard within the stream.


[View source]
def validate! : Nil #

[View source]