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

Package-level declarations

Types

data class GetPipeResult(val arn: String? = null, val creationTime: String? = null, val currentState: PipeState? = null, val description: String? = null, val desiredState: PipeRequestedPipeState? = null, val enrichment: String? = null, val enrichmentParameters: PipeEnrichmentParameters? = null, val lastModifiedTime: String? = null, val roleArn: String? = null, val stateReason: String? = null, val tags: PipeTagMap? = null, val target: String? = null)

PipeAwsVpcConfiguration

data class PipeAwsVpcConfiguration(val assignPublicIp: PipeAssignPublicIp? = null, val securityGroups: List<String>? = null, val subnets: List<String>)

PipeBatchArrayProperties

data class PipeBatchArrayProperties(val size: Int? = null)

PipeBatchContainerOverrides

data class PipeBatchContainerOverrides(val command: List<String>? = null, val environment: List<PipeBatchEnvironmentVariable>? = null, val instanceType: String? = null, val resourceRequirements: List<PipeBatchResourceRequirement>? = null)

PipeBatchEnvironmentVariable

data class PipeBatchEnvironmentVariable(val name: String? = null, val value: String? = null)

PipeBatchJobDependency

data class PipeBatchJobDependency(val jobId: String? = null, val type: PipeBatchJobDependencyType? = null)

PipeBatchParametersMap

class PipeBatchParametersMap

PipeBatchResourceRequirement

data class PipeBatchResourceRequirement(val type: PipeBatchResourceRequirementType, val value: String)

PipeBatchRetryStrategy

data class PipeBatchRetryStrategy(val attempts: Int? = null)

PipeCapacityProviderStrategyItem

data class PipeCapacityProviderStrategyItem(val base: Int? = null, val capacityProvider: String, val weight: Int? = null)

PipeDeadLetterConfig

data class PipeDeadLetterConfig(val arn: String? = null)

PipeEcsContainerOverride

data class PipeEcsContainerOverride(val command: List<String>? = null, val cpu: Int? = null, val environment: List<PipeEcsEnvironmentVariable>? = null, val environmentFiles: List<PipeEcsEnvironmentFile>? = null, val memory: Int? = null, val memoryReservation: Int? = null, val name: String? = null, val resourceRequirements: List<PipeEcsResourceRequirement>? = null)

PipeEcsEnvironmentFile

data class PipeEcsEnvironmentFile(val type: PipeEcsEnvironmentFileType, val value: String)

PipeEcsEnvironmentVariable

data class PipeEcsEnvironmentVariable(val name: String? = null, val value: String? = null)

PipeEcsEphemeralStorage

data class PipeEcsEphemeralStorage(val sizeInGiB: Int)

PipeEcsInferenceAcceleratorOverride

data class PipeEcsInferenceAcceleratorOverride(val deviceName: String? = null, val deviceType: String? = null)

PipeEcsResourceRequirement

data class PipeEcsResourceRequirement(val type: PipeEcsResourceRequirementType, val value: String)

PipeEcsTaskOverride

data class PipeEcsTaskOverride(val containerOverrides: List<PipeEcsContainerOverride>? = null, val cpu: String? = null, val ephemeralStorage: PipeEcsEphemeralStorage? = null, val executionRoleArn: String? = null, val inferenceAcceleratorOverrides: List<PipeEcsInferenceAcceleratorOverride>? = null, val memory: String? = null, val taskRoleArn: String? = null)

PipeEnrichmentHttpParameters

data class PipeEnrichmentHttpParameters(val headerParameters: PipeHeaderParametersMap? = null, val pathParameterValues: List<String>? = null, val queryStringParameters: PipeQueryStringParametersMap? = null)

PipeEnrichmentParameters

data class PipeEnrichmentParameters(val httpParameters: PipeEnrichmentHttpParameters? = null, val inputTemplate: String? = null)

PipeFilter

data class PipeFilter(val pattern: String? = null)

PipeFilterCriteria

data class PipeFilterCriteria(val filters: List<PipeFilter>? = null)

PipeHeaderParametersMap

class PipeHeaderParametersMap

PipeMqBrokerAccessCredentialsProperties

data class PipeMqBrokerAccessCredentialsProperties(val basicAuth: String)

PipeMskAccessCredentials0Properties

data class PipeMskAccessCredentials0Properties(val saslScram512Auth: String)

PipeMskAccessCredentials1Properties

data class PipeMskAccessCredentials1Properties(val clientCertificateTlsAuth: String)

PipeNetworkConfiguration

data class PipeNetworkConfiguration(val awsvpcConfiguration: PipeAwsVpcConfiguration? = null)

PipePlacementConstraint

data class PipePlacementConstraint(val expression: String? = null, val type: PipePlacementConstraintType? = null)

PipePlacementStrategy

data class PipePlacementStrategy(val field: String? = null, val type: PipePlacementStrategyType? = null)

PipeQueryStringParametersMap

class PipeQueryStringParametersMap

PipeSageMakerPipelineParameter

data class PipeSageMakerPipelineParameter(val name: String, val value: String)

PipeSelfManagedKafkaAccessConfigurationCredentials0Properties

data class PipeSelfManagedKafkaAccessConfigurationCredentials0Properties(val basicAuth: String)

PipeSelfManagedKafkaAccessConfigurationCredentials1Properties

data class PipeSelfManagedKafkaAccessConfigurationCredentials1Properties(val saslScram512Auth: String)

PipeSelfManagedKafkaAccessConfigurationCredentials2Properties

data class PipeSelfManagedKafkaAccessConfigurationCredentials2Properties(val saslScram256Auth: String)

PipeSelfManagedKafkaAccessConfigurationCredentials3Properties

data class PipeSelfManagedKafkaAccessConfigurationCredentials3Properties(val clientCertificateTlsAuth: String)

PipeSelfManagedKafkaAccessConfigurationVpc

data class PipeSelfManagedKafkaAccessConfigurationVpc(val securityGroup: List<String>? = null, val subnets: List<String>? = null)

PipeSourceActiveMqBrokerParameters

data class PipeSourceActiveMqBrokerParameters(val batchSize: Int? = null, val credentials: PipeMqBrokerAccessCredentialsProperties, val maximumBatchingWindowInSeconds: Int? = null, val queueName: String)

PipeSourceDynamoDbStreamParameters

data class PipeSourceDynamoDbStreamParameters(val batchSize: Int? = null, val deadLetterConfig: PipeDeadLetterConfig? = null, val maximumBatchingWindowInSeconds: Int? = null, val maximumRecordAgeInSeconds: Int? = null, val maximumRetryAttempts: Int? = null, val onPartialBatchItemFailure: PipeOnPartialBatchItemFailureStreams? = null, val parallelizationFactor: Int? = null, val startingPosition: PipeDynamoDbStreamStartPosition)

PipeSourceKinesisStreamParameters

data class PipeSourceKinesisStreamParameters(val batchSize: Int? = null, val deadLetterConfig: PipeDeadLetterConfig? = null, val maximumBatchingWindowInSeconds: Int? = null, val maximumRecordAgeInSeconds: Int? = null, val maximumRetryAttempts: Int? = null, val onPartialBatchItemFailure: PipeOnPartialBatchItemFailureStreams? = null, val parallelizationFactor: Int? = null, val startingPosition: PipeKinesisStreamStartPosition, val startingPositionTimestamp: String? = null)

PipeSourceManagedStreamingKafkaParameters

data class PipeSourceManagedStreamingKafkaParameters(val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: Either<PipeMskAccessCredentials0Properties, PipeMskAccessCredentials1Properties>? = null, val maximumBatchingWindowInSeconds: Int? = null, val startingPosition: PipeMskStartPosition? = null, val topicName: String)

PipeSourceParameters

data class PipeSourceParameters(val activeMqBrokerParameters: PipeSourceActiveMqBrokerParameters? = null, val dynamoDbStreamParameters: PipeSourceDynamoDbStreamParameters? = null, val filterCriteria: PipeFilterCriteria? = null, val kinesisStreamParameters: PipeSourceKinesisStreamParameters? = null, val managedStreamingKafkaParameters: PipeSourceManagedStreamingKafkaParameters? = null, val rabbitMqBrokerParameters: PipeSourceRabbitMqBrokerParameters? = null, val selfManagedKafkaParameters: PipeSourceSelfManagedKafkaParameters? = null, val sqsQueueParameters: PipeSourceSqsQueueParameters? = null)

PipeSourceRabbitMqBrokerParameters

data class PipeSourceRabbitMqBrokerParameters(val batchSize: Int? = null, val credentials: PipeMqBrokerAccessCredentialsProperties, val maximumBatchingWindowInSeconds: Int? = null, val queueName: String, val virtualHost: String? = null)

PipeSourceSelfManagedKafkaParameters

data class PipeSourceSelfManagedKafkaParameters(val additionalBootstrapServers: List<String>? = null, val batchSize: Int? = null, val consumerGroupId: String? = null, val credentials: Any? = null, val maximumBatchingWindowInSeconds: Int? = null, val serverRootCaCertificate: String? = null, val startingPosition: PipeSelfManagedKafkaStartPosition? = null, val topicName: String, val vpc: PipeSelfManagedKafkaAccessConfigurationVpc? = null)

PipeSourceSqsQueueParameters

data class PipeSourceSqsQueueParameters(val batchSize: Int? = null, val maximumBatchingWindowInSeconds: Int? = null)

PipeTag

data class PipeTag(val key: String, val value: String)

PipeTagMap

class PipeTagMap

PipeTargetBatchJobParameters

data class PipeTargetBatchJobParameters(val arrayProperties: PipeBatchArrayProperties? = null, val containerOverrides: PipeBatchContainerOverrides? = null, val dependsOn: List<PipeBatchJobDependency>? = null, val jobDefinition: String, val jobName: String, val parameters: PipeBatchParametersMap? = null, val retryStrategy: PipeBatchRetryStrategy? = null)

PipeTargetCloudWatchLogsParameters

data class PipeTargetCloudWatchLogsParameters(val logStreamName: String? = null, val timestamp: String? = null)

PipeTargetEcsTaskParameters

data class PipeTargetEcsTaskParameters(val capacityProviderStrategy: List<PipeCapacityProviderStrategyItem>? = null, val enableEcsManagedTags: Boolean? = null, val enableExecuteCommand: Boolean? = null, val group: String? = null, val launchType: PipeLaunchType? = null, val networkConfiguration: PipeNetworkConfiguration? = null, val overrides: PipeEcsTaskOverride? = null, val placementConstraints: List<PipePlacementConstraint>? = null, val placementStrategy: List<PipePlacementStrategy>? = null, val platformVersion: String? = null, val propagateTags: PipePropagateTags? = null, val referenceId: String? = null, val tags: List<PipeTag>? = null, val taskCount: Int? = null, val taskDefinitionArn: String)

PipeTargetEventBridgeEventBusParameters

data class PipeTargetEventBridgeEventBusParameters(val detailType: String? = null, val endpointId: String? = null, val resources: List<String>? = null, val source: String? = null, val time: String? = null)

PipeTargetHttpParameters

data class PipeTargetHttpParameters(val headerParameters: PipeHeaderParametersMap? = null, val pathParameterValues: List<String>? = null, val queryStringParameters: PipeQueryStringParametersMap? = null)

PipeTargetKinesisStreamParameters

data class PipeTargetKinesisStreamParameters(val partitionKey: String)

PipeTargetLambdaFunctionParameters

data class PipeTargetLambdaFunctionParameters(val invocationType: PipeTargetInvocationType? = null)

PipeTargetParameters

data class PipeTargetParameters(val batchJobParameters: PipeTargetBatchJobParameters? = null, val cloudWatchLogsParameters: PipeTargetCloudWatchLogsParameters? = null, val ecsTaskParameters: PipeTargetEcsTaskParameters? = null, val eventBridgeEventBusParameters: PipeTargetEventBridgeEventBusParameters? = null, val httpParameters: PipeTargetHttpParameters? = null, val inputTemplate: String? = null, val kinesisStreamParameters: PipeTargetKinesisStreamParameters? = null, val lambdaFunctionParameters: PipeTargetLambdaFunctionParameters? = null, val redshiftDataParameters: PipeTargetRedshiftDataParameters? = null, val sageMakerPipelineParameters: PipeTargetSageMakerPipelineParameters? = null, val sqsQueueParameters: PipeTargetSqsQueueParameters? = null, val stepFunctionStateMachineParameters: PipeTargetStateMachineParameters? = null)

PipeTargetRedshiftDataParameters

data class PipeTargetRedshiftDataParameters(val database: String, val dbUser: String? = null, val secretManagerArn: String? = null, val sqls: List<String>, val statementName: String? = null, val withEvent: Boolean? = null)

PipeTargetSageMakerPipelineParameters

data class PipeTargetSageMakerPipelineParameters(val pipelineParameterList: List<PipeSageMakerPipelineParameter>? = null)

PipeTargetSqsQueueParameters

data class PipeTargetSqsQueueParameters(val messageDeduplicationId: String? = null, val messageGroupId: String? = null)

PipeTargetStateMachineParameters

data class PipeTargetStateMachineParameters(val invocationType: PipeTargetInvocationType? = null)