class Amazonite::Kinesis::ConsumerDescription

Overview

An object that represents the details of a registered consumer. This type of object is returned by DescribeStreamConsumer.

Included Modules

Defined in:

kinesis/consumer_description.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(consumer_name : String, consumer_arn : String, consumer_status : ConsumerStatus, consumer_creation_timestamp : Time, stream_arn : String) #

[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 consumer_arn : String #

When you register a consumer, Kinesis Data Streams generates an ARN for it. You need this ARN to be able to call SubscribeToShard.

If you delete a consumer and then create a new one with the same name, it won't have the same ARN. That's because consumer ARNs contain the creation timestamp. This is important to keep in mind if you have IAM policies that reference consumer ARNs.


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

When you register a consumer, Kinesis Data Streams generates an ARN for it. You need this ARN to be able to call SubscribeToShard.

If you delete a consumer and then create a new one with the same name, it won't have the same ARN. That's because consumer ARNs contain the creation timestamp. This is important to keep in mind if you have IAM policies that reference consumer ARNs.


[View source]
def consumer_creation_timestamp : Time #

[View source]
def consumer_creation_timestamp=(consumer_creation_timestamp : Time) #

[View source]
def consumer_name : String #

The name of the consumer is something you choose when you register the consumer.


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

The name of the consumer is something you choose when you register the consumer.


[View source]
def consumer_status : ConsumerStatus #

A consumer can't read data while in the CREATING or DELETING states.


[View source]
def consumer_status=(consumer_status : ConsumerStatus) #

A consumer can't read data while in the CREATING or DELETING states.


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

See Object#hash(hasher)


def stream_arn : String #

The ARN of the stream with which you registered the consumer.


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

The ARN of the stream with which you registered the consumer.


[View source]
def validate! : Nil #

[View source]