class Amazonite::Kinesis::Record

• Amazonite::Kinesis::Record
• Reference
• Object

Overview

The unit of data of the Kinesis data stream, which is composed of a sequence number, a partition key, and a data blob.

Included Modules

• JSON::Serializable

Defined in:

kinesis/record.cr

Constructors

• .new(sequence_number : String, data : Bytes, partition_key : String, approximate_arrival_timestamp : Time | Nil = nil, encryption_type : EncryptionType | Nil = nil)
• .new(pull : JSON::PullParser)

Instance Method Summary

• #==(other : self)

  Returns true if this reference is the same as other.

• #approximate_arrival_timestamp : Time | Nil

  The approximate time that the record was inserted into the stream.

• #approximate_arrival_timestamp=(approximate_arrival_timestamp : Time | Nil)

  The approximate time that the record was inserted into the stream.

• #data : Bytes

  The data blob.

• #data=(data : Bytes)

  The data blob.

• #encryption_type : EncryptionType | Nil

  The encryption type used on the record.

• #encryption_type=(encryption_type : EncryptionType | Nil)

  The encryption type used on the record.

• #hash(hasher)

  See Object#hash(hasher)

• #partition_key : String

  Identifies which shard in the stream the data record is assigned to.

• #partition_key=(partition_key : String)

  Identifies which shard in the stream the data record is assigned to.

• #sequence_number : String

  The unique identifier of the record within its shard.

• #sequence_number=(sequence_number : String)

  The unique identifier of the record within its shard.

• #validate! : Nil

Constructor Detail

Instance Method Detail