class Amazonite::Kinesis::SubscribeToShardEventStream

Overview

This is a tagged union for all of the types of events an enhanced fan-out consumer can receive over HTTP/2 after a call to SubscribeToShard.

Included Modules

Defined in:

kinesis/subscribe_to_shard_event_stream.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(pull : JSON::PullParser) #

[View source]
def self.new(subscribe_to_shard_event : SubscribeToShardEvent | Nil = nil) #

[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 hash(hasher) #
Description copied from class Reference

See Object#hash(hasher)


def subscribe_to_shard_event : SubscribeToShardEvent | Nil #

After you call SubscribeToShard, Kinesis Data Streams sends events of this type to your consumer. For an example of how to handle these events, see Enhanced Fan-Out Using the Kinesis Data Streams API.


[View source]
def subscribe_to_shard_event=(subscribe_to_shard_event : SubscribeToShardEvent | Nil) #

After you call SubscribeToShard, Kinesis Data Streams sends events of this type to your consumer. For an example of how to handle these events, see Enhanced Fan-Out Using the Kinesis Data Streams API.


[View source]
def validate! : Nil #

[View source]