enum_AmazonOpenSearchServerlessS3BackupMode := [ "FailedDocumentsOnly", "AllDocuments" ]
enum_AmazonopensearchserviceIndexRotationPeriod := [ "NoRotation", "OneHour", "OneDay", "OneWeek", "OneMonth" ]
enum_AmazonopensearchserviceS3BackupMode := [ "FailedDocumentsOnly", "AllDocuments" ]
enum_CompressionFormat := [ "UNCOMPRESSED", "GZIP", "ZIP", "Snappy", "HADOOP_SNAPPY" ]
enum_Connectivity := [ "PUBLIC", "PRIVATE" ]
enum_ContentEncoding := [ "NONE", "GZIP" ]
enum_DatabaseType := [ "MySQL", "PostgreSQL" ]
enum_DefaultDocumentIdFormat := [ "FIREHOSE_DEFAULT", "NO_DOCUMENT_ID" ]
enum_DeliveryStreamType := [ "DirectPut", "KinesisStreamAsSource", "MSKAsSource", "DatabaseAsSource" ]
enum_ElasticsearchIndexRotationPeriod := [ "NoRotation", "OneHour", "OneDay", "OneWeek", "OneMonth" ]
enum_ElasticsearchS3BackupMode := [ "FailedDocumentsOnly", "AllDocuments" ]
enum_HECEndpointType := [ "Raw", "Event" ]
enum_HttpEndpointS3BackupMode := [ "FailedDataOnly", "AllData" ]
enum_IcebergS3BackupMode := [ "FailedDataOnly", "AllData" ]
enum_KeyType := [ "AWS_OWNED_CMK", "CUSTOMER_MANAGED_CMK" ]
enum_NoEncryptionConfig := [ "NoEncryption" ]
enum_OrcCompression := [ "NONE", "ZLIB", "SNAPPY" ]
enum_OrcFormatVersion := [ "V0_11", "V0_12" ]
enum_ParquetCompression := [ "UNCOMPRESSED", "GZIP", "SNAPPY" ]
enum_ParquetWriterVersion := [ "V1", "V2" ]
enum_ProcessorParameterName := [ "LambdaArn", "NumberOfRetries", "MetadataExtractionQuery", "JsonParsingEngine", "RoleArn", "BufferSizeInMBs", "BufferIntervalInSeconds", "SubRecordType", "Delimiter", "CompressionFormat", "DataMessageExtraction" ]
enum_ProcessorType := [ "RecordDeAggregation", "Decompression", "CloudWatchLogProcessing", "Lambda", "MetadataExtraction", "AppendDelimiterToRecord" ]
enum_RedshiftS3BackupMode := [ "Disabled", "Enabled" ]
enum_S3BackupMode := [ "Disabled", "Enabled" ]
enum_SSLMode := [ "Disabled", "Enabled" ]
enum_SnowflakeDataLoadingOption := [ "JSON_MAPPING", "VARIANT_CONTENT_MAPPING", "VARIANT_CONTENT_AND_METADATA_MAPPING" ]
enum_SnowflakeS3BackupMode := [ "FailedDataOnly", "AllData" ]
enum_SplunkS3BackupMode := [ "FailedEventsOnly", "AllEvents" ]

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.DeliveryStreamType == enum_DeliveryStreamType[_]
    input.Body.KinesisStreamSourceConfiguration.KinesisStreamARN == STRING
    input.Body.KinesisStreamSourceConfiguration.RoleARN == STRING
    input.Body.DeliveryStreamEncryptionConfigurationInput.KeyARN == STRING
    input.Body.DeliveryStreamEncryptionConfigurationInput.KeyType == enum_KeyType[_]
    input.Body.S3DestinationConfiguration.RoleARN == STRING
    input.Body.S3DestinationConfiguration.BucketARN == STRING
    input.Body.S3DestinationConfiguration.Prefix == STRING
    input.Body.S3DestinationConfiguration.ErrorOutputPrefix == STRING
    input.Body.S3DestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.S3DestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.S3DestinationConfiguration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.S3DestinationConfiguration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.S3DestinationConfiguration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.S3DestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.S3DestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.S3DestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ExtendedS3DestinationConfiguration.RoleARN == STRING
    input.Body.ExtendedS3DestinationConfiguration.BucketARN == STRING
    input.Body.ExtendedS3DestinationConfiguration.Prefix == STRING
    input.Body.ExtendedS3DestinationConfiguration.ErrorOutputPrefix == STRING
    input.Body.ExtendedS3DestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.ExtendedS3DestinationConfiguration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.ExtendedS3DestinationConfiguration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.ExtendedS3DestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ExtendedS3DestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ExtendedS3DestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.ExtendedS3DestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.ExtendedS3DestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.ExtendedS3DestinationConfiguration.S3BackupMode == enum_S3BackupMode[_]
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.RoleARN == STRING
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.BucketARN == STRING
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.Prefix == STRING
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.ErrorOutputPrefix == STRING
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ExtendedS3DestinationConfiguration.S3BackupConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.SchemaConfiguration.RoleARN == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.SchemaConfiguration.CatalogId == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.SchemaConfiguration.DatabaseName == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.SchemaConfiguration.TableName == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.SchemaConfiguration.Region == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.SchemaConfiguration.VersionId == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.OpenXJsonSerDe.ConvertDotsInJsonKeysToUnderscores == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.OpenXJsonSerDe.CaseInsensitive == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.OpenXJsonSerDe.ColumnToJsonKeyMappings.STRING == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.HiveJsonSerDe.TimestampFormats[_] == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.BlockSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.PageSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.Compression == enum_ParquetCompression[_]
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.EnableDictionaryCompression == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.MaxPaddingBytes == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.WriterVersion == enum_ParquetWriterVersion[_]
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.StripeSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.BlockSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.RowIndexStride == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.EnablePadding == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.PaddingTolerance == DOUBLE
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.Compression == enum_OrcCompression[_]
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.BloomFilterColumns[_] == STRING
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.BloomFilterFalsePositiveProbability == DOUBLE
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.DictionaryKeyThreshold == DOUBLE
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.FormatVersion == enum_OrcFormatVersion[_]
    input.Body.ExtendedS3DestinationConfiguration.DataFormatConversionConfiguration.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.DynamicPartitioningConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.ExtendedS3DestinationConfiguration.DynamicPartitioningConfiguration.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationConfiguration.FileExtension == STRING
    input.Body.ExtendedS3DestinationConfiguration.CustomTimeZone == STRING
    input.Body.RedshiftDestinationConfiguration.RoleARN == STRING
    input.Body.RedshiftDestinationConfiguration.ClusterJDBCURL == STRING
    input.Body.RedshiftDestinationConfiguration.CopyCommand.DataTableName == STRING
    input.Body.RedshiftDestinationConfiguration.CopyCommand.DataTableColumns == STRING
    input.Body.RedshiftDestinationConfiguration.CopyCommand.CopyOptions == STRING
    input.Body.RedshiftDestinationConfiguration.Username == STRING
    input.Body.RedshiftDestinationConfiguration.Password == STRING
    input.Body.RedshiftDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.RedshiftDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.RedshiftDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.RedshiftDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.RedshiftDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.RedshiftDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.RedshiftDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.RedshiftDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.RedshiftDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.RedshiftDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.RedshiftDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.RedshiftDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.RedshiftDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.RedshiftDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.RedshiftDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.RedshiftDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.RedshiftDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.RedshiftDestinationConfiguration.S3BackupMode == enum_RedshiftS3BackupMode[_]
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.RoleARN == STRING
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.BucketARN == STRING
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.Prefix == STRING
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.ErrorOutputPrefix == STRING
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.RedshiftDestinationConfiguration.S3BackupConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.RedshiftDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.RedshiftDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.RedshiftDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.RedshiftDestinationConfiguration.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.RedshiftDestinationConfiguration.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.RedshiftDestinationConfiguration.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationConfiguration.RoleARN == STRING
    input.Body.ElasticsearchDestinationConfiguration.DomainARN == STRING
    input.Body.ElasticsearchDestinationConfiguration.ClusterEndpoint == STRING
    input.Body.ElasticsearchDestinationConfiguration.IndexName == STRING
    input.Body.ElasticsearchDestinationConfiguration.TypeName == STRING
    input.Body.ElasticsearchDestinationConfiguration.IndexRotationPeriod == enum_ElasticsearchIndexRotationPeriod[_]
    input.Body.ElasticsearchDestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ElasticsearchDestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.ElasticsearchDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.ElasticsearchDestinationConfiguration.S3BackupMode == enum_ElasticsearchS3BackupMode[_]
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ElasticsearchDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ElasticsearchDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.ElasticsearchDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.ElasticsearchDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.ElasticsearchDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ElasticsearchDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ElasticsearchDestinationConfiguration.VpcConfiguration.SubnetIds[_] == STRING
    input.Body.ElasticsearchDestinationConfiguration.VpcConfiguration.RoleARN == STRING
    input.Body.ElasticsearchDestinationConfiguration.VpcConfiguration.SecurityGroupIds[_] == STRING
    input.Body.ElasticsearchDestinationConfiguration.DocumentIdOptions.DefaultDocumentIdFormat == enum_DefaultDocumentIdFormat[_]
    input.Body.AmazonopensearchserviceDestinationConfiguration.RoleARN == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.DomainARN == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.ClusterEndpoint == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.IndexName == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.TypeName == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.IndexRotationPeriod == enum_AmazonopensearchserviceIndexRotationPeriod[_]
    input.Body.AmazonopensearchserviceDestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonopensearchserviceDestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonopensearchserviceDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3BackupMode == enum_AmazonopensearchserviceS3BackupMode[_]
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.AmazonopensearchserviceDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.AmazonopensearchserviceDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.AmazonopensearchserviceDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonopensearchserviceDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.VpcConfiguration.SubnetIds[_] == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.VpcConfiguration.RoleARN == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.VpcConfiguration.SecurityGroupIds[_] == STRING
    input.Body.AmazonopensearchserviceDestinationConfiguration.DocumentIdOptions.DefaultDocumentIdFormat == enum_DefaultDocumentIdFormat[_]
    input.Body.SplunkDestinationConfiguration.HECEndpoint == STRING
    input.Body.SplunkDestinationConfiguration.HECEndpointType == enum_HECEndpointType[_]
    input.Body.SplunkDestinationConfiguration.HECToken == STRING
    input.Body.SplunkDestinationConfiguration.HECAcknowledgmentTimeoutInSeconds == INTEGER
    input.Body.SplunkDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.SplunkDestinationConfiguration.S3BackupMode == enum_SplunkS3BackupMode[_]
    input.Body.SplunkDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.SplunkDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.SplunkDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.SplunkDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.SplunkDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.SplunkDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.SplunkDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.SplunkDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.SplunkDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.SplunkDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SplunkDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SplunkDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SplunkDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.SplunkDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.SplunkDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.SplunkDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.SplunkDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SplunkDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SplunkDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SplunkDestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.SplunkDestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.SplunkDestinationConfiguration.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.SplunkDestinationConfiguration.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.SplunkDestinationConfiguration.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationConfiguration.EndpointConfiguration.Url == STRING
    input.Body.HttpEndpointDestinationConfiguration.EndpointConfiguration.Name == STRING
    input.Body.HttpEndpointDestinationConfiguration.EndpointConfiguration.AccessKey == STRING
    input.Body.HttpEndpointDestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.HttpEndpointDestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.HttpEndpointDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.HttpEndpointDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.HttpEndpointDestinationConfiguration.RequestConfiguration.ContentEncoding == enum_ContentEncoding[_]
    input.Body.HttpEndpointDestinationConfiguration.RequestConfiguration.CommonAttributes[_].AttributeName == STRING
    input.Body.HttpEndpointDestinationConfiguration.RequestConfiguration.CommonAttributes[_].AttributeValue == STRING
    input.Body.HttpEndpointDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.HttpEndpointDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.HttpEndpointDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.HttpEndpointDestinationConfiguration.RoleARN == STRING
    input.Body.HttpEndpointDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.HttpEndpointDestinationConfiguration.S3BackupMode == enum_HttpEndpointS3BackupMode[_]
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.HttpEndpointDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.HttpEndpointDestinationConfiguration.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.HttpEndpointDestinationConfiguration.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.HttpEndpointDestinationConfiguration.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.Tags[_].Key == STRING
    input.Body.Tags[_].Value == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.RoleARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.CollectionEndpoint == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.IndexName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3BackupMode == enum_AmazonOpenSearchServerlessS3BackupMode[_]
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.VpcConfiguration.SubnetIds[_] == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.VpcConfiguration.RoleARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationConfiguration.VpcConfiguration.SecurityGroupIds[_] == STRING
    input.Body.MSKSourceConfiguration.MSKClusterARN == STRING
    input.Body.MSKSourceConfiguration.TopicName == STRING
    input.Body.MSKSourceConfiguration.AuthenticationConfiguration.RoleARN == STRING
    input.Body.MSKSourceConfiguration.AuthenticationConfiguration.Connectivity == enum_Connectivity[_]
    input.Body.MSKSourceConfiguration.ReadFromTimestamp == TIMESTAMP
    input.Body.SnowflakeDestinationConfiguration.AccountUrl == STRING
    input.Body.SnowflakeDestinationConfiguration.PrivateKey == STRING
    input.Body.SnowflakeDestinationConfiguration.KeyPassphrase == STRING
    input.Body.SnowflakeDestinationConfiguration.User == STRING
    input.Body.SnowflakeDestinationConfiguration.Database == STRING
    input.Body.SnowflakeDestinationConfiguration.Schema == STRING
    input.Body.SnowflakeDestinationConfiguration.Table == STRING
    input.Body.SnowflakeDestinationConfiguration.SnowflakeRoleConfiguration.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationConfiguration.SnowflakeRoleConfiguration.SnowflakeRole == STRING
    input.Body.SnowflakeDestinationConfiguration.DataLoadingOption == enum_SnowflakeDataLoadingOption[_]
    input.Body.SnowflakeDestinationConfiguration.MetaDataColumnName == STRING
    input.Body.SnowflakeDestinationConfiguration.ContentColumnName == STRING
    input.Body.SnowflakeDestinationConfiguration.SnowflakeVpcConfiguration.PrivateLinkVpceId == STRING
    input.Body.SnowflakeDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SnowflakeDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SnowflakeDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.SnowflakeDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.SnowflakeDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.SnowflakeDestinationConfiguration.RoleARN == STRING
    input.Body.SnowflakeDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.SnowflakeDestinationConfiguration.S3BackupMode == enum_SnowflakeS3BackupMode[_]
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SnowflakeDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SnowflakeDestinationConfiguration.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.SnowflakeDestinationConfiguration.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.SnowflakeDestinationConfiguration.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.SnowflakeDestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.IcebergDestinationConfiguration.DestinationTableConfigurationList[_].DestinationTableName == STRING
    input.Body.IcebergDestinationConfiguration.DestinationTableConfigurationList[_].DestinationDatabaseName == STRING
    input.Body.IcebergDestinationConfiguration.DestinationTableConfigurationList[_].UniqueKeys[_] == STRING
    input.Body.IcebergDestinationConfiguration.DestinationTableConfigurationList[_].PartitionSpec.Identity[_].SourceName == STRING
    input.Body.IcebergDestinationConfiguration.DestinationTableConfigurationList[_].S3ErrorOutputPrefix == STRING
    input.Body.IcebergDestinationConfiguration.SchemaEvolutionConfiguration.Enabled == BOOLEAN
    input.Body.IcebergDestinationConfiguration.TableCreationConfiguration.Enabled == BOOLEAN
    input.Body.IcebergDestinationConfiguration.BufferingHints.SizeInMBs == INTEGER
    input.Body.IcebergDestinationConfiguration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.IcebergDestinationConfiguration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.IcebergDestinationConfiguration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.IcebergDestinationConfiguration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.IcebergDestinationConfiguration.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.IcebergDestinationConfiguration.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.IcebergDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.IcebergDestinationConfiguration.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.IcebergDestinationConfiguration.S3BackupMode == enum_IcebergS3BackupMode[_]
    input.Body.IcebergDestinationConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.IcebergDestinationConfiguration.RoleARN == STRING
    input.Body.IcebergDestinationConfiguration.CatalogConfiguration.CatalogARN == STRING
    input.Body.IcebergDestinationConfiguration.CatalogConfiguration.WarehouseLocation == STRING
    input.Body.IcebergDestinationConfiguration.S3Configuration.RoleARN == STRING
    input.Body.IcebergDestinationConfiguration.S3Configuration.BucketARN == STRING
    input.Body.IcebergDestinationConfiguration.S3Configuration.Prefix == STRING
    input.Body.IcebergDestinationConfiguration.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.IcebergDestinationConfiguration.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.IcebergDestinationConfiguration.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.IcebergDestinationConfiguration.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.IcebergDestinationConfiguration.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.IcebergDestinationConfiguration.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.IcebergDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.IcebergDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.IcebergDestinationConfiguration.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.DatabaseSourceConfiguration.Type == enum_DatabaseType[_]
    input.Body.DatabaseSourceConfiguration.Endpoint == STRING
    input.Body.DatabaseSourceConfiguration.Port == INTEGER
    input.Body.DatabaseSourceConfiguration.SSLMode == enum_SSLMode[_]
    input.Body.DatabaseSourceConfiguration.Databases.Include[_] == STRING
    input.Body.DatabaseSourceConfiguration.Databases.Exclude[_] == STRING
    input.Body.DatabaseSourceConfiguration.Tables.Include[_] == STRING
    input.Body.DatabaseSourceConfiguration.Tables.Exclude[_] == STRING
    input.Body.DatabaseSourceConfiguration.Columns.Include[_] == STRING
    input.Body.DatabaseSourceConfiguration.Columns.Exclude[_] == STRING
    input.Body.DatabaseSourceConfiguration.SurrogateKeys[_] == STRING
    input.Body.DatabaseSourceConfiguration.SnapshotWatermarkTable == STRING
    input.Body.DatabaseSourceConfiguration.DatabaseSourceAuthenticationConfiguration.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.DatabaseSourceConfiguration.DatabaseSourceAuthenticationConfiguration.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.DatabaseSourceConfiguration.DatabaseSourceAuthenticationConfiguration.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.DatabaseSourceConfiguration.DatabaseSourceVPCConfiguration.VpcEndpointServiceName == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.AllowForceDelete == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.Limit == INTEGER
    input.Body.ExclusiveStartDestinationId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_DeliveryStreamType := [ "DirectPut", "KinesisStreamAsSource", "MSKAsSource", "DatabaseAsSource" ]

valid {
    input.Body.Limit == INTEGER
    input.Body.DeliveryStreamType == enum_DeliveryStreamType[_]
    input.Body.ExclusiveStartDeliveryStreamName == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.ExclusiveStartTagKey == STRING
    input.Body.Limit == INTEGER
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.Record.Data == BLOB
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.Records[_].Data == BLOB
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_KeyType := [ "AWS_OWNED_CMK", "CUSTOMER_MANAGED_CMK" ]

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.DeliveryStreamEncryptionConfigurationInput.KeyARN == STRING
    input.Body.DeliveryStreamEncryptionConfigurationInput.KeyType == enum_KeyType[_]
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.Tags[_].Key == STRING
    input.Body.Tags[_].Value == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.TagKeys[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_AmazonopensearchserviceIndexRotationPeriod := [ "NoRotation", "OneHour", "OneDay", "OneWeek", "OneMonth" ]
enum_CompressionFormat := [ "UNCOMPRESSED", "GZIP", "ZIP", "Snappy", "HADOOP_SNAPPY" ]
enum_ContentEncoding := [ "NONE", "GZIP" ]
enum_DefaultDocumentIdFormat := [ "FIREHOSE_DEFAULT", "NO_DOCUMENT_ID" ]
enum_ElasticsearchIndexRotationPeriod := [ "NoRotation", "OneHour", "OneDay", "OneWeek", "OneMonth" ]
enum_HECEndpointType := [ "Raw", "Event" ]
enum_HttpEndpointS3BackupMode := [ "FailedDataOnly", "AllData" ]
enum_IcebergS3BackupMode := [ "FailedDataOnly", "AllData" ]
enum_NoEncryptionConfig := [ "NoEncryption" ]
enum_OrcCompression := [ "NONE", "ZLIB", "SNAPPY" ]
enum_OrcFormatVersion := [ "V0_11", "V0_12" ]
enum_ParquetCompression := [ "UNCOMPRESSED", "GZIP", "SNAPPY" ]
enum_ParquetWriterVersion := [ "V1", "V2" ]
enum_ProcessorParameterName := [ "LambdaArn", "NumberOfRetries", "MetadataExtractionQuery", "JsonParsingEngine", "RoleArn", "BufferSizeInMBs", "BufferIntervalInSeconds", "SubRecordType", "Delimiter", "CompressionFormat", "DataMessageExtraction" ]
enum_ProcessorType := [ "RecordDeAggregation", "Decompression", "CloudWatchLogProcessing", "Lambda", "MetadataExtraction", "AppendDelimiterToRecord" ]
enum_RedshiftS3BackupMode := [ "Disabled", "Enabled" ]
enum_S3BackupMode := [ "Disabled", "Enabled" ]
enum_SnowflakeDataLoadingOption := [ "JSON_MAPPING", "VARIANT_CONTENT_MAPPING", "VARIANT_CONTENT_AND_METADATA_MAPPING" ]
enum_SnowflakeS3BackupMode := [ "FailedDataOnly", "AllData" ]
enum_SplunkS3BackupMode := [ "FailedEventsOnly", "AllEvents" ]

valid {
    input.Body.DeliveryStreamName == STRING
    input.Body.CurrentDeliveryStreamVersionId == STRING
    input.Body.DestinationId == STRING
    input.Body.S3DestinationUpdate.RoleARN == STRING
    input.Body.S3DestinationUpdate.BucketARN == STRING
    input.Body.S3DestinationUpdate.Prefix == STRING
    input.Body.S3DestinationUpdate.ErrorOutputPrefix == STRING
    input.Body.S3DestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.S3DestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.S3DestinationUpdate.CompressionFormat == enum_CompressionFormat[_]
    input.Body.S3DestinationUpdate.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.S3DestinationUpdate.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.S3DestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.S3DestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.S3DestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ExtendedS3DestinationUpdate.RoleARN == STRING
    input.Body.ExtendedS3DestinationUpdate.BucketARN == STRING
    input.Body.ExtendedS3DestinationUpdate.Prefix == STRING
    input.Body.ExtendedS3DestinationUpdate.ErrorOutputPrefix == STRING
    input.Body.ExtendedS3DestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.ExtendedS3DestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ExtendedS3DestinationUpdate.CompressionFormat == enum_CompressionFormat[_]
    input.Body.ExtendedS3DestinationUpdate.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.ExtendedS3DestinationUpdate.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.ExtendedS3DestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ExtendedS3DestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ExtendedS3DestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.ExtendedS3DestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.ExtendedS3DestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.ExtendedS3DestinationUpdate.S3BackupMode == enum_S3BackupMode[_]
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.RoleARN == STRING
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.BucketARN == STRING
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.Prefix == STRING
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.ErrorOutputPrefix == STRING
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.CompressionFormat == enum_CompressionFormat[_]
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ExtendedS3DestinationUpdate.S3BackupUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.SchemaConfiguration.RoleARN == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.SchemaConfiguration.CatalogId == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.SchemaConfiguration.DatabaseName == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.SchemaConfiguration.TableName == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.SchemaConfiguration.Region == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.SchemaConfiguration.VersionId == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.OpenXJsonSerDe.ConvertDotsInJsonKeysToUnderscores == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.OpenXJsonSerDe.CaseInsensitive == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.OpenXJsonSerDe.ColumnToJsonKeyMappings.STRING == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.InputFormatConfiguration.Deserializer.HiveJsonSerDe.TimestampFormats[_] == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.BlockSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.PageSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.Compression == enum_ParquetCompression[_]
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.EnableDictionaryCompression == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.MaxPaddingBytes == INTEGER
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.ParquetSerDe.WriterVersion == enum_ParquetWriterVersion[_]
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.StripeSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.BlockSizeBytes == INTEGER
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.RowIndexStride == INTEGER
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.EnablePadding == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.PaddingTolerance == DOUBLE
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.Compression == enum_OrcCompression[_]
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.BloomFilterColumns[_] == STRING
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.BloomFilterFalsePositiveProbability == DOUBLE
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.DictionaryKeyThreshold == DOUBLE
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.OutputFormatConfiguration.Serializer.OrcSerDe.FormatVersion == enum_OrcFormatVersion[_]
    input.Body.ExtendedS3DestinationUpdate.DataFormatConversionConfiguration.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.DynamicPartitioningConfiguration.RetryOptions.DurationInSeconds == INTEGER
    input.Body.ExtendedS3DestinationUpdate.DynamicPartitioningConfiguration.Enabled == BOOLEAN
    input.Body.ExtendedS3DestinationUpdate.FileExtension == STRING
    input.Body.ExtendedS3DestinationUpdate.CustomTimeZone == STRING
    input.Body.RedshiftDestinationUpdate.RoleARN == STRING
    input.Body.RedshiftDestinationUpdate.ClusterJDBCURL == STRING
    input.Body.RedshiftDestinationUpdate.CopyCommand.DataTableName == STRING
    input.Body.RedshiftDestinationUpdate.CopyCommand.DataTableColumns == STRING
    input.Body.RedshiftDestinationUpdate.CopyCommand.CopyOptions == STRING
    input.Body.RedshiftDestinationUpdate.Username == STRING
    input.Body.RedshiftDestinationUpdate.Password == STRING
    input.Body.RedshiftDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.RedshiftDestinationUpdate.S3Update.RoleARN == STRING
    input.Body.RedshiftDestinationUpdate.S3Update.BucketARN == STRING
    input.Body.RedshiftDestinationUpdate.S3Update.Prefix == STRING
    input.Body.RedshiftDestinationUpdate.S3Update.ErrorOutputPrefix == STRING
    input.Body.RedshiftDestinationUpdate.S3Update.BufferingHints.SizeInMBs == INTEGER
    input.Body.RedshiftDestinationUpdate.S3Update.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.RedshiftDestinationUpdate.S3Update.CompressionFormat == enum_CompressionFormat[_]
    input.Body.RedshiftDestinationUpdate.S3Update.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.RedshiftDestinationUpdate.S3Update.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.RedshiftDestinationUpdate.S3Update.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.RedshiftDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.RedshiftDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.RedshiftDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.RedshiftDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.RedshiftDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.RedshiftDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.RedshiftDestinationUpdate.S3BackupMode == enum_RedshiftS3BackupMode[_]
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.RoleARN == STRING
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.BucketARN == STRING
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.Prefix == STRING
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.ErrorOutputPrefix == STRING
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.CompressionFormat == enum_CompressionFormat[_]
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.RedshiftDestinationUpdate.S3BackupUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.RedshiftDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.RedshiftDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.RedshiftDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.RedshiftDestinationUpdate.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.RedshiftDestinationUpdate.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.RedshiftDestinationUpdate.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationUpdate.RoleARN == STRING
    input.Body.ElasticsearchDestinationUpdate.DomainARN == STRING
    input.Body.ElasticsearchDestinationUpdate.ClusterEndpoint == STRING
    input.Body.ElasticsearchDestinationUpdate.IndexName == STRING
    input.Body.ElasticsearchDestinationUpdate.TypeName == STRING
    input.Body.ElasticsearchDestinationUpdate.IndexRotationPeriod == enum_ElasticsearchIndexRotationPeriod[_]
    input.Body.ElasticsearchDestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ElasticsearchDestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.ElasticsearchDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.ElasticsearchDestinationUpdate.S3Update.RoleARN == STRING
    input.Body.ElasticsearchDestinationUpdate.S3Update.BucketARN == STRING
    input.Body.ElasticsearchDestinationUpdate.S3Update.Prefix == STRING
    input.Body.ElasticsearchDestinationUpdate.S3Update.ErrorOutputPrefix == STRING
    input.Body.ElasticsearchDestinationUpdate.S3Update.BufferingHints.SizeInMBs == INTEGER
    input.Body.ElasticsearchDestinationUpdate.S3Update.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.ElasticsearchDestinationUpdate.S3Update.CompressionFormat == enum_CompressionFormat[_]
    input.Body.ElasticsearchDestinationUpdate.S3Update.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.ElasticsearchDestinationUpdate.S3Update.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.ElasticsearchDestinationUpdate.S3Update.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ElasticsearchDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ElasticsearchDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.ElasticsearchDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.ElasticsearchDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.ElasticsearchDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.ElasticsearchDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.ElasticsearchDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.ElasticsearchDestinationUpdate.DocumentIdOptions.DefaultDocumentIdFormat == enum_DefaultDocumentIdFormat[_]
    input.Body.AmazonopensearchserviceDestinationUpdate.RoleARN == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.DomainARN == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.ClusterEndpoint == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.IndexName == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.TypeName == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.IndexRotationPeriod == enum_AmazonopensearchserviceIndexRotationPeriod[_]
    input.Body.AmazonopensearchserviceDestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonopensearchserviceDestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonopensearchserviceDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.RoleARN == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.BucketARN == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.Prefix == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.ErrorOutputPrefix == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.CompressionFormat == enum_CompressionFormat[_]
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.AmazonopensearchserviceDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.AmazonopensearchserviceDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.AmazonopensearchserviceDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonopensearchserviceDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.AmazonopensearchserviceDestinationUpdate.DocumentIdOptions.DefaultDocumentIdFormat == enum_DefaultDocumentIdFormat[_]
    input.Body.SplunkDestinationUpdate.HECEndpoint == STRING
    input.Body.SplunkDestinationUpdate.HECEndpointType == enum_HECEndpointType[_]
    input.Body.SplunkDestinationUpdate.HECToken == STRING
    input.Body.SplunkDestinationUpdate.HECAcknowledgmentTimeoutInSeconds == INTEGER
    input.Body.SplunkDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.SplunkDestinationUpdate.S3BackupMode == enum_SplunkS3BackupMode[_]
    input.Body.SplunkDestinationUpdate.S3Update.RoleARN == STRING
    input.Body.SplunkDestinationUpdate.S3Update.BucketARN == STRING
    input.Body.SplunkDestinationUpdate.S3Update.Prefix == STRING
    input.Body.SplunkDestinationUpdate.S3Update.ErrorOutputPrefix == STRING
    input.Body.SplunkDestinationUpdate.S3Update.BufferingHints.SizeInMBs == INTEGER
    input.Body.SplunkDestinationUpdate.S3Update.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.SplunkDestinationUpdate.S3Update.CompressionFormat == enum_CompressionFormat[_]
    input.Body.SplunkDestinationUpdate.S3Update.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.SplunkDestinationUpdate.S3Update.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.SplunkDestinationUpdate.S3Update.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SplunkDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SplunkDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SplunkDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.SplunkDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.SplunkDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.SplunkDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.SplunkDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SplunkDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SplunkDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SplunkDestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.SplunkDestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.SplunkDestinationUpdate.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.SplunkDestinationUpdate.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.SplunkDestinationUpdate.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationUpdate.EndpointConfiguration.Url == STRING
    input.Body.HttpEndpointDestinationUpdate.EndpointConfiguration.Name == STRING
    input.Body.HttpEndpointDestinationUpdate.EndpointConfiguration.AccessKey == STRING
    input.Body.HttpEndpointDestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.HttpEndpointDestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.HttpEndpointDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.HttpEndpointDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.HttpEndpointDestinationUpdate.RequestConfiguration.ContentEncoding == enum_ContentEncoding[_]
    input.Body.HttpEndpointDestinationUpdate.RequestConfiguration.CommonAttributes[_].AttributeName == STRING
    input.Body.HttpEndpointDestinationUpdate.RequestConfiguration.CommonAttributes[_].AttributeValue == STRING
    input.Body.HttpEndpointDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.HttpEndpointDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.HttpEndpointDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.HttpEndpointDestinationUpdate.RoleARN == STRING
    input.Body.HttpEndpointDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.HttpEndpointDestinationUpdate.S3BackupMode == enum_HttpEndpointS3BackupMode[_]
    input.Body.HttpEndpointDestinationUpdate.S3Update.RoleARN == STRING
    input.Body.HttpEndpointDestinationUpdate.S3Update.BucketARN == STRING
    input.Body.HttpEndpointDestinationUpdate.S3Update.Prefix == STRING
    input.Body.HttpEndpointDestinationUpdate.S3Update.ErrorOutputPrefix == STRING
    input.Body.HttpEndpointDestinationUpdate.S3Update.BufferingHints.SizeInMBs == INTEGER
    input.Body.HttpEndpointDestinationUpdate.S3Update.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.HttpEndpointDestinationUpdate.S3Update.CompressionFormat == enum_CompressionFormat[_]
    input.Body.HttpEndpointDestinationUpdate.S3Update.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.HttpEndpointDestinationUpdate.S3Update.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.HttpEndpointDestinationUpdate.S3Update.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.HttpEndpointDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.HttpEndpointDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.HttpEndpointDestinationUpdate.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.HttpEndpointDestinationUpdate.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.HttpEndpointDestinationUpdate.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.RoleARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.CollectionEndpoint == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.IndexName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.RoleARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.BucketARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.Prefix == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.ErrorOutputPrefix == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.BufferingHints.SizeInMBs == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.CompressionFormat == enum_CompressionFormat[_]
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.AmazonOpenSearchServerlessDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SnowflakeDestinationUpdate.AccountUrl == STRING
    input.Body.SnowflakeDestinationUpdate.PrivateKey == STRING
    input.Body.SnowflakeDestinationUpdate.KeyPassphrase == STRING
    input.Body.SnowflakeDestinationUpdate.User == STRING
    input.Body.SnowflakeDestinationUpdate.Database == STRING
    input.Body.SnowflakeDestinationUpdate.Schema == STRING
    input.Body.SnowflakeDestinationUpdate.Table == STRING
    input.Body.SnowflakeDestinationUpdate.SnowflakeRoleConfiguration.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationUpdate.SnowflakeRoleConfiguration.SnowflakeRole == STRING
    input.Body.SnowflakeDestinationUpdate.DataLoadingOption == enum_SnowflakeDataLoadingOption[_]
    input.Body.SnowflakeDestinationUpdate.MetaDataColumnName == STRING
    input.Body.SnowflakeDestinationUpdate.ContentColumnName == STRING
    input.Body.SnowflakeDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SnowflakeDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SnowflakeDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.SnowflakeDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.SnowflakeDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.SnowflakeDestinationUpdate.RoleARN == STRING
    input.Body.SnowflakeDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.SnowflakeDestinationUpdate.S3BackupMode == enum_SnowflakeS3BackupMode[_]
    input.Body.SnowflakeDestinationUpdate.S3Update.RoleARN == STRING
    input.Body.SnowflakeDestinationUpdate.S3Update.BucketARN == STRING
    input.Body.SnowflakeDestinationUpdate.S3Update.Prefix == STRING
    input.Body.SnowflakeDestinationUpdate.S3Update.ErrorOutputPrefix == STRING
    input.Body.SnowflakeDestinationUpdate.S3Update.BufferingHints.SizeInMBs == INTEGER
    input.Body.SnowflakeDestinationUpdate.S3Update.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.SnowflakeDestinationUpdate.S3Update.CompressionFormat == enum_CompressionFormat[_]
    input.Body.SnowflakeDestinationUpdate.S3Update.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.SnowflakeDestinationUpdate.S3Update.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.SnowflakeDestinationUpdate.S3Update.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.SnowflakeDestinationUpdate.S3Update.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.SnowflakeDestinationUpdate.SecretsManagerConfiguration.SecretARN == STRING
    input.Body.SnowflakeDestinationUpdate.SecretsManagerConfiguration.RoleARN == STRING
    input.Body.SnowflakeDestinationUpdate.SecretsManagerConfiguration.Enabled == BOOLEAN
    input.Body.SnowflakeDestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.SnowflakeDestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.IcebergDestinationUpdate.DestinationTableConfigurationList[_].DestinationTableName == STRING
    input.Body.IcebergDestinationUpdate.DestinationTableConfigurationList[_].DestinationDatabaseName == STRING
    input.Body.IcebergDestinationUpdate.DestinationTableConfigurationList[_].UniqueKeys[_] == STRING
    input.Body.IcebergDestinationUpdate.DestinationTableConfigurationList[_].PartitionSpec.Identity[_].SourceName == STRING
    input.Body.IcebergDestinationUpdate.DestinationTableConfigurationList[_].S3ErrorOutputPrefix == STRING
    input.Body.IcebergDestinationUpdate.SchemaEvolutionConfiguration.Enabled == BOOLEAN
    input.Body.IcebergDestinationUpdate.TableCreationConfiguration.Enabled == BOOLEAN
    input.Body.IcebergDestinationUpdate.BufferingHints.SizeInMBs == INTEGER
    input.Body.IcebergDestinationUpdate.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.IcebergDestinationUpdate.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.IcebergDestinationUpdate.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.IcebergDestinationUpdate.CloudWatchLoggingOptions.LogStreamName == STRING
    input.Body.IcebergDestinationUpdate.ProcessingConfiguration.Enabled == BOOLEAN
    input.Body.IcebergDestinationUpdate.ProcessingConfiguration.Processors[_].Type == enum_ProcessorType[_]
    input.Body.IcebergDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterName == enum_ProcessorParameterName[_]
    input.Body.IcebergDestinationUpdate.ProcessingConfiguration.Processors[_].Parameters[_].ParameterValue == STRING
    input.Body.IcebergDestinationUpdate.S3BackupMode == enum_IcebergS3BackupMode[_]
    input.Body.IcebergDestinationUpdate.RetryOptions.DurationInSeconds == INTEGER
    input.Body.IcebergDestinationUpdate.RoleARN == STRING
    input.Body.IcebergDestinationUpdate.CatalogConfiguration.CatalogARN == STRING
    input.Body.IcebergDestinationUpdate.CatalogConfiguration.WarehouseLocation == STRING
    input.Body.IcebergDestinationUpdate.S3Configuration.RoleARN == STRING
    input.Body.IcebergDestinationUpdate.S3Configuration.BucketARN == STRING
    input.Body.IcebergDestinationUpdate.S3Configuration.Prefix == STRING
    input.Body.IcebergDestinationUpdate.S3Configuration.ErrorOutputPrefix == STRING
    input.Body.IcebergDestinationUpdate.S3Configuration.BufferingHints.SizeInMBs == INTEGER
    input.Body.IcebergDestinationUpdate.S3Configuration.BufferingHints.IntervalInSeconds == INTEGER
    input.Body.IcebergDestinationUpdate.S3Configuration.CompressionFormat == enum_CompressionFormat[_]
    input.Body.IcebergDestinationUpdate.S3Configuration.EncryptionConfiguration.NoEncryptionConfig == enum_NoEncryptionConfig[_]
    input.Body.IcebergDestinationUpdate.S3Configuration.EncryptionConfiguration.KMSEncryptionConfig.AWSKMSKeyARN == STRING
    input.Body.IcebergDestinationUpdate.S3Configuration.CloudWatchLoggingOptions.Enabled == BOOLEAN
    input.Body.IcebergDestinationUpdate.S3Configuration.CloudWatchLoggingOptions.LogGroupName == STRING
    input.Body.IcebergDestinationUpdate.S3Configuration.CloudWatchLoggingOptions.LogStreamName == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}