pulumi-aws-kotlin/com.pulumi.aws.pipes.kotlin.outputs

Package-level declarations

Types

Link copied to clipboard
data class PipeEnrichmentParameters(val httpParameters: PipeEnrichmentParametersHttpParameters? = null, val inputTemplate: String? = null)
Link copied to clipboard
data class PipeEnrichmentParametersHttpParameters(val headerParameters: Map<String, String>? = null, val pathParameterValues: String? = null, val queryStringParameters: Map<String, String>? = null)
Link copied to clipboard
data class PipeLogConfiguration(val cloudwatchLogsLogDestination: PipeLogConfigurationCloudwatchLogsLogDestination? = null, val firehoseLogDestination: PipeLogConfigurationFirehoseLogDestination? = null, val includeExecutionDatas: List<String>? = null, val level: String, val s3LogDestination: PipeLogConfigurationS3LogDestination? = null)
data class PipeLogConfigurationFirehoseLogDestination(val deliveryStreamArn: String)
Link copied to clipboard
data class PipeLogConfigurationS3LogDestination(val bucketName: String, val bucketOwner: String, val outputFormat: String? = null, val prefix: String? = null)
Link copied to clipboard
data class PipeSourceParameters(val activemqBrokerParameters: PipeSourceParametersActivemqBrokerParameters? = null, val dynamodbStreamParameters: PipeSourceParametersDynamodbStreamParameters? = null, val filterCriteria: PipeSourceParametersFilterCriteria? = null, val kinesisStreamParameters: PipeSourceParametersKinesisStreamParameters? = null, val managedStreamingKafkaParameters: PipeSourceParametersManagedStreamingKafkaParameters? = null, val rabbitmqBrokerParameters: PipeSourceParametersRabbitmqBrokerParameters? = null, val selfManagedKafkaParameters: PipeSourceParametersSelfManagedKafkaParameters? = null, val sqsQueueParameters: PipeSourceParametersSqsQueueParameters? = null)
data class PipeSourceParametersActivemqBrokerParameters(val batchSize: Int? = null, val credentials: PipeSourceParametersActivemqBrokerParametersCredentials, val maximumBatchingWindowInSeconds: Int? = null, val queueName: String)
data class PipeSourceParametersDynamodbStreamParameters(val batchSize: Int? = null, val deadLetterConfig: PipeSourceParametersDynamodbStreamParametersDeadLetterConfig? = null, val maximumBatchingWindowInSeconds: Int? = null, val maximumRecordAgeInSeconds: Int? = null, val maximumRetryAttempts: Int? = null, val onPartialBatchItemFailure: String? = null, val parallelizationFactor: Int? = null, val startingPosition: String)
Link copied to clipboard
Link copied to clipboard
data class PipeSourceParametersKinesisStreamParameters(val batchSize: Int? = null, val deadLetterConfig: PipeSourceParametersKinesisStreamParametersDeadLetterConfig? = null, val maximumBatchingWindowInSeconds: Int? = null, val maximumRecordAgeInSeconds: Int? = null, val maximumRetryAttempts: Int? = null, val onPartialBatchItemFailure: String? = null, val parallelizationFactor: Int? = null, val startingPosition: String, val startingPositionTimestamp: String? = null)
data class PipeSourceParametersManagedStreamingKafkaParameters(val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: PipeSourceParametersManagedStreamingKafkaParametersCredentials? = null, val maximumBatchingWindowInSeconds: Int? = null, val startingPosition: String? = null, val topicName: String)
data class PipeSourceParametersManagedStreamingKafkaParametersCredentials(val clientCertificateTlsAuth: String? = null, val saslScram512Auth: String? = null)
data class PipeSourceParametersRabbitmqBrokerParameters(val batchSize: Int? = null, val credentials: PipeSourceParametersRabbitmqBrokerParametersCredentials, val maximumBatchingWindowInSeconds: Int? = null, val queueName: String, val virtualHost: String? = null)
data class PipeSourceParametersSelfManagedKafkaParameters(val additionalBootstrapServers: List<String>? = null, val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: PipeSourceParametersSelfManagedKafkaParametersCredentials? = null, val maximumBatchingWindowInSeconds: Int? = null, val serverRootCaCertificate: String? = null, val startingPosition: String? = null, val topicName: String, val vpc: PipeSourceParametersSelfManagedKafkaParametersVpc? = null)
data class PipeSourceParametersSelfManagedKafkaParametersCredentials(val basicAuth: String? = null, val clientCertificateTlsAuth: String? = null, val saslScram256Auth: String? = null, val saslScram512Auth: String? = null)
data class PipeSourceParametersSelfManagedKafkaParametersVpc(val securityGroups: List<String>? = null, val subnets: List<String>? = null)
Link copied to clipboard
data class PipeSourceParametersSqsQueueParameters(val batchSize: Int? = null, val maximumBatchingWindowInSeconds: Int? = null)
Link copied to clipboard
data class PipeTargetParameters(val batchJobParameters: PipeTargetParametersBatchJobParameters? = null, val cloudwatchLogsParameters: PipeTargetParametersCloudwatchLogsParameters? = null, val ecsTaskParameters: PipeTargetParametersEcsTaskParameters? = null, val eventbridgeEventBusParameters: PipeTargetParametersEventbridgeEventBusParameters? = null, val httpParameters: PipeTargetParametersHttpParameters? = null, val inputTemplate: String? = null, val kinesisStreamParameters: PipeTargetParametersKinesisStreamParameters? = null, val lambdaFunctionParameters: PipeTargetParametersLambdaFunctionParameters? = null, val redshiftDataParameters: PipeTargetParametersRedshiftDataParameters? = null, val sagemakerPipelineParameters: PipeTargetParametersSagemakerPipelineParameters? = null, val sqsQueueParameters: PipeTargetParametersSqsQueueParameters? = null, val stepFunctionStateMachineParameters: PipeTargetParametersStepFunctionStateMachineParameters? = null)
Link copied to clipboard
data class PipeTargetParametersBatchJobParameters(val arrayProperties: PipeTargetParametersBatchJobParametersArrayProperties? = null, val containerOverrides: PipeTargetParametersBatchJobParametersContainerOverrides? = null, val dependsOns: List<PipeTargetParametersBatchJobParametersDependsOn>? = null, val jobDefinition: String, val jobName: String, val parameters: Map<String, String>? = null, val retryStrategy: PipeTargetParametersBatchJobParametersRetryStrategy? = null)
data class PipeTargetParametersBatchJobParametersContainerOverridesEnvironment(val name: String? = null, val value: String? = null)
data class PipeTargetParametersBatchJobParametersDependsOn(val jobId: String? = null, val type: String? = null)
data class PipeTargetParametersBatchJobParametersRetryStrategy(val attempts: Int? = null)
data class PipeTargetParametersCloudwatchLogsParameters(val logStreamName: String? = null, val timestamp: String? = null)
Link copied to clipboard
data class PipeTargetParametersEcsTaskParameters(val capacityProviderStrategies: List<PipeTargetParametersEcsTaskParametersCapacityProviderStrategy>? = null, val enableEcsManagedTags: Boolean? = null, val enableExecuteCommand: Boolean? = null, val group: String? = null, val launchType: String? = null, val networkConfiguration: PipeTargetParametersEcsTaskParametersNetworkConfiguration? = null, val overrides: PipeTargetParametersEcsTaskParametersOverrides? = null, val placementConstraints: List<PipeTargetParametersEcsTaskParametersPlacementConstraint>? = null, val placementStrategies: List<PipeTargetParametersEcsTaskParametersPlacementStrategy>? = null, val platformVersion: String? = null, val propagateTags: String? = null, val referenceId: String? = null, val tags: Map<String, String>? = null, val taskCount: Int? = null, val taskDefinitionArn: String)
data class PipeTargetParametersEcsTaskParametersCapacityProviderStrategy(val base: Int? = null, val capacityProvider: String, val weight: Int? = null)
data class PipeTargetParametersEcsTaskParametersNetworkConfigurationAwsVpcConfiguration(val assignPublicIp: String? = null, val securityGroups: List<String>? = null, val subnets: List<String>? = null)
data class PipeTargetParametersEcsTaskParametersOverrides(val containerOverrides: List<PipeTargetParametersEcsTaskParametersOverridesContainerOverride>? = null, val cpu: String? = null, val ephemeralStorage: PipeTargetParametersEcsTaskParametersOverridesEphemeralStorage? = null, val executionRoleArn: String? = null, val inferenceAcceleratorOverrides: List<PipeTargetParametersEcsTaskParametersOverridesInferenceAcceleratorOverride>? = null, val memory: String? = null, val taskRoleArn: String? = null)
data class PipeTargetParametersEcsTaskParametersOverridesContainerOverride(val commands: List<String>? = null, val cpu: Int? = null, val environmentFiles: List<PipeTargetParametersEcsTaskParametersOverridesContainerOverrideEnvironmentFile>? = null, val environments: List<PipeTargetParametersEcsTaskParametersOverridesContainerOverrideEnvironment>? = null, val memory: Int? = null, val memoryReservation: Int? = null, val name: String? = null, val resourceRequirements: List<PipeTargetParametersEcsTaskParametersOverridesContainerOverrideResourceRequirement>? = null)
data class PipeTargetParametersEcsTaskParametersOverridesInferenceAcceleratorOverride(val deviceName: String? = null, val deviceType: String? = null)
data class PipeTargetParametersEcsTaskParametersPlacementConstraint(val expression: String? = null, val type: String? = null)
data class PipeTargetParametersEcsTaskParametersPlacementStrategy(val field: String? = null, val type: String? = null)
data class PipeTargetParametersEventbridgeEventBusParameters(val detailType: String? = null, val endpointId: String? = null, val resources: List<String>? = null, val source: String? = null, val time: String? = null)
Link copied to clipboard
data class PipeTargetParametersHttpParameters(val headerParameters: Map<String, String>? = null, val pathParameterValues: String? = null, val queryStringParameters: Map<String, String>? = null)
data class PipeTargetParametersKinesisStreamParameters(val partitionKey: String)
data class PipeTargetParametersLambdaFunctionParameters(val invocationType: String)
data class PipeTargetParametersRedshiftDataParameters(val database: String, val dbUser: String? = null, val secretManagerArn: String? = null, val sqls: List<String>, val statementName: String? = null, val withEvent: Boolean? = null)
Link copied to clipboard
data class PipeTargetParametersSqsQueueParameters(val messageDeduplicationId: String? = null, val messageGroupId: String? = null)