import { AssignPublicIp, BatchJobDependencyType, BatchResourceRequirementType, DimensionValueType, DynamoDBStreamStartPosition, EcsEnvironmentFileType, EcsResourceRequirementType, EpochTimeUnit, IncludeExecutionDataOption, KinesisStreamStartPosition, LaunchType, LogLevel, MeasureValueType, MSKStartPosition, OnPartialBatchItemFailureStreams, PipeState, PipeTargetInvocationType, PlacementConstraintType, PlacementStrategyType, PropagateTags, RequestedPipeState, RequestedPipeStateDescribeResponse, S3OutputFormat, SelfManagedKafkaStartPosition, TimeFieldType, } from "./enums"; export interface AwsVpcConfiguration { Subnets: string[] | undefined; SecurityGroups?: string[] | undefined; AssignPublicIp?: AssignPublicIp | undefined; } export interface BatchArrayProperties { Size?: number | undefined; } export interface BatchEnvironmentVariable { Name?: string | undefined; Value?: string | undefined; } export interface BatchResourceRequirement { Type: BatchResourceRequirementType | undefined; Value: string | undefined; } export interface BatchContainerOverrides { Command?: string[] | undefined; Environment?: BatchEnvironmentVariable[] | undefined; InstanceType?: string | undefined; ResourceRequirements?: BatchResourceRequirement[] | undefined; } export interface BatchJobDependency { JobId?: string | undefined; Type?: BatchJobDependencyType | undefined; } export interface BatchRetryStrategy { Attempts?: number | undefined; } export interface CapacityProviderStrategyItem { capacityProvider: string | undefined; weight?: number | undefined; base?: number | undefined; } export interface CloudwatchLogsLogDestination { LogGroupArn?: string | undefined; } export interface CloudwatchLogsLogDestinationParameters { LogGroupArn: string | undefined; } export interface PipeEnrichmentHttpParameters { PathParameterValues?: string[] | undefined; HeaderParameters?: Record | undefined; QueryStringParameters?: Record | undefined; } export interface PipeEnrichmentParameters { InputTemplate?: string | undefined; HttpParameters?: PipeEnrichmentHttpParameters | undefined; } export interface FirehoseLogDestinationParameters { DeliveryStreamArn: string | undefined; } export interface S3LogDestinationParameters { BucketName: string | undefined; BucketOwner: string | undefined; OutputFormat?: S3OutputFormat | undefined; Prefix?: string | undefined; } export interface PipeLogConfigurationParameters { S3LogDestination?: S3LogDestinationParameters | undefined; FirehoseLogDestination?: FirehoseLogDestinationParameters | undefined; CloudwatchLogsLogDestination?: CloudwatchLogsLogDestinationParameters | undefined; Level: LogLevel | undefined; IncludeExecutionData?: IncludeExecutionDataOption[] | undefined; } export type MQBrokerAccessCredentials = | MQBrokerAccessCredentials.BasicAuthMember | MQBrokerAccessCredentials.$UnknownMember; export declare namespace MQBrokerAccessCredentials { interface BasicAuthMember { BasicAuth: string; $unknown?: never; } interface $UnknownMember { BasicAuth?: never; $unknown: [string, any]; } interface Visitor { BasicAuth: (value: string) => T; _: (name: string, value: any) => T; } } export interface PipeSourceActiveMQBrokerParameters { Credentials: MQBrokerAccessCredentials | undefined; QueueName: string | undefined; BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; } export interface DeadLetterConfig { Arn?: string | undefined; } export interface PipeSourceDynamoDBStreamParameters { BatchSize?: number | undefined; DeadLetterConfig?: DeadLetterConfig | undefined; OnPartialBatchItemFailure?: OnPartialBatchItemFailureStreams | undefined; MaximumBatchingWindowInSeconds?: number | undefined; MaximumRecordAgeInSeconds?: number | undefined; MaximumRetryAttempts?: number | undefined; ParallelizationFactor?: number | undefined; StartingPosition: DynamoDBStreamStartPosition | undefined; } export interface Filter { Pattern?: string | undefined; } export interface FilterCriteria { Filters?: Filter[] | undefined; } export interface PipeSourceKinesisStreamParameters { BatchSize?: number | undefined; DeadLetterConfig?: DeadLetterConfig | undefined; OnPartialBatchItemFailure?: OnPartialBatchItemFailureStreams | undefined; MaximumBatchingWindowInSeconds?: number | undefined; MaximumRecordAgeInSeconds?: number | undefined; MaximumRetryAttempts?: number | undefined; ParallelizationFactor?: number | undefined; StartingPosition: KinesisStreamStartPosition | undefined; StartingPositionTimestamp?: Date | undefined; } export type MSKAccessCredentials = | MSKAccessCredentials.ClientCertificateTlsAuthMember | MSKAccessCredentials.SaslScram512AuthMember | MSKAccessCredentials.$UnknownMember; export declare namespace MSKAccessCredentials { interface SaslScram512AuthMember { SaslScram512Auth: string; ClientCertificateTlsAuth?: never; $unknown?: never; } interface ClientCertificateTlsAuthMember { SaslScram512Auth?: never; ClientCertificateTlsAuth: string; $unknown?: never; } interface $UnknownMember { SaslScram512Auth?: never; ClientCertificateTlsAuth?: never; $unknown: [string, any]; } interface Visitor { SaslScram512Auth: (value: string) => T; ClientCertificateTlsAuth: (value: string) => T; _: (name: string, value: any) => T; } } export interface PipeSourceManagedStreamingKafkaParameters { TopicName: string | undefined; StartingPosition?: MSKStartPosition | undefined; BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; ConsumerGroupID?: string | undefined; Credentials?: MSKAccessCredentials | undefined; } export interface PipeSourceRabbitMQBrokerParameters { Credentials: MQBrokerAccessCredentials | undefined; QueueName: string | undefined; VirtualHost?: string | undefined; BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; } export type SelfManagedKafkaAccessConfigurationCredentials = | SelfManagedKafkaAccessConfigurationCredentials.BasicAuthMember | SelfManagedKafkaAccessConfigurationCredentials.ClientCertificateTlsAuthMember | SelfManagedKafkaAccessConfigurationCredentials.SaslScram256AuthMember | SelfManagedKafkaAccessConfigurationCredentials.SaslScram512AuthMember | SelfManagedKafkaAccessConfigurationCredentials.$UnknownMember; export declare namespace SelfManagedKafkaAccessConfigurationCredentials { interface BasicAuthMember { BasicAuth: string; SaslScram512Auth?: never; SaslScram256Auth?: never; ClientCertificateTlsAuth?: never; $unknown?: never; } interface SaslScram512AuthMember { BasicAuth?: never; SaslScram512Auth: string; SaslScram256Auth?: never; ClientCertificateTlsAuth?: never; $unknown?: never; } interface SaslScram256AuthMember { BasicAuth?: never; SaslScram512Auth?: never; SaslScram256Auth: string; ClientCertificateTlsAuth?: never; $unknown?: never; } interface ClientCertificateTlsAuthMember { BasicAuth?: never; SaslScram512Auth?: never; SaslScram256Auth?: never; ClientCertificateTlsAuth: string; $unknown?: never; } interface $UnknownMember { BasicAuth?: never; SaslScram512Auth?: never; SaslScram256Auth?: never; ClientCertificateTlsAuth?: never; $unknown: [string, any]; } interface Visitor { BasicAuth: (value: string) => T; SaslScram512Auth: (value: string) => T; SaslScram256Auth: (value: string) => T; ClientCertificateTlsAuth: (value: string) => T; _: (name: string, value: any) => T; } } export interface SelfManagedKafkaAccessConfigurationVpc { Subnets?: string[] | undefined; SecurityGroup?: string[] | undefined; } export interface PipeSourceSelfManagedKafkaParameters { TopicName: string | undefined; StartingPosition?: SelfManagedKafkaStartPosition | undefined; AdditionalBootstrapServers?: string[] | undefined; BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; ConsumerGroupID?: string | undefined; Credentials?: SelfManagedKafkaAccessConfigurationCredentials | undefined; ServerRootCaCertificate?: string | undefined; Vpc?: SelfManagedKafkaAccessConfigurationVpc | undefined; } export interface PipeSourceSqsQueueParameters { BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; } export interface PipeSourceParameters { FilterCriteria?: FilterCriteria | undefined; KinesisStreamParameters?: PipeSourceKinesisStreamParameters | undefined; DynamoDBStreamParameters?: PipeSourceDynamoDBStreamParameters | undefined; SqsQueueParameters?: PipeSourceSqsQueueParameters | undefined; ActiveMQBrokerParameters?: PipeSourceActiveMQBrokerParameters | undefined; RabbitMQBrokerParameters?: PipeSourceRabbitMQBrokerParameters | undefined; ManagedStreamingKafkaParameters?: PipeSourceManagedStreamingKafkaParameters | undefined; SelfManagedKafkaParameters?: PipeSourceSelfManagedKafkaParameters | undefined; } export interface PipeTargetBatchJobParameters { JobDefinition: string | undefined; JobName: string | undefined; ArrayProperties?: BatchArrayProperties | undefined; RetryStrategy?: BatchRetryStrategy | undefined; ContainerOverrides?: BatchContainerOverrides | undefined; DependsOn?: BatchJobDependency[] | undefined; Parameters?: Record | undefined; } export interface PipeTargetCloudWatchLogsParameters { LogStreamName?: string | undefined; Timestamp?: string | undefined; } export interface NetworkConfiguration { awsvpcConfiguration?: AwsVpcConfiguration | undefined; } export interface EcsEnvironmentVariable { name?: string | undefined; value?: string | undefined; } export interface EcsEnvironmentFile { type: EcsEnvironmentFileType | undefined; value: string | undefined; } export interface EcsResourceRequirement { type: EcsResourceRequirementType | undefined; value: string | undefined; } export interface EcsContainerOverride { Command?: string[] | undefined; Cpu?: number | undefined; Environment?: EcsEnvironmentVariable[] | undefined; EnvironmentFiles?: EcsEnvironmentFile[] | undefined; Memory?: number | undefined; MemoryReservation?: number | undefined; Name?: string | undefined; ResourceRequirements?: EcsResourceRequirement[] | undefined; } export interface EcsEphemeralStorage { sizeInGiB: number | undefined; } export interface EcsInferenceAcceleratorOverride { deviceName?: string | undefined; deviceType?: string | undefined; } export interface EcsTaskOverride { ContainerOverrides?: EcsContainerOverride[] | undefined; Cpu?: string | undefined; EphemeralStorage?: EcsEphemeralStorage | undefined; ExecutionRoleArn?: string | undefined; InferenceAcceleratorOverrides?: EcsInferenceAcceleratorOverride[] | undefined; Memory?: string | undefined; TaskRoleArn?: string | undefined; } export interface PlacementConstraint { type?: PlacementConstraintType | undefined; expression?: string | undefined; } export interface PlacementStrategy { type?: PlacementStrategyType | undefined; field?: string | undefined; } export interface Tag { Key: string | undefined; Value: string | undefined; } export interface PipeTargetEcsTaskParameters { TaskDefinitionArn: string | undefined; TaskCount?: number | undefined; LaunchType?: LaunchType | undefined; NetworkConfiguration?: NetworkConfiguration | undefined; PlatformVersion?: string | undefined; Group?: string | undefined; CapacityProviderStrategy?: CapacityProviderStrategyItem[] | undefined; EnableECSManagedTags?: boolean | undefined; EnableExecuteCommand?: boolean | undefined; PlacementConstraints?: PlacementConstraint[] | undefined; PlacementStrategy?: PlacementStrategy[] | undefined; PropagateTags?: PropagateTags | undefined; ReferenceId?: string | undefined; Overrides?: EcsTaskOverride | undefined; Tags?: Tag[] | undefined; } export interface PipeTargetEventBridgeEventBusParameters { EndpointId?: string | undefined; DetailType?: string | undefined; Source?: string | undefined; Resources?: string[] | undefined; Time?: string | undefined; } export interface PipeTargetHttpParameters { PathParameterValues?: string[] | undefined; HeaderParameters?: Record | undefined; QueryStringParameters?: Record | undefined; } export interface PipeTargetKinesisStreamParameters { PartitionKey: string | undefined; } export interface PipeTargetLambdaFunctionParameters { InvocationType?: PipeTargetInvocationType | undefined; } export interface PipeTargetRedshiftDataParameters { SecretManagerArn?: string | undefined; Database: string | undefined; DbUser?: string | undefined; StatementName?: string | undefined; WithEvent?: boolean | undefined; Sqls: string[] | undefined; } export interface SageMakerPipelineParameter { Name: string | undefined; Value: string | undefined; } export interface PipeTargetSageMakerPipelineParameters { PipelineParameterList?: SageMakerPipelineParameter[] | undefined; } export interface PipeTargetSqsQueueParameters { MessageGroupId?: string | undefined; MessageDeduplicationId?: string | undefined; } export interface PipeTargetStateMachineParameters { InvocationType?: PipeTargetInvocationType | undefined; } export interface DimensionMapping { DimensionValue: string | undefined; DimensionValueType: DimensionValueType | undefined; DimensionName: string | undefined; } export interface MultiMeasureAttributeMapping { MeasureValue: string | undefined; MeasureValueType: MeasureValueType | undefined; MultiMeasureAttributeName: string | undefined; } export interface MultiMeasureMapping { MultiMeasureName: string | undefined; MultiMeasureAttributeMappings: MultiMeasureAttributeMapping[] | undefined; } export interface SingleMeasureMapping { MeasureValue: string | undefined; MeasureValueType: MeasureValueType | undefined; MeasureName: string | undefined; } export interface PipeTargetTimestreamParameters { TimeValue: string | undefined; EpochTimeUnit?: EpochTimeUnit | undefined; TimeFieldType?: TimeFieldType | undefined; TimestampFormat?: string | undefined; VersionValue: string | undefined; DimensionMappings: DimensionMapping[] | undefined; SingleMeasureMappings?: SingleMeasureMapping[] | undefined; MultiMeasureMappings?: MultiMeasureMapping[] | undefined; } export interface PipeTargetParameters { InputTemplate?: string | undefined; LambdaFunctionParameters?: PipeTargetLambdaFunctionParameters | undefined; StepFunctionStateMachineParameters?: PipeTargetStateMachineParameters | undefined; KinesisStreamParameters?: PipeTargetKinesisStreamParameters | undefined; EcsTaskParameters?: PipeTargetEcsTaskParameters | undefined; BatchJobParameters?: PipeTargetBatchJobParameters | undefined; SqsQueueParameters?: PipeTargetSqsQueueParameters | undefined; HttpParameters?: PipeTargetHttpParameters | undefined; RedshiftDataParameters?: PipeTargetRedshiftDataParameters | undefined; SageMakerPipelineParameters?: PipeTargetSageMakerPipelineParameters | undefined; EventBridgeEventBusParameters?: PipeTargetEventBridgeEventBusParameters | undefined; CloudWatchLogsParameters?: PipeTargetCloudWatchLogsParameters | undefined; TimestreamParameters?: PipeTargetTimestreamParameters | undefined; } export interface CreatePipeRequest { Name: string | undefined; Description?: string | undefined; DesiredState?: RequestedPipeState | undefined; Source: string | undefined; SourceParameters?: PipeSourceParameters | undefined; Enrichment?: string | undefined; EnrichmentParameters?: PipeEnrichmentParameters | undefined; Target: string | undefined; TargetParameters?: PipeTargetParameters | undefined; RoleArn: string | undefined; Tags?: Record | undefined; LogConfiguration?: PipeLogConfigurationParameters | undefined; KmsKeyIdentifier?: string | undefined; } export interface CreatePipeResponse { Arn?: string | undefined; Name?: string | undefined; DesiredState?: RequestedPipeState | undefined; CurrentState?: PipeState | undefined; CreationTime?: Date | undefined; LastModifiedTime?: Date | undefined; } export interface ValidationExceptionField { name: string | undefined; message: string | undefined; } export interface DeletePipeRequest { Name: string | undefined; } export interface DeletePipeResponse { Arn?: string | undefined; Name?: string | undefined; DesiredState?: RequestedPipeStateDescribeResponse | undefined; CurrentState?: PipeState | undefined; CreationTime?: Date | undefined; LastModifiedTime?: Date | undefined; } export interface DescribePipeRequest { Name: string | undefined; } export interface FirehoseLogDestination { DeliveryStreamArn?: string | undefined; } export interface S3LogDestination { BucketName?: string | undefined; Prefix?: string | undefined; BucketOwner?: string | undefined; OutputFormat?: S3OutputFormat | undefined; } export interface PipeLogConfiguration { S3LogDestination?: S3LogDestination | undefined; FirehoseLogDestination?: FirehoseLogDestination | undefined; CloudwatchLogsLogDestination?: CloudwatchLogsLogDestination | undefined; Level?: LogLevel | undefined; IncludeExecutionData?: IncludeExecutionDataOption[] | undefined; } export interface DescribePipeResponse { Arn?: string | undefined; Name?: string | undefined; Description?: string | undefined; DesiredState?: RequestedPipeStateDescribeResponse | undefined; CurrentState?: PipeState | undefined; StateReason?: string | undefined; Source?: string | undefined; SourceParameters?: PipeSourceParameters | undefined; Enrichment?: string | undefined; EnrichmentParameters?: PipeEnrichmentParameters | undefined; Target?: string | undefined; TargetParameters?: PipeTargetParameters | undefined; RoleArn?: string | undefined; Tags?: Record | undefined; CreationTime?: Date | undefined; LastModifiedTime?: Date | undefined; LogConfiguration?: PipeLogConfiguration | undefined; KmsKeyIdentifier?: string | undefined; } export interface ListPipesRequest { NamePrefix?: string | undefined; DesiredState?: RequestedPipeState | undefined; CurrentState?: PipeState | undefined; SourcePrefix?: string | undefined; TargetPrefix?: string | undefined; NextToken?: string | undefined; Limit?: number | undefined; } export interface Pipe { Name?: string | undefined; Arn?: string | undefined; DesiredState?: RequestedPipeState | undefined; CurrentState?: PipeState | undefined; StateReason?: string | undefined; CreationTime?: Date | undefined; LastModifiedTime?: Date | undefined; Source?: string | undefined; Target?: string | undefined; Enrichment?: string | undefined; } export interface ListPipesResponse { Pipes?: Pipe[] | undefined; NextToken?: string | undefined; } export interface ListTagsForResourceRequest { resourceArn: string | undefined; } export interface ListTagsForResourceResponse { tags?: Record | undefined; } export interface StartPipeRequest { Name: string | undefined; } export interface StartPipeResponse { Arn?: string | undefined; Name?: string | undefined; DesiredState?: RequestedPipeState | undefined; CurrentState?: PipeState | undefined; CreationTime?: Date | undefined; LastModifiedTime?: Date | undefined; } export interface StopPipeRequest { Name: string | undefined; } export interface StopPipeResponse { Arn?: string | undefined; Name?: string | undefined; DesiredState?: RequestedPipeState | undefined; CurrentState?: PipeState | undefined; CreationTime?: Date | undefined; LastModifiedTime?: Date | undefined; } export interface UpdatePipeSourceActiveMQBrokerParameters { Credentials: MQBrokerAccessCredentials | undefined; BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; } export interface UpdatePipeSourceDynamoDBStreamParameters { BatchSize?: number | undefined; DeadLetterConfig?: DeadLetterConfig | undefined; OnPartialBatchItemFailure?: OnPartialBatchItemFailureStreams | undefined; MaximumBatchingWindowInSeconds?: number | undefined; MaximumRecordAgeInSeconds?: number | undefined; MaximumRetryAttempts?: number | undefined; ParallelizationFactor?: number | undefined; } export interface UpdatePipeSourceKinesisStreamParameters { BatchSize?: number | undefined; DeadLetterConfig?: DeadLetterConfig | undefined; OnPartialBatchItemFailure?: OnPartialBatchItemFailureStreams | undefined; MaximumBatchingWindowInSeconds?: number | undefined; MaximumRecordAgeInSeconds?: number | undefined; MaximumRetryAttempts?: number | undefined; ParallelizationFactor?: number | undefined; } export interface UpdatePipeSourceManagedStreamingKafkaParameters { BatchSize?: number | undefined; Credentials?: MSKAccessCredentials | undefined; MaximumBatchingWindowInSeconds?: number | undefined; } export interface UpdatePipeSourceRabbitMQBrokerParameters { Credentials: MQBrokerAccessCredentials | undefined; BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; } export interface UpdatePipeSourceSelfManagedKafkaParameters { BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; Credentials?: SelfManagedKafkaAccessConfigurationCredentials | undefined; ServerRootCaCertificate?: string | undefined; Vpc?: SelfManagedKafkaAccessConfigurationVpc | undefined; } export interface UpdatePipeSourceSqsQueueParameters { BatchSize?: number | undefined; MaximumBatchingWindowInSeconds?: number | undefined; } export interface UpdatePipeSourceParameters { FilterCriteria?: FilterCriteria | undefined; KinesisStreamParameters?: UpdatePipeSourceKinesisStreamParameters | undefined; DynamoDBStreamParameters?: UpdatePipeSourceDynamoDBStreamParameters | undefined; SqsQueueParameters?: UpdatePipeSourceSqsQueueParameters | undefined; ActiveMQBrokerParameters?: UpdatePipeSourceActiveMQBrokerParameters | undefined; RabbitMQBrokerParameters?: UpdatePipeSourceRabbitMQBrokerParameters | undefined; ManagedStreamingKafkaParameters?: UpdatePipeSourceManagedStreamingKafkaParameters | undefined; SelfManagedKafkaParameters?: UpdatePipeSourceSelfManagedKafkaParameters | undefined; } export interface UpdatePipeRequest { Name: string | undefined; Description?: string | undefined; DesiredState?: RequestedPipeState | undefined; SourceParameters?: UpdatePipeSourceParameters | undefined; Enrichment?: string | undefined; EnrichmentParameters?: PipeEnrichmentParameters | undefined; Target?: string | undefined; TargetParameters?: PipeTargetParameters | undefined; RoleArn: string | undefined; LogConfiguration?: PipeLogConfigurationParameters | undefined; KmsKeyIdentifier?: string | undefined; } export interface UpdatePipeResponse { Arn?: string | undefined; Name?: string | undefined; DesiredState?: RequestedPipeState | undefined; CurrentState?: PipeState | undefined; CreationTime?: Date | undefined; LastModifiedTime?: Date | undefined; } export interface TagResourceRequest { resourceArn: string | undefined; tags: Record | undefined; } export interface TagResourceResponse {} export interface UntagResourceRequest { resourceArn: string | undefined; tagKeys: string[] | undefined; } export interface UntagResourceResponse {}