class Amazonite::Kinesis::SubscribeToShardInput

Included Modules

Defined in:

kinesis/subscribe_to_shard_input.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(consumer_arn : String, shard_id : String, starting_position : StartingPosition, stream_id : String | Nil = nil, dry_run : Bool | Nil = nil) #

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

[View source]
def self.new(*, __pull_for_json_serializable 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 consumer_arn : String #

For this parameter, use the value you obtained when you called RegisterStreamConsumer.


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

For this parameter, use the value you obtained when you called RegisterStreamConsumer.


[View source]
def dry_run : Bool | Nil #

Checks if your request will succeed. DryRun is an optional parameter.


[View source]
def dry_run=(dry_run : Bool | Nil) #

Checks if your request will succeed. DryRun is an optional parameter.


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

See Object#hash(hasher)


def shard_id : String #

The ID of the shard you want to subscribe to. To see a list of all the shards for a given stream, use ListShards.


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

The ID of the shard you want to subscribe to. To see a list of all the shards for a given stream, use ListShards.


[View source]
def starting_position : StartingPosition #

The starting position in the data stream from which to start streaming.


[View source]
def starting_position=(starting_position : StartingPosition) #

The starting position in the data stream from which to start streaming.


[View source]
def stream_id : String | Nil #

Not Implemented. Reserved for future use.


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

Not Implemented. Reserved for future use.


[View source]
def validate! : Nil #

[View source]