http4k-connect-amazon-firehose/org.http4k.connect.amazon.model

Package-level declarations

Types

@JsonSerializable

data class BufferingHints(val IntervalInSeconds: Int? = null, val SizeInMBs: Int? = null)

@JsonSerializable

data class CloudWatchLoggingOptions(val Enabled: Boolean? = null, val LogGroupName: String? = null, val LogStreamName: String? = null)

Compression

@JsonSerializable

enum Compression : Enum<Compression>

CompressionFormat

@JsonSerializable

enum CompressionFormat : Enum<CompressionFormat>

ContentEncoding

@JsonSerializable

enum ContentEncoding : Enum<ContentEncoding>

CopyCommand

@JsonSerializable

data class CopyCommand(val DataTableName: String, val CopyOptions: String? = null, val DataTableColumns: String? = null)

DataFormatConversionConfiguration

@JsonSerializable

data class DataFormatConversionConfiguration(val Enabled: Boolean? = null, val InputFormatConfiguration: InputFormatConfiguration? = null, val OutputFormatConfiguration: OutputFormatConfiguration? = null, val SchemaConfiguration: SchemaConfiguration? = null)

DeliveryStreamEncryptionConfigurationInput

@JsonSerializable

data class DeliveryStreamEncryptionConfigurationInput(val KeyType: KeyType, val KeyARN: ARN? = null)

DeliveryStreamName

class DeliveryStreamName : ResourceId

Deserializer

@JsonSerializable

data class Deserializer(val HiveJsonSerDe: HiveJsonSerDe? = null, val OpenXJsonSerDe: OpenXJsonSerDe? = null)

ElasticS3BackupMode

@JsonSerializable

enum ElasticS3BackupMode : Enum<ElasticS3BackupMode>

ElasticsearchDestinationConfiguration

@JsonSerializable

data class ElasticsearchDestinationConfiguration(val RoleARN: ARN, val IndexName: String, val S3Configuration: S3DestinationConfiguration, val BufferingHints: BufferingHints? = null, val CloudWatchLoggingOptions: CloudWatchLoggingOptions? = null, val ClusterEndpoint: String? = null, val DomainARN: ARN? = null, val IndexRotationPeriod: IndexRotationPeriod? = null, val ProcessingConfiguration: ProcessingConfiguration? = null, val RetryOptions: RetryOptions? = null, val S3BackupMode: ElasticS3BackupMode? = null, val TypeName: String? = null, val VpcConfiguration: VpcConfiguration? = null)

EncryptionConfiguration

@JsonSerializable

data class EncryptionConfiguration(val KMSEncryptionConfig: KMSEncryptionConfig? = null, val NoEncryptionConfig: NoEncryptionConfig? = null)

EndpointConfiguration

@JsonSerializable

data class EndpointConfiguration(val Url: Uri, val AccessKey: String? = null, val Name: String? = null)

ExtendedS3DestinationConfiguration

@JsonSerializable

data class ExtendedS3DestinationConfiguration(val BucketARN: ARN, val RoleARN: ARN, val BufferingHints: BufferingHints? = null, val CloudWatchLoggingOptions: CloudWatchLoggingOptions? = null, val CompressionFormat: CompressionFormat? = null, val DataFormatConversionConfiguration: DataFormatConversionConfiguration? = null, val EncryptionConfiguration: EncryptionConfiguration? = null, val ErrorOutputPrefix: String? = null, val Prefix: String? = null, val ProcessingConfiguration: ProcessingConfiguration? = null, val S3BackupConfiguration: S3BackupConfiguration? = null, val S3BackupMode: String? = null)

FormatVersion

@JsonSerializable

enum FormatVersion : Enum<FormatVersion>

HECEndpointType

@JsonSerializable

enum HECEndpointType : Enum<HECEndpointType>

HiveJsonSerDe

@JsonSerializable

data class HiveJsonSerDe(val TimestampFormats: List<String>? = null)

HttpEndpointCommonAttribute

@JsonSerializable

data class HttpEndpointCommonAttribute(val AttributeName: String, val AttributeValue: String)

HttpEndpointDestinationConfiguration

@JsonSerializable

data class HttpEndpointDestinationConfiguration(val S3Configuration: S3DestinationConfiguration?, val BufferingHints: BufferingHints? = null, val CloudWatchLoggingOptions: CloudWatchLoggingOptions? = null, val EndpointConfiguration: EndpointConfiguration? = null, val ProcessingConfiguration: ProcessingConfiguration? = null, val RequestConfiguration: RequestConfiguration? = null, val RetryOptions: RetryOptions? = null, val RoleARN: ARN? = null, val S3BackupMode: S3BackupMode? = null)

IndexRotationPeriod

@JsonSerializable

enum IndexRotationPeriod : Enum<IndexRotationPeriod>

InputFormatConfiguration

@JsonSerializable

data class InputFormatConfiguration(val Deserializer: Deserializer? = null)

KeyType

@JsonSerializable

enum KeyType : Enum<KeyType>

KinesisStreamSourceConfiguration

@JsonSerializable

data class KinesisStreamSourceConfiguration(val KinesisStreamARN: ARN, val RoleARN: ARN)

KMSEncryptionConfig

@JsonSerializable

data class KMSEncryptionConfig(val AWSKMSKeyARN: ARN)

NoEncryptionConfig

@JsonSerializable

enum NoEncryptionConfig : Enum<NoEncryptionConfig>

OpenXJsonSerDe

@JsonSerializable

data class OpenXJsonSerDe(val CaseInsensitive: Boolean? = null, val ColumnToJsonKeyMappings: Map<String, String>? = null, val ConvertDotsInJsonKeysToUnderscores: Boolean? = null)

OrcSerDe

@JsonSerializable

data class OrcSerDe(val BlockSizeBytes: Int? = null, val BloomFilterColumns: List<String>? = null, val BloomFilterFalsePositiveProbability: Int? = null, val Compression: Compression? = null, val DictionaryKeyThreshold: Int? = null, val EnablePadding: Boolean? = null, val FormatVersion: FormatVersion? = null, val PaddingTolerance: Int? = null, val RowIndexStride: Int? = null, val StripeSizeBytes: Int? = null)

OutputFormatConfiguration

@JsonSerializable

data class OutputFormatConfiguration(val Serializer: Serializer? = null)

ParameterName

@JsonSerializable

enum ParameterName : Enum<ParameterName>

ParquetSerDe

@JsonSerializable

data class ParquetSerDe(val BlockSizeBytes: Int? = null, val Compression: Compression? = null, val EnableDictionaryCompression: Boolean? = null, val MaxPaddingBytes: Int? = null, val PageSizeBytes: Int? = null, val WriterVersion: WriterVersion? = null)

ProcessingConfiguration

@JsonSerializable

data class ProcessingConfiguration(val Enabled: Boolean? = null, val Processors: List<Processor>? = null)

Processor

@JsonSerializable

data class Processor(val Parameters: List<ProcessorParameter>? = null)

ProcessorParameter

@JsonSerializable

data class ProcessorParameter(val ParameterName: ParameterName, val ParameterValue: String)

Record

@JsonSerializable

data class Record(val Data: Base64Blob)

RedshiftBackupMode

@JsonSerializable

enum RedshiftBackupMode : Enum<RedshiftBackupMode>

RedshiftDestinationConfiguration

@JsonSerializable

data class RedshiftDestinationConfiguration(val RoleARN: ARN, val ClusterJDBCURL: String, val CopyCommand: CopyCommand, val Username: String, val Password: String, val S3Configuration: S3DestinationConfiguration, val CloudWatchLoggingOptions: CloudWatchLoggingOptions? = null, val ProcessingConfiguration: ProcessingConfiguration? = null, val RetryOptions: RetryOptions? = null, val S3BackupConfiguration: S3BackupConfiguration? = null, val S3BackupMode: RedshiftBackupMode? = null)

RequestConfiguration

@JsonSerializable

data class RequestConfiguration(val CommonAttributes: List<HttpEndpointCommonAttribute>? = null, val ContentEncoding: ContentEncoding? = null)

RequestResponses

@JsonSerializable

data class RequestResponses(val ErrorCode: String? = null, val ErrorMessage: String? = null, val RecordId: String? = null)

RetryOptions

@JsonSerializable

data class RetryOptions(val DurationInSeconds: Int? = null)

S3BackupConfiguration

@JsonSerializable

data class S3BackupConfiguration(val BucketARN: ARN? = null, val BufferingHints: BufferingHints? = null, val CloudWatchLoggingOptions: CloudWatchLoggingOptions? = null, val CompressionFormat: String? = null, val EncryptionConfiguration: EncryptionConfiguration? = null, val ErrorOutputPrefix: String? = null, val Prefix: String? = null, val RoleARN: ARN? = null)

S3BackupMode

@JsonSerializable

enum S3BackupMode : Enum<S3BackupMode>

S3DestinationConfiguration

@JsonSerializable

data class S3DestinationConfiguration(val BucketARN: ARN, val RoleARN: ARN, val BufferingHints: BufferingHints? = null, val CloudWatchLoggingOptions: CloudWatchLoggingOptions? = null, val CompressionFormat: CompressionFormat? = null, val EncryptionConfiguration: EncryptionConfiguration? = null, val ErrorOutputPrefix: String? = null, val Prefix: String? = null)

SchemaConfiguration

@JsonSerializable

data class SchemaConfiguration(val CatalogId: String? = null, val DatabaseName: String? = null, val Region: Region? = null, val RoleARN: ARN? = null, val TableName: String? = null, val VersionId: String? = null)

Serializer

@JsonSerializable

data class Serializer(val OrcSerDe: OrcSerDe? = null, val ParquetSerDe: ParquetSerDe? = null)

SplunkDestinationConfiguration

@JsonSerializable

data class SplunkDestinationConfiguration(val HECEndpoint: String, val HECEndpointType: HECEndpointType, val HECToken: UUID, val CloudWatchLoggingOptions: CloudWatchLoggingOptions? = null, val HECAcknowledgmentTimeoutInSeconds: Int? = null, val ProcessingConfiguration: ProcessingConfiguration? = null, val RetryOptions: RetryOptions? = null, val S3BackupMode: SplunkS3BackupMode? = null, val S3Configuration: S3DestinationConfiguration? = null)

SplunkS3BackupMode

@JsonSerializable

enum SplunkS3BackupMode : Enum<SplunkS3BackupMode>

VpcConfiguration

@JsonSerializable

data class VpcConfiguration(val RoleARN: ARN, val SecurityGroupIds: List<String>, val SubnetIds: List<String>)

WriterVersion

@JsonSerializable

enum WriterVersion : Enum<WriterVersion>