class Amazonite::Kinesis::CreateChannelInput

Included Modules

Defined in:

kinesis/create_channel_input.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(channel_name : String, service_execution_role_arn : String, stream_configuration_list : Array(ChannelStreamConfiguration), s3_destination_configuration : S3DestinationConfiguration | Nil = nil, s3_tables_destination_configuration : S3TablesDestinationConfiguration | Nil = nil, encryption_configuration : ChannelEncryptionConfiguration | Nil = nil, tags : Hash(String, String) | Nil = nil, logging_configuration : ChannelLoggingConfiguration | Nil = nil) #

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

The name of the channel. The name is unique within your Amazon Web Services account and Amazon Web Services Region.


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

The name of the channel. The name is unique within your Amazon Web Services account and Amazon Web Services Region.


[View source]
def encryption_configuration : ChannelEncryptionConfiguration | Nil #

The server-side encryption configuration that uses an Amazon Web Services KMS key to encrypt data delivered to the destination.


[View source]
def encryption_configuration=(encryption_configuration : ChannelEncryptionConfiguration | Nil) #

The server-side encryption configuration that uses an Amazon Web Services KMS key to encrypt data delivered to the destination.


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

See Object#hash(hasher)


def logging_configuration : ChannelLoggingConfiguration | Nil #

The Amazon CloudWatch Logs configuration for the channel.


[View source]
def logging_configuration=(logging_configuration : ChannelLoggingConfiguration | Nil) #

The Amazon CloudWatch Logs configuration for the channel.


[View source]
def s3_destination_configuration : S3DestinationConfiguration | Nil #

The configuration for delivery to a general purpose Amazon S3 bucket. You must specify either S3DestinationConfiguration or S3TablesDestinationConfiguration, but not both.


[View source]
def s3_destination_configuration=(s3_destination_configuration : S3DestinationConfiguration | Nil) #

The configuration for delivery to a general purpose Amazon S3 bucket. You must specify either S3DestinationConfiguration or S3TablesDestinationConfiguration, but not both.


[View source]
def s3_tables_destination_configuration : S3TablesDestinationConfiguration | Nil #

The configuration for delivery to streaming tables on Apache Iceberg in Amazon S3 Tables. You must specify either S3DestinationConfiguration or S3TablesDestinationConfiguration, but not both.


[View source]
def s3_tables_destination_configuration=(s3_tables_destination_configuration : S3TablesDestinationConfiguration | Nil) #

The configuration for delivery to streaming tables on Apache Iceberg in Amazon S3 Tables. You must specify either S3DestinationConfiguration or S3TablesDestinationConfiguration, but not both.


[View source]
def service_execution_role_arn : String #

The Amazon Resource Name (ARN) of the IAM role that Amazon Kinesis Data Streams assumes to write records to the destination.


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

The Amazon Resource Name (ARN) of the IAM role that Amazon Kinesis Data Streams assumes to write records to the destination.


[View source]
def stream_configuration_list : Array(ChannelStreamConfiguration) #

The source stream configuration for the channel. Currently, one stream is supported per channel.


[View source]
def stream_configuration_list=(stream_configuration_list : Array(ChannelStreamConfiguration)) #

The source stream configuration for the channel. Currently, one stream is supported per channel.


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

A set of key-value pairs to assign to the channel. A tag consists of a required key and an optional value.


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

A set of key-value pairs to assign to the channel. A tag consists of a required key and an optional value.


[View source]
def validate! : Nil #

[View source]