class Amazonite::Kinesis::StreamDescriptionSummary

Overview

Represents the output for DescribeStreamSummary

Included Modules

Defined in:

kinesis/stream_description_summary.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(stream_name : String, stream_arn : String, stream_status : StreamStatus, retention_period_hours : Int32, stream_creation_timestamp : Time, enhanced_monitoring : Array(EnhancedMetrics), open_shard_count : Int32, stream_id : String | Nil = nil, stream_mode_details : StreamModeDetails | Nil = nil, encryption_type : EncryptionType | Nil = nil, key_id : String | Nil = nil, consumer_count : Int32 | Nil = nil, warm_throughput : WarmThroughputObject | Nil = nil, max_record_size_in_ki_b : Int32 | Nil = nil, channel_count : Int32 | 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 channel_count : Int32 | Nil #

The number of channels associated with the stream.


[View source]
def channel_count=(channel_count : Int32 | Nil) #

The number of channels associated with the stream.


[View source]
def consumer_count : Int32 | Nil #

The number of enhanced fan-out consumers registered with the stream.


[View source]
def consumer_count=(consumer_count : Int32 | Nil) #

The number of enhanced fan-out consumers registered with the stream.


[View source]
def encryption_type : EncryptionType | Nil #

The encryption type used. This value is one of the following:

  • KMS

  • NONE


[View source]
def encryption_type=(encryption_type : EncryptionType | Nil) #

The encryption type used. This value is one of the following:

  • KMS

  • NONE


[View source]
def enhanced_monitoring : Array(EnhancedMetrics) #

Represents the current enhanced monitoring settings of the stream.


[View source]
def enhanced_monitoring=(enhanced_monitoring : Array(EnhancedMetrics)) #

Represents the current enhanced monitoring settings of the stream.


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

See Object#hash(hasher)


def key_id : String | Nil #

The GUID for the customer-managed Amazon Web Services KMS key to use for encryption. This value can be a globally unique identifier, a fully specified ARN to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.

  • Key ARN example: arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012

  • Alias ARN example: arn:aws:kms:us-east-1:123456789012:alias/MyAliasName

  • Globally unique key ID example: 12345678-1234-1234-1234-123456789012

  • Alias name example: alias/MyAliasName

  • Master key owned by Kinesis Data Streams: alias/aws/kinesis


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

The GUID for the customer-managed Amazon Web Services KMS key to use for encryption. This value can be a globally unique identifier, a fully specified ARN to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.

  • Key ARN example: arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012

  • Alias ARN example: arn:aws:kms:us-east-1:123456789012:alias/MyAliasName

  • Globally unique key ID example: 12345678-1234-1234-1234-123456789012

  • Alias name example: alias/MyAliasName

  • Master key owned by Kinesis Data Streams: alias/aws/kinesis


[View source]
def max_record_size_in_ki_b : Int32 | Nil #

The maximum record size of a single record in kibibyte (KiB) that you can write to, and read from a stream.


[View source]
def max_record_size_in_ki_b=(max_record_size_in_ki_b : Int32 | Nil) #

The maximum record size of a single record in kibibyte (KiB) that you can write to, and read from a stream.


[View source]
def open_shard_count : Int32 #

The number of open shards in the stream.


[View source]
def open_shard_count=(open_shard_count : Int32) #

The number of open shards in the stream.


[View source]
def retention_period_hours : Int32 #

The current retention period, in hours.


[View source]
def retention_period_hours=(retention_period_hours : Int32) #

The current retention period, in hours.


[View source]
def stream_arn : String #

The Amazon Resource Name (ARN) for the stream being described.


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

The Amazon Resource Name (ARN) for the stream being described.


[View source]
def stream_creation_timestamp : Time #

The approximate time that the stream was created.


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

The approximate time that the stream was created.


[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 stream_mode_details : StreamModeDetails | Nil #

Specifies the capacity mode to which you want to set your data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand ycapacity mode and a provisioned capacity mode for your data streams.


[View source]
def stream_mode_details=(stream_mode_details : StreamModeDetails | Nil) #

Specifies the capacity mode to which you want to set your data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand ycapacity mode and a provisioned capacity mode for your data streams.


[View source]
def stream_name : String #

The name of the stream being described.


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

The name of the stream being described.


[View source]
def stream_status : StreamStatus #

The current status of the stream being described. The stream status is one of the following states:

  • CREATING - The stream is being created. Kinesis Data Streams immediately returns and sets StreamStatus to CREATING.

  • DELETING - The stream is being deleted. The specified stream is in the DELETING state until Kinesis Data Streams completes the deletion.

  • ACTIVE - The stream exists and is ready for read and write operations or deletion. You should perform read and write operations only on an ACTIVE stream.

  • UPDATING - Shards in the stream are being merged or split. Read and write operations continue to work while the stream is in the UPDATING state.


[View source]
def stream_status=(stream_status : StreamStatus) #

The current status of the stream being described. The stream status is one of the following states:

  • CREATING - The stream is being created. Kinesis Data Streams immediately returns and sets StreamStatus to CREATING.

  • DELETING - The stream is being deleted. The specified stream is in the DELETING state until Kinesis Data Streams completes the deletion.

  • ACTIVE - The stream exists and is ready for read and write operations or deletion. You should perform read and write operations only on an ACTIVE stream.

  • UPDATING - Shards in the stream are being merged or split. Read and write operations continue to work while the stream is in the UPDATING state.


[View source]
def validate! : Nil #

[View source]
def warm_throughput : WarmThroughputObject | Nil #

The warm throughput in MB/s for the stream. This represents the throughput capacity that will be immediately available for write operations.


[View source]
def warm_throughput=(warm_throughput : WarmThroughputObject | Nil) #

The warm throughput in MB/s for the stream. This represents the throughput capacity that will be immediately available for write operations.


[View source]