class Amazonite::Kinesis::S3DestinationConfiguration

Overview

The configuration for delivery to a general purpose Amazon S3 bucket. Used in CreateChannel.

Included Modules

Defined in:

kinesis/s3_destination_configuration.cr

Constructors

Instance Method Summary

Constructor Detail

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

[View source]
def self.new(storage_configuration : S3StorageConfiguration, data_freshness_in_seconds : Int32 | Nil = nil, dead_letter_queue_s3_configuration : DeadLetterQueueS3Configuration | Nil = nil) #

[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 data_freshness_in_seconds : Int32 | Nil #

The maximum age, in seconds, of undelivered data. Valid range is 300 to 900 seconds (5 to 15 minutes). The default value is 300 seconds.


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

The maximum age, in seconds, of undelivered data. Valid range is 300 to 900 seconds (5 to 15 minutes). The default value is 300 seconds.


[View source]
def dead_letter_queue_s3_configuration : DeadLetterQueueS3Configuration | Nil #

The dead-letter queue configuration for records that cannot be delivered. Optional for general purpose Amazon S3 destinations. If not specified, it defaults to the destination bucket with an error prefix.


[View source]
def dead_letter_queue_s3_configuration=(dead_letter_queue_s3_configuration : DeadLetterQueueS3Configuration | Nil) #

The dead-letter queue configuration for records that cannot be delivered. Optional for general purpose Amazon S3 destinations. If not specified, it defaults to the destination bucket with an error prefix.


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

See Object#hash(hasher)


def storage_configuration : S3StorageConfiguration #

The Amazon S3 storage configuration for the channel.


[View source]
def storage_configuration=(storage_configuration : S3StorageConfiguration) #

The Amazon S3 storage configuration for the channel.


[View source]
def validate! : Nil #

[View source]