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

Package-level declarations

Types

@JsonSerializable

data class BatchResult(val Encrypted: Boolean, val FailedPutCount: Int, val RequestResponses: List<RequestResponses>?)

CreatedDeliveryStream

@JsonSerializable

data class CreatedDeliveryStream(val DeliveryStreamARN: ARN)

CreateDeliveryStream

@JsonSerializable

data class CreateDeliveryStream : FirehoseAction<CreatedDeliveryStream>

DeleteDeliveryStream

@JsonSerializable

data class DeleteDeliveryStream(val DeliveryStreamName: DeliveryStreamName, val AllowForceDelete: Boolean? = false) : FirehoseAction<Unit>

DeliveryStreams

@JsonSerializable

data class DeliveryStreams(val DeliveryStreamNames: List<DeliveryStreamName>, val HasMoreDeliveryStreams: Boolean)

ListDeliveryStreams

@JsonSerializable

data class ListDeliveryStreams(val DeliveryStreamType: DeliveryStreamType? = null, val ExclusiveStartDeliveryStreamName: String? = null, val Limit: Int? = 10) : FirehoseAction<DeliveryStreams>

@JsonSerializable

data class PutRecord(val DeliveryStreamName: DeliveryStreamName, val Record: Record) : FirehoseAction<RecordAdded>

@JsonSerializable

data class PutRecordBatch(val DeliveryStreamName: DeliveryStreamName, val Records: List<Record>) : FirehoseAction<BatchResult>

@JsonSerializable

data class RecordAdded(val Encrypted: Boolean, val RecordId: String)