class Amazonite::Kinesis::SubscribeToShardEvent

• Amazonite::Kinesis::SubscribeToShardEvent
• Reference
• Object

Overview

After you call SubscribeToShard, Kinesis Data Streams sends events of this type over an HTTP/2 connection to your consumer.

Included Modules

• JSON::Serializable

Defined in:

kinesis/subscribe_to_shard_event.cr

Constructors

• .new(records : Array(Record), continuation_sequence_number : String, millis_behind_latest : Int64, child_shards : Array(ChildShard) | Nil = nil)
• .new(pull : JSON::PullParser)

Instance Method Summary

• #==(other : self)

  Returns true if this reference is the same as other.

• #child_shards : Array(ChildShard) | Nil

  The list of the child shards of the current shard, returned only at the end of the current shard.

• #child_shards=(child_shards : Array(ChildShard) | Nil)

  The list of the child shards of the current shard, returned only at the end of the current shard.

• #continuation_sequence_number : String

  Use this as SequenceNumber in the next call to SubscribeToShard, with StartingPosition set to AT_SEQUENCE_NUMBER or AFTER_SEQUENCE_NUMBER.

• #continuation_sequence_number=(continuation_sequence_number : String)

  Use this as SequenceNumber in the next call to SubscribeToShard, with StartingPosition set to AT_SEQUENCE_NUMBER or AFTER_SEQUENCE_NUMBER.

• #hash(hasher)

  See Object#hash(hasher)

• #millis_behind_latest : Int64

  The number of milliseconds the read records are from the tip of the stream, indicating how far behind current time the consumer is.

• #millis_behind_latest=(millis_behind_latest : Int64)

  The number of milliseconds the read records are from the tip of the stream, indicating how far behind current time the consumer is.

• #records : Array(Record)
• #records=(records : Array(Record))
• #validate! : Nil

Constructor Detail

Instance Method Detail