class Amazonite::Kinesis::CreateStreamInput

Overview

Represents the input for CreateStream.

Included Modules

Defined in:

kinesis/create_stream_input.cr

Constructors

Instance Method Summary

Constructor Detail

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

[View source]
def self.new(stream_name : String, shard_count : Int32 | Nil = nil, stream_mode_details : StreamModeDetails | Nil = nil, tags : Hash(String, String) | Nil = nil, warm_throughput_mi_bps : Int32 | Nil = nil, max_record_size_in_ki_b : Int32 | 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 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 shard_count : Int32 | Nil #

The number of shards that the stream will use. The throughput of the stream is a function of the number of shards; more shards are required for greater provisioned throughput.


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

The number of shards that the stream will use. The throughput of the stream is a function of the number of shards; more shards are required for greater provisioned throughput.


[View source]
def stream_mode_details : StreamModeDetails | Nil #

Indicates the capacity mode of the data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand capacity mode and a provisioned capacity mode for your data streams.


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

Indicates the capacity mode of the data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand capacity mode and a provisioned capacity mode for your data streams.


[View source]
def stream_name : String #

A name to identify the stream. The stream name is scoped to the Amazon Web Services account used by the application that creates the stream. It is also scoped by Amazon Web Services Region. That is, two streams in two different Amazon Web Services accounts can have the same name. Two streams in the same Amazon Web Services account but in two different Regions can also have the same name.


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

A name to identify the stream. The stream name is scoped to the Amazon Web Services account used by the application that creates the stream. It is also scoped by Amazon Web Services Region. That is, two streams in two different Amazon Web Services accounts can have the same name. Two streams in the same Amazon Web Services account but in two different Regions can also have the same name.


[View source]
def tags : Hash(String, String) | Nil #

A set of up to 50 key-value pairs to use to create the tags. A tag consists of a required key and an optional value.


[View source]
def tags=(tags : Hash(String, String) | Nil) #

A set of up to 50 key-value pairs to use to create the tags. A tag consists of a required key and an optional value.


[View source]
def validate! : Nil #

[View source]
def warm_throughput_mi_bps : Int32 | Nil #

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


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

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


[View source]