types

Jan 28, 2025

Changes in this version

+ type DirectPutSourceConfiguration struct

+ ThroughputHintInMBs *int32

+ type DirectPutSourceDescription struct

+ ThroughputHintInMBs *int32

type IcebergDestinationConfiguration

+ AppendOnly *bool

type IcebergDestinationDescription

+ AppendOnly *bool

type IcebergDestinationUpdate

+ AppendOnly *bool

type SourceDescription

+ DirectPutSourceDescription *DirectPutSourceDescription

Nov 8, 2024

Changes in this version

type CatalogConfiguration

+ WarehouseLocation *string

+ type DatabaseColumnList struct

+ Exclude []string

+ Include []string

+ type DatabaseList struct

+ Exclude []string

+ Include []string

+ type DatabaseSnapshotInfo struct

+ FailureDescription *FailureDescription

+ Id *string

+ RequestTimestamp *time.Time

+ RequestedBy SnapshotRequestedBy

+ Status SnapshotStatus

+ Table *string

+ type DatabaseSourceAuthenticationConfiguration struct

+ SecretsManagerConfiguration *SecretsManagerConfiguration

+ type DatabaseSourceConfiguration struct

+ Columns *DatabaseColumnList

+ DatabaseSourceAuthenticationConfiguration *DatabaseSourceAuthenticationConfiguration

+ DatabaseSourceVPCConfiguration *DatabaseSourceVPCConfiguration

+ Databases *DatabaseList

+ Endpoint *string

+ Port *int32

+ SSLMode SSLMode

+ SnapshotWatermarkTable *string

+ SurrogateKeys []string

+ Tables *DatabaseTableList

+ Type DatabaseType

+ type DatabaseSourceDescription struct

+ Columns *DatabaseColumnList

+ DatabaseSourceAuthenticationConfiguration *DatabaseSourceAuthenticationConfiguration

+ DatabaseSourceVPCConfiguration *DatabaseSourceVPCConfiguration

+ Databases *DatabaseList

+ Endpoint *string

+ Port *int32

+ SSLMode SSLMode

+ SnapshotInfo []DatabaseSnapshotInfo

+ SnapshotWatermarkTable *string

+ SurrogateKeys []string

+ Tables *DatabaseTableList

+ Type DatabaseType

+ type DatabaseSourceVPCConfiguration struct

+ VpcEndpointServiceName *string

+ type DatabaseTableList struct

+ Exclude []string

+ Include []string

+ type DatabaseType string

+ const DatabaseTypeMySQL

+ const DatabaseTypePostgreSQL

+ func (DatabaseType) Values() []DatabaseType

type DeliveryStreamFailureType

+ const DeliveryStreamFailureTypeVpcEndpointServiceNameNotFound

+ const DeliveryStreamFailureTypeVpcInterfaceEndpointServiceAccessDenied

type DeliveryStreamType

+ const DeliveryStreamTypeDatabaseAsSource

type DestinationTableConfiguration

+ PartitionSpec *PartitionSpec

type IcebergDestinationConfiguration

+ SchemaEvolutionConfiguration *SchemaEvolutionConfiguration

+ TableCreationConfiguration *TableCreationConfiguration

type IcebergDestinationDescription

+ SchemaEvolutionConfiguration *SchemaEvolutionConfiguration

+ TableCreationConfiguration *TableCreationConfiguration

type IcebergDestinationUpdate

+ SchemaEvolutionConfiguration *SchemaEvolutionConfiguration

+ TableCreationConfiguration *TableCreationConfiguration

+ type PartitionField struct

+ SourceName *string

+ type PartitionSpec struct

+ Identity []PartitionField

+ type SSLMode string

+ const SSLModeDisabled

+ const SSLModeEnabled

+ func (SSLMode) Values() []SSLMode

+ type SchemaEvolutionConfiguration struct

+ Enabled *bool

+ type SnapshotRequestedBy string

+ const SnapshotRequestedByFirehose

+ const SnapshotRequestedByUser

+ func (SnapshotRequestedBy) Values() []SnapshotRequestedBy

+ type SnapshotStatus string

+ const SnapshotStatusComplete

+ const SnapshotStatusInProgress

+ const SnapshotStatusSuspended

+ func (SnapshotStatus) Values() []SnapshotStatus

type SourceDescription

+ DatabaseSourceDescription *DatabaseSourceDescription

+ type TableCreationConfiguration struct

+ Enabled *bool

Jul 18, 2024

Changes in this version

+ type CatalogConfiguration struct

+ CatalogARN *string

type DestinationDescription

+ IcebergDestinationDescription *IcebergDestinationDescription

+ type DestinationTableConfiguration struct

+ DestinationDatabaseName *string

+ DestinationTableName *string

+ S3ErrorOutputPrefix *string

+ UniqueKeys []string

+ type IcebergDestinationConfiguration struct

+ BufferingHints *BufferingHints

+ CatalogConfiguration *CatalogConfiguration

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DestinationTableConfigurationList []DestinationTableConfiguration

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *RetryOptions

+ RoleARN *string

+ S3BackupMode IcebergS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ type IcebergDestinationDescription struct

+ BufferingHints *BufferingHints

+ CatalogConfiguration *CatalogConfiguration

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DestinationTableConfigurationList []DestinationTableConfiguration

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *RetryOptions

+ RoleARN *string

+ S3BackupMode IcebergS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ type IcebergDestinationUpdate struct

+ BufferingHints *BufferingHints

+ CatalogConfiguration *CatalogConfiguration

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DestinationTableConfigurationList []DestinationTableConfiguration

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *RetryOptions

+ RoleARN *string

+ S3BackupMode IcebergS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ type IcebergS3BackupMode string

+ const IcebergS3BackupModeAllData

+ const IcebergS3BackupModeFailedDataOnly

+ func (IcebergS3BackupMode) Values() []IcebergS3BackupMode

type MSKSourceConfiguration

+ ReadFromTimestamp *time.Time

type MSKSourceDescription

+ ReadFromTimestamp *time.Time

+ type SnowflakeBufferingHints struct

+ IntervalInSeconds *int32

+ SizeInMBs *int32

type SnowflakeDestinationConfiguration

+ BufferingHints *SnowflakeBufferingHints

type SnowflakeDestinationDescription

+ BufferingHints *SnowflakeBufferingHints

type SnowflakeDestinationUpdate

+ BufferingHints *SnowflakeBufferingHints

Jun 6, 2024

Changes in this version

type HttpEndpointDestinationConfiguration

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type HttpEndpointDestinationDescription

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type HttpEndpointDestinationUpdate

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type RedshiftDestinationConfiguration

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type RedshiftDestinationDescription

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type RedshiftDestinationUpdate

+ SecretsManagerConfiguration *SecretsManagerConfiguration

+ type SecretsManagerConfiguration struct

+ Enabled *bool

+ RoleARN *string

+ SecretARN *string

type SnowflakeDestinationConfiguration

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type SnowflakeDestinationDescription

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type SnowflakeDestinationUpdate

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type SplunkDestinationConfiguration

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type SplunkDestinationDescription

+ SecretsManagerConfiguration *SecretsManagerConfiguration

type SplunkDestinationUpdate

+ SecretsManagerConfiguration *SecretsManagerConfiguration

Feb 16, 2024

Changes in this version

type ExtendedS3DestinationConfiguration

+ CustomTimeZone *string

+ FileExtension *string

type ExtendedS3DestinationDescription

+ CustomTimeZone *string

+ FileExtension *string

type ExtendedS3DestinationUpdate

+ CustomTimeZone *string

+ FileExtension *string

type ProcessorParameterName

+ const ProcessorParameterNameDataMessageExtraction

type ProcessorType

+ const ProcessorTypeCloudWatchLogProcessing

Jan 18, 2024

Changes in this version

type DestinationDescription

+ SnowflakeDestinationDescription *SnowflakeDestinationDescription

+ type SnowflakeDataLoadingOption string

+ const SnowflakeDataLoadingOptionJsonMapping

+ const SnowflakeDataLoadingOptionVariantContentAndMetadataMapping

+ const SnowflakeDataLoadingOptionVariantContentMapping

+ func (SnowflakeDataLoadingOption) Values() []SnowflakeDataLoadingOption

+ type SnowflakeDestinationConfiguration struct

+ AccountUrl *string

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ContentColumnName *string

+ DataLoadingOption SnowflakeDataLoadingOption

+ Database *string

+ KeyPassphrase *string

+ MetaDataColumnName *string

+ PrivateKey *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SnowflakeRetryOptions

+ RoleARN *string

+ S3BackupMode SnowflakeS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ Schema *string

+ SnowflakeRoleConfiguration *SnowflakeRoleConfiguration

+ SnowflakeVpcConfiguration *SnowflakeVpcConfiguration

+ Table *string

+ User *string

+ type SnowflakeDestinationDescription struct

+ AccountUrl *string

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ContentColumnName *string

+ DataLoadingOption SnowflakeDataLoadingOption

+ Database *string

+ MetaDataColumnName *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SnowflakeRetryOptions

+ RoleARN *string

+ S3BackupMode SnowflakeS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ Schema *string

+ SnowflakeRoleConfiguration *SnowflakeRoleConfiguration

+ SnowflakeVpcConfiguration *SnowflakeVpcConfiguration

+ Table *string

+ User *string

+ type SnowflakeDestinationUpdate struct

+ AccountUrl *string

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ContentColumnName *string

+ DataLoadingOption SnowflakeDataLoadingOption

+ Database *string

+ KeyPassphrase *string

+ MetaDataColumnName *string

+ PrivateKey *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SnowflakeRetryOptions

+ RoleARN *string

+ S3BackupMode SnowflakeS3BackupMode

+ S3Update *S3DestinationUpdate

+ Schema *string

+ SnowflakeRoleConfiguration *SnowflakeRoleConfiguration

+ Table *string

+ User *string

+ type SnowflakeRetryOptions struct

+ DurationInSeconds *int32

+ type SnowflakeRoleConfiguration struct

+ Enabled *bool

+ SnowflakeRole *string

+ type SnowflakeS3BackupMode string

+ const SnowflakeS3BackupModeAllData

+ const SnowflakeS3BackupModeFailedDataOnly

+ func (SnowflakeS3BackupMode) Values() []SnowflakeS3BackupMode

+ type SnowflakeVpcConfiguration struct

+ PrivateLinkVpceId *string

Dec 14, 2023

Changes in this version

+ type InvalidSourceException struct

+ Code *string

+ ErrorCodeOverride *string

+ Message *string

+ func (e *InvalidSourceException) Error() string

+ func (e *InvalidSourceException) ErrorCode() string

+ func (e *InvalidSourceException) ErrorFault() smithy.ErrorFault

+ func (e *InvalidSourceException) ErrorMessage() string

+ type SplunkBufferingHints struct

+ IntervalInSeconds *int32

+ SizeInMBs *int32

type SplunkDestinationConfiguration

+ BufferingHints *SplunkBufferingHints

type SplunkDestinationDescription

+ BufferingHints *SplunkBufferingHints

type SplunkDestinationUpdate

+ BufferingHints *SplunkBufferingHints

Sep 27, 2023

Changes in this version

+ type AuthenticationConfiguration struct

+ Connectivity Connectivity

+ RoleARN *string

+ type Connectivity string

+ const ConnectivityPrivate

+ const ConnectivityPublic

+ func (Connectivity) Values() []Connectivity

type DeliveryStreamType

+ const DeliveryStreamTypeMSKAsSource

+ type MSKSourceConfiguration struct

+ AuthenticationConfiguration *AuthenticationConfiguration

+ MSKClusterARN *string

+ TopicName *string

+ type MSKSourceDescription struct

+ AuthenticationConfiguration *AuthenticationConfiguration

+ DeliveryStartTimestamp *time.Time

+ MSKClusterARN *string

+ TopicName *string

type ProcessorParameterName

+ const ProcessorParameterNameCompressionFormat

type ProcessorType

+ const ProcessorTypeDecompression

type SourceDescription

+ MSKSourceDescription *MSKSourceDescription

Sep 13, 2023

Changes in this version

type AmazonopensearchserviceDestinationConfiguration

+ DocumentIdOptions *DocumentIdOptions

type AmazonopensearchserviceDestinationDescription

+ DocumentIdOptions *DocumentIdOptions

type AmazonopensearchserviceDestinationUpdate

+ DocumentIdOptions *DocumentIdOptions

+ type DefaultDocumentIdFormat string

+ const DefaultDocumentIdFormatFirehoseDefault

+ const DefaultDocumentIdFormatNoDocumentId

+ func (DefaultDocumentIdFormat) Values() []DefaultDocumentIdFormat

+ type DocumentIdOptions struct

+ DefaultDocumentIdFormat DefaultDocumentIdFormat

type ElasticsearchDestinationConfiguration

+ DocumentIdOptions *DocumentIdOptions

type ElasticsearchDestinationDescription

+ DocumentIdOptions *DocumentIdOptions

type ElasticsearchDestinationUpdate

+ DocumentIdOptions *DocumentIdOptions

Jan 5, 2023

Changes in this version

type ConcurrentModificationException

+ ErrorCodeOverride *string

type InvalidArgumentException

+ ErrorCodeOverride *string

type InvalidKMSResourceException

+ ErrorCodeOverride *string

type LimitExceededException

+ ErrorCodeOverride *string

type ResourceInUseException

+ ErrorCodeOverride *string

type ResourceNotFoundException

+ ErrorCodeOverride *string

type ServiceUnavailableException

+ ErrorCodeOverride *string

Nov 29, 2022

Changes in this version

+ type AmazonOpenSearchServerlessBufferingHints struct

+ IntervalInSeconds *int32

+ SizeInMBs *int32

+ type AmazonOpenSearchServerlessDestinationConfiguration struct

+ BufferingHints *AmazonOpenSearchServerlessBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CollectionEndpoint *string

+ IndexName *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *AmazonOpenSearchServerlessRetryOptions

+ RoleARN *string

+ S3BackupMode AmazonOpenSearchServerlessS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ VpcConfiguration *VpcConfiguration

+ type AmazonOpenSearchServerlessDestinationDescription struct

+ BufferingHints *AmazonOpenSearchServerlessBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CollectionEndpoint *string

+ IndexName *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *AmazonOpenSearchServerlessRetryOptions

+ RoleARN *string

+ S3BackupMode AmazonOpenSearchServerlessS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ VpcConfigurationDescription *VpcConfigurationDescription

+ type AmazonOpenSearchServerlessDestinationUpdate struct

+ BufferingHints *AmazonOpenSearchServerlessBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CollectionEndpoint *string

+ IndexName *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *AmazonOpenSearchServerlessRetryOptions

+ RoleARN *string

+ S3Update *S3DestinationUpdate

+ type AmazonOpenSearchServerlessRetryOptions struct

+ DurationInSeconds *int32

+ type AmazonOpenSearchServerlessS3BackupMode string

+ const AmazonOpenSearchServerlessS3BackupModeAllDocuments

+ const AmazonOpenSearchServerlessS3BackupModeFailedDocumentsOnly

+ func (AmazonOpenSearchServerlessS3BackupMode) Values() []AmazonOpenSearchServerlessS3BackupMode

type DestinationDescription

+ AmazonOpenSearchServerlessDestinationDescription *AmazonOpenSearchServerlessDestinationDescription

Oct 11, 2021

Changes in this version

+ type AmazonopensearchserviceBufferingHints struct

+ IntervalInSeconds *int32

+ SizeInMBs *int32

+ type AmazonopensearchserviceDestinationConfiguration struct

+ BufferingHints *AmazonopensearchserviceBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterEndpoint *string

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod AmazonopensearchserviceIndexRotationPeriod

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *AmazonopensearchserviceRetryOptions

+ RoleARN *string

+ S3BackupMode AmazonopensearchserviceS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ TypeName *string

+ VpcConfiguration *VpcConfiguration

+ type AmazonopensearchserviceDestinationDescription struct

+ BufferingHints *AmazonopensearchserviceBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterEndpoint *string

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod AmazonopensearchserviceIndexRotationPeriod

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *AmazonopensearchserviceRetryOptions

+ RoleARN *string

+ S3BackupMode AmazonopensearchserviceS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ TypeName *string

+ VpcConfigurationDescription *VpcConfigurationDescription

+ type AmazonopensearchserviceDestinationUpdate struct

+ BufferingHints *AmazonopensearchserviceBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterEndpoint *string

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod AmazonopensearchserviceIndexRotationPeriod

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *AmazonopensearchserviceRetryOptions

+ RoleARN *string

+ S3Update *S3DestinationUpdate

+ TypeName *string

+ type AmazonopensearchserviceIndexRotationPeriod string

+ const AmazonopensearchserviceIndexRotationPeriodNoRotation

+ const AmazonopensearchserviceIndexRotationPeriodOneDay

+ const AmazonopensearchserviceIndexRotationPeriodOneHour

+ const AmazonopensearchserviceIndexRotationPeriodOneMonth

+ const AmazonopensearchserviceIndexRotationPeriodOneWeek

+ func (AmazonopensearchserviceIndexRotationPeriod) Values() []AmazonopensearchserviceIndexRotationPeriod

+ type AmazonopensearchserviceRetryOptions struct

+ DurationInSeconds *int32

+ type AmazonopensearchserviceS3BackupMode string

+ const AmazonopensearchserviceS3BackupModeAllDocuments

+ const AmazonopensearchserviceS3BackupModeFailedDocumentsOnly

+ func (AmazonopensearchserviceS3BackupMode) Values() []AmazonopensearchserviceS3BackupMode

type DestinationDescription

+ AmazonopensearchserviceDestinationDescription *AmazonopensearchserviceDestinationDescription

Sep 2, 2021

Changes in this version

+ type DynamicPartitioningConfiguration struct

+ Enabled *bool

+ RetryOptions *RetryOptions

type ExtendedS3DestinationConfiguration

+ DynamicPartitioningConfiguration *DynamicPartitioningConfiguration

type ExtendedS3DestinationDescription

+ DynamicPartitioningConfiguration *DynamicPartitioningConfiguration

type ExtendedS3DestinationUpdate

+ DynamicPartitioningConfiguration *DynamicPartitioningConfiguration

type ProcessorParameterName

+ const ProcessorParameterNameDelimiter

+ const ProcessorParameterNameJsonParsingEngine

+ const ProcessorParameterNameMetadataExtractionQuery

+ const ProcessorParameterNameSubRecordType

type ProcessorType

+ const ProcessorTypeAppendDelimiterToRecord

+ const ProcessorTypeMetadataExtraction

+ const ProcessorTypeRecordDeAggregation

+ type RetryOptions struct

+ DurationInSeconds *int32

Jan 19, 2021

Changes in this version

type DeliveryStreamType

+ const DeliveryStreamTypeDirectPut

+ const DeliveryStreamTypeKinesisStreamAsSource

type ElasticsearchIndexRotationPeriod

+ const ElasticsearchIndexRotationPeriodNoRotation

+ const ElasticsearchIndexRotationPeriodOneDay

+ const ElasticsearchIndexRotationPeriodOneHour

+ const ElasticsearchIndexRotationPeriodOneMonth

+ const ElasticsearchIndexRotationPeriodOneWeek

type ElasticsearchS3BackupMode

+ const ElasticsearchS3BackupModeAllDocuments

+ const ElasticsearchS3BackupModeFailedDocumentsOnly

type HttpEndpointS3BackupMode

+ const HttpEndpointS3BackupModeAllData

+ const HttpEndpointS3BackupModeFailedDataOnly

type NoEncryptionConfig

+ const NoEncryptionConfigNoEncryption

type SplunkS3BackupMode

+ const SplunkS3BackupModeAllEvents

+ const SplunkS3BackupModeFailedEventsOnly

Oct 31, 2020

Changes in this version

type CompressionFormat

+ const CompressionFormatHadoopSnappy

+ func (CompressionFormat) Values() []CompressionFormat

type ContentEncoding

+ func (ContentEncoding) Values() []ContentEncoding

type DeliveryStreamEncryptionStatus

+ const DeliveryStreamEncryptionStatusDisablingFailed

+ const DeliveryStreamEncryptionStatusEnablingFailed

+ func (DeliveryStreamEncryptionStatus) Values() []DeliveryStreamEncryptionStatus

type DeliveryStreamFailureType

+ const DeliveryStreamFailureTypeCreateEniFailed

+ const DeliveryStreamFailureTypeCreateKmsGrantFailed

+ const DeliveryStreamFailureTypeDeleteEniFailed

+ const DeliveryStreamFailureTypeDisabledKmsKey

+ const DeliveryStreamFailureTypeEniAccessDenied

+ const DeliveryStreamFailureTypeInvalidKmsKey

+ const DeliveryStreamFailureTypeKmsAccessDenied

+ const DeliveryStreamFailureTypeKmsKeyNotFound

+ const DeliveryStreamFailureTypeKmsOptInRequired

+ const DeliveryStreamFailureTypeRetireKmsGrantFailed

+ const DeliveryStreamFailureTypeSecurityGroupAccessDenied

+ const DeliveryStreamFailureTypeSecurityGroupNotFound

+ const DeliveryStreamFailureTypeSubnetAccessDenied

+ const DeliveryStreamFailureTypeSubnetNotFound

+ const DeliveryStreamFailureTypeUnknownError

+ func (DeliveryStreamFailureType) Values() []DeliveryStreamFailureType

type DeliveryStreamStatus

+ const DeliveryStreamStatusCreatingFailed

+ const DeliveryStreamStatusDeletingFailed

+ func (DeliveryStreamStatus) Values() []DeliveryStreamStatus

type DeliveryStreamType

+ func (DeliveryStreamType) Values() []DeliveryStreamType

type ElasticsearchIndexRotationPeriod

+ func (ElasticsearchIndexRotationPeriod) Values() []ElasticsearchIndexRotationPeriod

type ElasticsearchS3BackupMode

+ func (ElasticsearchS3BackupMode) Values() []ElasticsearchS3BackupMode

type HECEndpointType

+ func (HECEndpointType) Values() []HECEndpointType

type HttpEndpointS3BackupMode

+ func (HttpEndpointS3BackupMode) Values() []HttpEndpointS3BackupMode

type KeyType

+ const KeyTypeAwsOwnedCmk

+ const KeyTypeCustomerManagedCmk

+ func (KeyType) Values() []KeyType

type NoEncryptionConfig

+ func (NoEncryptionConfig) Values() []NoEncryptionConfig

type OrcCompression

+ func (OrcCompression) Values() []OrcCompression

type OrcFormatVersion

+ const OrcFormatVersionV011

+ const OrcFormatVersionV012

+ func (OrcFormatVersion) Values() []OrcFormatVersion

type ParquetCompression

+ func (ParquetCompression) Values() []ParquetCompression

type ParquetWriterVersion

+ func (ParquetWriterVersion) Values() []ParquetWriterVersion

type ProcessorParameterName

+ const ProcessorParameterNameBufferIntervalInSeconds

+ const ProcessorParameterNameBufferSizeInMb

+ const ProcessorParameterNameLambdaArn

+ const ProcessorParameterNameLambdaNumberOfRetries

+ const ProcessorParameterNameRoleArn

+ func (ProcessorParameterName) Values() []ProcessorParameterName

type ProcessorType

+ func (ProcessorType) Values() []ProcessorType

type RedshiftS3BackupMode

+ func (RedshiftS3BackupMode) Values() []RedshiftS3BackupMode

type S3BackupMode

+ func (S3BackupMode) Values() []S3BackupMode

type SplunkS3BackupMode

+ func (SplunkS3BackupMode) Values() []SplunkS3BackupMode

Oct 1, 2020

Changes in this version

+ type BufferingHints struct

+ IntervalInSeconds *int32

+ SizeInMBs *int32

+ type CloudWatchLoggingOptions struct

+ Enabled *bool

+ LogGroupName *string

+ LogStreamName *string

+ type CompressionFormat string

+ const CompressionFormatGzip

+ const CompressionFormatHadoop_snappy

+ const CompressionFormatSnappy

+ const CompressionFormatUncompressed

+ const CompressionFormatZip

+ type ConcurrentModificationException struct

+ Message *string

+ func (e *ConcurrentModificationException) Error() string

+ func (e *ConcurrentModificationException) ErrorCode() string

+ func (e *ConcurrentModificationException) ErrorFault() smithy.ErrorFault

+ func (e *ConcurrentModificationException) ErrorMessage() string

+ type ContentEncoding string

+ const ContentEncodingGzip

+ const ContentEncodingNone

+ type CopyCommand struct

+ CopyOptions *string

+ DataTableColumns *string

+ DataTableName *string

+ type DataFormatConversionConfiguration struct

+ Enabled *bool

+ InputFormatConfiguration *InputFormatConfiguration

+ OutputFormatConfiguration *OutputFormatConfiguration

+ SchemaConfiguration *SchemaConfiguration

+ type DeliveryStreamDescription struct

+ CreateTimestamp *time.Time

+ DeliveryStreamARN *string

+ DeliveryStreamEncryptionConfiguration *DeliveryStreamEncryptionConfiguration

+ DeliveryStreamName *string

+ DeliveryStreamStatus DeliveryStreamStatus

+ DeliveryStreamType DeliveryStreamType

+ Destinations []*DestinationDescription

+ FailureDescription *FailureDescription

+ HasMoreDestinations *bool

+ LastUpdateTimestamp *time.Time

+ Source *SourceDescription

+ VersionId *string

+ type DeliveryStreamEncryptionConfiguration struct

+ FailureDescription *FailureDescription

+ KeyARN *string

+ KeyType KeyType

+ Status DeliveryStreamEncryptionStatus

+ type DeliveryStreamEncryptionConfigurationInput struct

+ KeyARN *string

+ KeyType KeyType

+ type DeliveryStreamEncryptionStatus string

+ const DeliveryStreamEncryptionStatusDisabled

+ const DeliveryStreamEncryptionStatusDisabling

+ const DeliveryStreamEncryptionStatusDisabling_failed

+ const DeliveryStreamEncryptionStatusEnabled

+ const DeliveryStreamEncryptionStatusEnabling

+ const DeliveryStreamEncryptionStatusEnabling_failed

+ type DeliveryStreamFailureType string

+ const DeliveryStreamFailureTypeCreate_eni_failed

+ const DeliveryStreamFailureTypeCreate_kms_grant_failed

+ const DeliveryStreamFailureTypeDelete_eni_failed

+ const DeliveryStreamFailureTypeDisabled_kms_key

+ const DeliveryStreamFailureTypeEni_access_denied

+ const DeliveryStreamFailureTypeInvalid_kms_key

+ const DeliveryStreamFailureTypeKms_access_denied

+ const DeliveryStreamFailureTypeKms_key_not_found

+ const DeliveryStreamFailureTypeKms_opt_in_required

+ const DeliveryStreamFailureTypeRetire_kms_grant_failed

+ const DeliveryStreamFailureTypeSecurity_group_access_denied

+ const DeliveryStreamFailureTypeSecurity_group_not_found

+ const DeliveryStreamFailureTypeSubnet_access_denied

+ const DeliveryStreamFailureTypeSubnet_not_found

+ const DeliveryStreamFailureTypeUnknown_error

+ type DeliveryStreamStatus string

+ const DeliveryStreamStatusActive

+ const DeliveryStreamStatusCreating

+ const DeliveryStreamStatusCreating_failed

+ const DeliveryStreamStatusDeleting

+ const DeliveryStreamStatusDeleting_failed

+ type DeliveryStreamType string

+ const DeliveryStreamTypeDirectput

+ const DeliveryStreamTypeKinesisstreamassource

+ type Deserializer struct

+ HiveJsonSerDe *HiveJsonSerDe

+ OpenXJsonSerDe *OpenXJsonSerDe

+ type DestinationDescription struct

+ DestinationId *string

+ ElasticsearchDestinationDescription *ElasticsearchDestinationDescription

+ ExtendedS3DestinationDescription *ExtendedS3DestinationDescription

+ HttpEndpointDestinationDescription *HttpEndpointDestinationDescription

+ RedshiftDestinationDescription *RedshiftDestinationDescription

+ S3DestinationDescription *S3DestinationDescription

+ SplunkDestinationDescription *SplunkDestinationDescription

+ type ElasticsearchBufferingHints struct

+ IntervalInSeconds *int32

+ SizeInMBs *int32

+ type ElasticsearchDestinationConfiguration struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterEndpoint *string

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod ElasticsearchIndexRotationPeriod

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode ElasticsearchS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ TypeName *string

+ VpcConfiguration *VpcConfiguration

+ type ElasticsearchDestinationDescription struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterEndpoint *string

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod ElasticsearchIndexRotationPeriod

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode ElasticsearchS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ TypeName *string

+ VpcConfigurationDescription *VpcConfigurationDescription

+ type ElasticsearchDestinationUpdate struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterEndpoint *string

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod ElasticsearchIndexRotationPeriod

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3Update *S3DestinationUpdate

+ TypeName *string

+ type ElasticsearchIndexRotationPeriod string

+ const ElasticsearchIndexRotationPeriodNorotation

+ const ElasticsearchIndexRotationPeriodOneday

+ const ElasticsearchIndexRotationPeriodOnehour

+ const ElasticsearchIndexRotationPeriodOnemonth

+ const ElasticsearchIndexRotationPeriodOneweek

+ type ElasticsearchRetryOptions struct

+ DurationInSeconds *int32

+ type ElasticsearchS3BackupMode string

+ const ElasticsearchS3BackupModeAlldocuments

+ const ElasticsearchS3BackupModeFaileddocumentsonly

+ type EncryptionConfiguration struct

+ KMSEncryptionConfig *KMSEncryptionConfig

+ NoEncryptionConfig NoEncryptionConfig

+ type ExtendedS3DestinationConfiguration struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

+ DataFormatConversionConfiguration *DataFormatConversionConfiguration

+ EncryptionConfiguration *EncryptionConfiguration

+ ErrorOutputPrefix *string

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupConfiguration *S3DestinationConfiguration

+ S3BackupMode S3BackupMode

+ type ExtendedS3DestinationDescription struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

+ DataFormatConversionConfiguration *DataFormatConversionConfiguration

+ EncryptionConfiguration *EncryptionConfiguration

+ ErrorOutputPrefix *string

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupDescription *S3DestinationDescription

+ S3BackupMode S3BackupMode

+ type ExtendedS3DestinationUpdate struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

+ DataFormatConversionConfiguration *DataFormatConversionConfiguration

+ EncryptionConfiguration *EncryptionConfiguration

+ ErrorOutputPrefix *string

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupMode S3BackupMode

+ S3BackupUpdate *S3DestinationUpdate

+ type FailureDescription struct

+ Details *string

+ Type DeliveryStreamFailureType

+ type HECEndpointType string

+ const HECEndpointTypeEvent

+ const HECEndpointTypeRaw

+ type HiveJsonSerDe struct

+ TimestampFormats []*string

+ type HttpEndpointBufferingHints struct

+ IntervalInSeconds *int32

+ SizeInMBs *int32

+ type HttpEndpointCommonAttribute struct

+ AttributeName *string

+ AttributeValue *string

+ type HttpEndpointConfiguration struct

+ AccessKey *string

+ Name *string

+ Url *string

+ type HttpEndpointDescription struct

+ Name *string

+ Url *string

+ type HttpEndpointDestinationConfiguration struct

+ BufferingHints *HttpEndpointBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ EndpointConfiguration *HttpEndpointConfiguration

+ ProcessingConfiguration *ProcessingConfiguration

+ RequestConfiguration *HttpEndpointRequestConfiguration

+ RetryOptions *HttpEndpointRetryOptions

+ RoleARN *string

+ S3BackupMode HttpEndpointS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ type HttpEndpointDestinationDescription struct

+ BufferingHints *HttpEndpointBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ EndpointConfiguration *HttpEndpointDescription

+ ProcessingConfiguration *ProcessingConfiguration

+ RequestConfiguration *HttpEndpointRequestConfiguration

+ RetryOptions *HttpEndpointRetryOptions

+ RoleARN *string

+ S3BackupMode HttpEndpointS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ type HttpEndpointDestinationUpdate struct

+ BufferingHints *HttpEndpointBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ EndpointConfiguration *HttpEndpointConfiguration

+ ProcessingConfiguration *ProcessingConfiguration

+ RequestConfiguration *HttpEndpointRequestConfiguration

+ RetryOptions *HttpEndpointRetryOptions

+ RoleARN *string

+ S3BackupMode HttpEndpointS3BackupMode

+ S3Update *S3DestinationUpdate

+ type HttpEndpointRequestConfiguration struct

+ CommonAttributes []*HttpEndpointCommonAttribute

+ ContentEncoding ContentEncoding

+ type HttpEndpointRetryOptions struct

+ DurationInSeconds *int32

+ type HttpEndpointS3BackupMode string

+ const HttpEndpointS3BackupModeAlldata

+ const HttpEndpointS3BackupModeFaileddataonly

+ type InputFormatConfiguration struct

+ Deserializer *Deserializer

+ type InvalidArgumentException struct

+ Message *string

+ func (e *InvalidArgumentException) Error() string

+ func (e *InvalidArgumentException) ErrorCode() string

+ func (e *InvalidArgumentException) ErrorFault() smithy.ErrorFault

+ func (e *InvalidArgumentException) ErrorMessage() string

+ type InvalidKMSResourceException struct

+ Code *string

+ Message *string

+ func (e *InvalidKMSResourceException) Error() string

+ func (e *InvalidKMSResourceException) ErrorCode() string

+ func (e *InvalidKMSResourceException) ErrorFault() smithy.ErrorFault

+ func (e *InvalidKMSResourceException) ErrorMessage() string

+ type KMSEncryptionConfig struct

+ AWSKMSKeyARN *string

+ type KeyType string

+ const KeyTypeAws_owned_cmk

+ const KeyTypeCustomer_managed_cmk

+ type KinesisStreamSourceConfiguration struct

+ KinesisStreamARN *string

+ RoleARN *string

+ type KinesisStreamSourceDescription struct

+ DeliveryStartTimestamp *time.Time

+ KinesisStreamARN *string

+ RoleARN *string

+ type LimitExceededException struct

+ Message *string

+ func (e *LimitExceededException) Error() string

+ func (e *LimitExceededException) ErrorCode() string

+ func (e *LimitExceededException) ErrorFault() smithy.ErrorFault

+ func (e *LimitExceededException) ErrorMessage() string

+ type NoEncryptionConfig string

+ const NoEncryptionConfigNoencryption

+ type OpenXJsonSerDe struct

+ CaseInsensitive *bool

+ ColumnToJsonKeyMappings map[string]*string

+ ConvertDotsInJsonKeysToUnderscores *bool

+ type OrcCompression string

+ const OrcCompressionNone

+ const OrcCompressionSnappy

+ const OrcCompressionZlib

+ type OrcFormatVersion string

+ const OrcFormatVersionV0_11

+ const OrcFormatVersionV0_12

+ type OrcSerDe struct

+ BlockSizeBytes *int32

+ BloomFilterColumns []*string

+ BloomFilterFalsePositiveProbability *float64

+ Compression OrcCompression

+ DictionaryKeyThreshold *float64

+ EnablePadding *bool

+ FormatVersion OrcFormatVersion

+ PaddingTolerance *float64

+ RowIndexStride *int32

+ StripeSizeBytes *int32

+ type OutputFormatConfiguration struct

+ Serializer *Serializer

+ type ParquetCompression string

+ const ParquetCompressionGzip

+ const ParquetCompressionSnappy

+ const ParquetCompressionUncompressed

+ type ParquetSerDe struct

+ BlockSizeBytes *int32

+ Compression ParquetCompression

+ EnableDictionaryCompression *bool

+ MaxPaddingBytes *int32

+ PageSizeBytes *int32

+ WriterVersion ParquetWriterVersion

+ type ParquetWriterVersion string

+ const ParquetWriterVersionV1

+ const ParquetWriterVersionV2

+ type ProcessingConfiguration struct

+ Enabled *bool

+ Processors []*Processor

+ type Processor struct

+ Parameters []*ProcessorParameter

+ Type ProcessorType

+ type ProcessorParameter struct

+ ParameterName ProcessorParameterName

+ ParameterValue *string

+ type ProcessorParameterName string

+ const ProcessorParameterNameBuffer_interval_in_seconds

+ const ProcessorParameterNameBuffer_size_in_mb

+ const ProcessorParameterNameLambda_arn

+ const ProcessorParameterNameLambda_number_of_retries

+ const ProcessorParameterNameRole_arn

+ type ProcessorType string

+ const ProcessorTypeLambda

+ type PutRecordBatchResponseEntry struct

+ ErrorCode *string

+ ErrorMessage *string

+ RecordId *string

+ type Record struct

+ Data []byte

+ type RedshiftDestinationConfiguration struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ Password *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *RedshiftRetryOptions

+ RoleARN *string

+ S3BackupConfiguration *S3DestinationConfiguration

+ S3BackupMode RedshiftS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ Username *string

+ type RedshiftDestinationDescription struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *RedshiftRetryOptions

+ RoleARN *string

+ S3BackupDescription *S3DestinationDescription

+ S3BackupMode RedshiftS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ Username *string

+ type RedshiftDestinationUpdate struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ Password *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *RedshiftRetryOptions

+ RoleARN *string

+ S3BackupMode RedshiftS3BackupMode

+ S3BackupUpdate *S3DestinationUpdate

+ S3Update *S3DestinationUpdate

+ Username *string

+ type RedshiftRetryOptions struct

+ DurationInSeconds *int32

+ type RedshiftS3BackupMode string

+ const RedshiftS3BackupModeDisabled

+ const RedshiftS3BackupModeEnabled

+ type ResourceInUseException struct

+ Message *string

+ func (e *ResourceInUseException) Error() string

+ func (e *ResourceInUseException) ErrorCode() string

+ func (e *ResourceInUseException) ErrorFault() smithy.ErrorFault

+ func (e *ResourceInUseException) ErrorMessage() string

+ type ResourceNotFoundException struct

+ Message *string

+ func (e *ResourceNotFoundException) Error() string

+ func (e *ResourceNotFoundException) ErrorCode() string

+ func (e *ResourceNotFoundException) ErrorFault() smithy.ErrorFault

+ func (e *ResourceNotFoundException) ErrorMessage() string

+ type S3BackupMode string

+ const S3BackupModeDisabled

+ const S3BackupModeEnabled

+ type S3DestinationConfiguration struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

+ EncryptionConfiguration *EncryptionConfiguration

+ ErrorOutputPrefix *string

+ Prefix *string

+ RoleARN *string

+ type S3DestinationDescription struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

+ EncryptionConfiguration *EncryptionConfiguration

+ ErrorOutputPrefix *string

+ Prefix *string

+ RoleARN *string

+ type S3DestinationUpdate struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

+ EncryptionConfiguration *EncryptionConfiguration

+ ErrorOutputPrefix *string

+ Prefix *string

+ RoleARN *string

+ type SchemaConfiguration struct

+ CatalogId *string

+ DatabaseName *string

+ Region *string

+ RoleARN *string

+ TableName *string

+ VersionId *string

+ type Serializer struct

+ OrcSerDe *OrcSerDe

+ ParquetSerDe *ParquetSerDe

+ type ServiceUnavailableException struct

+ Message *string

+ func (e *ServiceUnavailableException) Error() string

+ func (e *ServiceUnavailableException) ErrorCode() string

+ func (e *ServiceUnavailableException) ErrorFault() smithy.ErrorFault

+ func (e *ServiceUnavailableException) ErrorMessage() string

+ type SourceDescription struct

+ KinesisStreamSourceDescription *KinesisStreamSourceDescription

+ type SplunkDestinationConfiguration struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ HECAcknowledgmentTimeoutInSeconds *int32

+ HECEndpoint *string

+ HECEndpointType HECEndpointType

+ HECToken *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SplunkRetryOptions

+ S3BackupMode SplunkS3BackupMode

+ S3Configuration *S3DestinationConfiguration

+ type SplunkDestinationDescription struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ HECAcknowledgmentTimeoutInSeconds *int32

+ HECEndpoint *string

+ HECEndpointType HECEndpointType

+ HECToken *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SplunkRetryOptions

+ S3BackupMode SplunkS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

+ type SplunkDestinationUpdate struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ HECAcknowledgmentTimeoutInSeconds *int32

+ HECEndpoint *string

+ HECEndpointType HECEndpointType

+ HECToken *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SplunkRetryOptions

+ S3BackupMode SplunkS3BackupMode

+ S3Update *S3DestinationUpdate

+ type SplunkRetryOptions struct

+ DurationInSeconds *int32

+ type SplunkS3BackupMode string

+ const SplunkS3BackupModeAllevents

+ const SplunkS3BackupModeFailedeventsonly

+ type Tag struct

+ Key *string

+ Value *string

+ type VpcConfiguration struct

+ RoleARN *string

+ SecurityGroupIds []*string

+ SubnetIds []*string

+ type VpcConfigurationDescription struct

+ RoleARN *string

+ SecurityGroupIds []*string

+ SubnetIds []*string

+ VpcId *string