v1alpha1

type AWSVPCConfiguration struct {
	AssignPublicIP *string   `json:"assignPublicIP,omitempty"`
	SecurityGroups []*string `json:"securityGroups,omitempty"`
	Subnets        []*string `json:"subnets,omitempty"`
}

type AssignPublicIP string

type BatchArrayProperties struct {
	Size *int64 `json:"size,omitempty"`
}

type BatchContainerOverrides struct {
	Command              []*string                   `json:"command,omitempty"`
	Environment          []*BatchEnvironmentVariable `json:"environment,omitempty"`
	InstanceType         *string                     `json:"instanceType,omitempty"`
	ResourceRequirements []*BatchResourceRequirement `json:"resourceRequirements,omitempty"`
}

type BatchEnvironmentVariable struct {
	Name  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
}

type BatchJobDependency struct {
	JobID *string `json:"jobID,omitempty"`
	Type  *string `json:"type_,omitempty"`
}

type BatchJobDependencyType string

type BatchResourceRequirement struct {
	Type  *string `json:"type_,omitempty"`
	Value *string `json:"value,omitempty"`
}

type BatchResourceRequirementType string

type BatchRetryStrategy struct {
	Attempts *int64 `json:"attempts,omitempty"`
}

type CapacityProviderStrategyItem struct {
	Base             *int64  `json:"base,omitempty"`
	CapacityProvider *string `json:"capacityProvider,omitempty"`
	Weight           *int64  `json:"weight,omitempty"`
}

type DeadLetterConfig struct {
	ARN *string `json:"arn,omitempty"`
}

type DynamoDBStreamStartPosition string

type ECSContainerOverride struct {
	Command              []*string                 `json:"command,omitempty"`
	CPU                  *int64                    `json:"cpu,omitempty"`
	Environment          []*ECSEnvironmentVariable `json:"environment,omitempty"`
	EnvironmentFiles     []*ECSEnvironmentFile     `json:"environmentFiles,omitempty"`
	Memory               *int64                    `json:"memory,omitempty"`
	MemoryReservation    *int64                    `json:"memoryReservation,omitempty"`
	Name                 *string                   `json:"name,omitempty"`
	ResourceRequirements []*ECSResourceRequirement `json:"resourceRequirements,omitempty"`
}

type ECSEnvironmentFile struct {
	Type  *string `json:"type_,omitempty"`
	Value *string `json:"value,omitempty"`
}

type ECSEnvironmentFileType string

type ECSEnvironmentVariable struct {
	Name  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
}

type ECSEphemeralStorage struct {
	SizeInGiB *int64 `json:"sizeInGiB,omitempty"`
}

type ECSInferenceAcceleratorOverride struct {
	DeviceName *string `json:"deviceName,omitempty"`
	DeviceType *string `json:"deviceType,omitempty"`
}

type ECSResourceRequirement struct {
	Type  *string `json:"type_,omitempty"`
	Value *string `json:"value,omitempty"`
}

type ECSResourceRequirementType string

type ECSTaskOverride struct {
	ContainerOverrides []*ECSContainerOverride `json:"containerOverrides,omitempty"`
	CPU                *string                 `json:"cpu,omitempty"`
	// The amount of ephemeral storage to allocate for the task. This parameter
	// is used to expand the total amount of ephemeral storage available, beyond
	// the default amount, for tasks hosted on Fargate. For more information, see
	// Fargate task storage (https://docs.aws.amazon.com/AmazonECS/latest/userguide/using_data_volumes.html)
	// in the Amazon ECS User Guide for Fargate.
	//
	// This parameter is only supported for tasks hosted on Fargate using Linux
	// platform version 1.4.0 or later. This parameter is not supported for Windows
	// containers on Fargate.
	EphemeralStorage              *ECSEphemeralStorage               `json:"ephemeralStorage,omitempty"`
	ExecutionRoleARN              *string                            `json:"executionRoleARN,omitempty"`
	InferenceAcceleratorOverrides []*ECSInferenceAcceleratorOverride `json:"inferenceAcceleratorOverrides,omitempty"`
	Memory                        *string                            `json:"memory,omitempty"`
	TaskRoleARN                   *string                            `json:"taskRoleARN,omitempty"`
}

type Filter struct {
	Pattern *string `json:"pattern,omitempty"`
}

type FilterCriteria struct {
	Filters []*Filter `json:"filters,omitempty"`
}

type KinesisStreamStartPosition string

type LaunchType string

type MQBrokerAccessCredentials struct {
	// // Optional SecretManager ARN which stores the database credentials
	BasicAuth *string `json:"basicAuth,omitempty"`
}

type MSKAccessCredentials struct {
	// // Optional SecretManager ARN which stores the database credentials
	ClientCertificateTLSAuth *string `json:"clientCertificateTLSAuth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	SASLSCRAM512Auth *string `json:"saslSCRAM512Auth,omitempty"`
}

type MSKStartPosition string

type NetworkConfiguration struct {
	// This structure specifies the VPC subnets and security groups for the task,
	// and whether a public IP address is to be used. This structure is relevant
	// only for ECS tasks that use the awsvpc network mode.
	AWSVPCConfiguration *AWSVPCConfiguration `json:"awsVPCConfiguration,omitempty"`
}

type OnPartialBatchItemFailureStreams string

type Pipe struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              PipeSpec   `json:"spec,omitempty"`
	Status            PipeStatus `json:"status,omitempty"`
}

type PipeEnrichmentHTTPParameters struct {
	HeaderParameters      map[string]*string `json:"headerParameters,omitempty"`
	PathParameterValues   []*string          `json:"pathParameterValues,omitempty"`
	QueryStringParameters map[string]*string `json:"queryStringParameters,omitempty"`
}

type PipeEnrichmentParameters struct {
	// These are custom parameter to be used when the target is an API Gateway REST
	// APIs or EventBridge ApiDestinations. In the latter case, these are merged
	// with any InvocationParameters specified on the Connection, with any values
	// from the Connection taking precedence.
	HTTPParameters *PipeEnrichmentHTTPParameters `json:"httpParameters,omitempty"`
	InputTemplate  *string                       `json:"inputTemplate,omitempty"`
}

type PipeList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Pipe `json:"items"`
}

type PipeSourceActiveMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
	QueueName                      *string                    `json:"queueName,omitempty"`
}

type PipeSourceDynamoDBStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
	StartingPosition               *string           `json:"startingPosition,omitempty"`
}

type PipeSourceKinesisStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
	StartingPosition               *string           `json:"startingPosition,omitempty"`
	StartingPositionTimestamp      *metav1.Time      `json:"startingPositionTimestamp,omitempty"`
}

type PipeSourceManagedStreamingKafkaParameters struct {
	BatchSize       *int64  `json:"batchSize,omitempty"`
	ConsumerGroupID *string `json:"consumerGroupID,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *MSKAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                `json:"maximumBatchingWindowInSeconds,omitempty"`
	StartingPosition               *string               `json:"startingPosition,omitempty"`
	TopicName                      *string               `json:"topicName,omitempty"`
}

type PipeSourceParameters struct {
	// The parameters for using an Active MQ broker as a source.
	ActiveMQBrokerParameters *PipeSourceActiveMQBrokerParameters `json:"activeMQBrokerParameters,omitempty"`
	// The parameters for using a DynamoDB stream as a source.
	DynamoDBStreamParameters *PipeSourceDynamoDBStreamParameters `json:"dynamoDBStreamParameters,omitempty"`
	// The collection of event patterns used to filter events. For more information,
	// see Events and Event Patterns (https://docs.aws.amazon.com/eventbridge/latest/userguide/eventbridge-and-event-patterns.html)
	// in the Amazon EventBridge User Guide.
	FilterCriteria *FilterCriteria `json:"filterCriteria,omitempty"`
	// The parameters for using a Kinesis stream as a source.
	KinesisStreamParameters *PipeSourceKinesisStreamParameters `json:"kinesisStreamParameters,omitempty"`
	// The parameters for using an MSK stream as a source.
	ManagedStreamingKafkaParameters *PipeSourceManagedStreamingKafkaParameters `json:"managedStreamingKafkaParameters,omitempty"`
	// The parameters for using a Rabbit MQ broker as a source.
	RabbitMQBrokerParameters *PipeSourceRabbitMQBrokerParameters `json:"rabbitMQBrokerParameters,omitempty"`
	// The parameters for using a self-managed Apache Kafka stream as a source.
	SelfManagedKafkaParameters *PipeSourceSelfManagedKafkaParameters `json:"selfManagedKafkaParameters,omitempty"`
	// The parameters for using a Amazon SQS stream as a source.
	SQSQueueParameters *PipeSourceSQSQueueParameters `json:"sqsQueueParameters,omitempty"`
}

type PipeSourceRabbitMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
	QueueName                      *string                    `json:"queueName,omitempty"`
	VirtualHost                    *string                    `json:"virtualHost,omitempty"`
}

type PipeSourceSQSQueueParameters struct {
	BatchSize                      *int64 `json:"batchSize,omitempty"`
	MaximumBatchingWindowInSeconds *int64 `json:"maximumBatchingWindowInSeconds,omitempty"`
}

type PipeSourceSelfManagedKafkaParameters struct {
	AdditionalBootstrapServers []*string `json:"additionalBootstrapServers,omitempty"`
	BatchSize                  *int64    `json:"batchSize,omitempty"`
	ConsumerGroupID            *string   `json:"consumerGroupID,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *SelfManagedKafkaAccessConfigurationCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                                          `json:"maximumBatchingWindowInSeconds,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	ServerRootCaCertificate *string `json:"serverRootCaCertificate,omitempty"`
	StartingPosition        *string `json:"startingPosition,omitempty"`
	TopicName               *string `json:"topicName,omitempty"`
	// This structure specifies the VPC subnets and security groups for the stream,
	// and whether a public IP address is to be used.
	VPC *SelfManagedKafkaAccessConfigurationVPC `json:"vpc,omitempty"`
}

type PipeSpec struct {

	// A description of the pipe.
	Description *string `json:"description,omitempty"`
	// The state the pipe should be in.
	DesiredState *string `json:"desiredState,omitempty"`
	// The ARN of the enrichment resource.
	Enrichment *string `json:"enrichment,omitempty"`
	// The parameters required to set up enrichment on your pipe.
	EnrichmentParameters *PipeEnrichmentParameters `json:"enrichmentParameters,omitempty"`
	// The name of the pipe.
	// +kubebuilder:validation:Required
	Name *string `json:"name"`
	// The ARN of the role that allows the pipe to send data to the target.
	// +kubebuilder:validation:Required
	RoleARN *string `json:"roleARN"`
	// The ARN of the source resource.
	// +kubebuilder:validation:Required
	Source *string `json:"source"`
	// The parameters required to set up a source for your pipe.
	SourceParameters *PipeSourceParameters `json:"sourceParameters,omitempty"`
	// The list of key-value pairs to associate with the pipe.
	Tags map[string]*string `json:"tags,omitempty"`
	// The ARN of the target resource.
	// +kubebuilder:validation:Required
	Target *string `json:"target"`
	// The parameters required to set up a target for your pipe.
	TargetParameters *PipeTargetParameters `json:"targetParameters,omitempty"`
}

type PipeState string

type PipeStatus struct {
	// All CRs managed by ACK have a common `Status.ACKResourceMetadata` member
	// that is used to contain resource sync state, account ownership,
	// constructed ARN for the resource
	// +kubebuilder:validation:Optional
	ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"`
	// All CRS managed by ACK have a common `Status.Conditions` member that
	// contains a collection of `ackv1alpha1.Condition` objects that describe
	// the various terminal states of the CR and its backend AWS service API
	// resource
	// +kubebuilder:validation:Optional
	Conditions []*ackv1alpha1.Condition `json:"conditions"`
	// The time the pipe was created.
	// +kubebuilder:validation:Optional
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// The state the pipe is in.
	// +kubebuilder:validation:Optional
	CurrentState *string `json:"currentState,omitempty"`
	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	// +kubebuilder:validation:Optional
	LastModifiedTime *metav1.Time `json:"lastModifiedTime,omitempty"`
	// The reason the pipe is in its current state.
	// +kubebuilder:validation:Optional
	StateReason *string `json:"stateReason,omitempty"`
}

type PipeTargetBatchJobParameters struct {
	// The array properties for the submitted job, such as the size of the array.
	// The array size can be between 2 and 10,000. If you specify array properties
	// for a job, it becomes an array job. This parameter is used only if the target
	// is an Batch job.
	ArrayProperties *BatchArrayProperties `json:"arrayProperties,omitempty"`
	// The overrides that are sent to a container.
	ContainerOverrides *BatchContainerOverrides `json:"containerOverrides,omitempty"`
	DependsOn          []*BatchJobDependency    `json:"dependsOn,omitempty"`
	JobDefinition      *string                  `json:"jobDefinition,omitempty"`
	JobName            *string                  `json:"jobName,omitempty"`
	Parameters         map[string]*string       `json:"parameters,omitempty"`
	// The retry strategy that's associated with a job. For more information, see
	// Automated job retries (https://docs.aws.amazon.com/batch/latest/userguide/job_retries.html)
	// in the Batch User Guide.
	RetryStrategy *BatchRetryStrategy `json:"retryStrategy,omitempty"`
}

type PipeTargetCloudWatchLogsParameters struct {
	LogStreamName *string `json:"logStreamName,omitempty"`
	Timestamp     *string `json:"timestamp,omitempty"`
}

type PipeTargetECSTaskParameters struct {
	CapacityProviderStrategy []*CapacityProviderStrategyItem `json:"capacityProviderStrategy,omitempty"`
	EnableECSManagedTags     *bool                           `json:"enableECSManagedTags,omitempty"`
	EnableExecuteCommand     *bool                           `json:"enableExecuteCommand,omitempty"`
	Group                    *string                         `json:"group,omitempty"`
	LaunchType               *string                         `json:"launchType,omitempty"`
	// This structure specifies the network configuration for an Amazon ECS task.
	NetworkConfiguration *NetworkConfiguration `json:"networkConfiguration,omitempty"`
	// The overrides that are associated with a task.
	Overrides            *ECSTaskOverride       `json:"overrides,omitempty"`
	PlacementConstraints []*PlacementConstraint `json:"placementConstraints,omitempty"`
	PlacementStrategy    []*PlacementStrategy   `json:"placementStrategy,omitempty"`
	PlatformVersion      *string                `json:"platformVersion,omitempty"`
	PropagateTags        *string                `json:"propagateTags,omitempty"`
	ReferenceID          *string                `json:"referenceID,omitempty"`
	Tags                 []*Tag                 `json:"tags,omitempty"`
	TaskCount            *int64                 `json:"taskCount,omitempty"`
	TaskDefinitionARN    *string                `json:"taskDefinitionARN,omitempty"`
}

type PipeTargetEventBridgeEventBusParameters struct {
	DetailType *string   `json:"detailType,omitempty"`
	EndpointID *string   `json:"endpointID,omitempty"`
	Resources  []*string `json:"resources,omitempty"`
	Source     *string   `json:"source,omitempty"`
	Time       *string   `json:"time,omitempty"`
}

type PipeTargetHTTPParameters struct {
	HeaderParameters      map[string]*string `json:"headerParameters,omitempty"`
	PathParameterValues   []*string          `json:"pathParameterValues,omitempty"`
	QueryStringParameters map[string]*string `json:"queryStringParameters,omitempty"`
}

type PipeTargetInvocationType string

type PipeTargetKinesisStreamParameters struct {
	PartitionKey *string `json:"partitionKey,omitempty"`
}

type PipeTargetLambdaFunctionParameters struct {
	InvocationType *string `json:"invocationType,omitempty"`
}

type PipeTargetParameters struct {
	// The parameters for using an Batch job as a target.
	BatchJobParameters *PipeTargetBatchJobParameters `json:"batchJobParameters,omitempty"`
	// The parameters for using an CloudWatch Logs log stream as a target.
	CloudWatchLogsParameters *PipeTargetCloudWatchLogsParameters `json:"cloudWatchLogsParameters,omitempty"`
	// The parameters for using an Amazon ECS task as a target.
	ECSTaskParameters *PipeTargetECSTaskParameters `json:"ecsTaskParameters,omitempty"`
	// The parameters for using an EventBridge event bus as a target.
	EventBridgeEventBusParameters *PipeTargetEventBridgeEventBusParameters `json:"eventBridgeEventBusParameters,omitempty"`
	// These are custom parameter to be used when the target is an API Gateway REST
	// APIs or EventBridge ApiDestinations.
	HTTPParameters *PipeTargetHTTPParameters `json:"httpParameters,omitempty"`
	InputTemplate  *string                   `json:"inputTemplate,omitempty"`
	// The parameters for using a Kinesis stream as a source.
	KinesisStreamParameters *PipeTargetKinesisStreamParameters `json:"kinesisStreamParameters,omitempty"`
	// The parameters for using a Lambda function as a target.
	LambdaFunctionParameters *PipeTargetLambdaFunctionParameters `json:"lambdaFunctionParameters,omitempty"`
	// These are custom parameters to be used when the target is a Amazon Redshift
	// cluster to invoke the Amazon Redshift Data API ExecuteStatement.
	RedshiftDataParameters *PipeTargetRedshiftDataParameters `json:"redshiftDataParameters,omitempty"`
	// The parameters for using a SageMaker pipeline as a target.
	SageMakerPipelineParameters *PipeTargetSageMakerPipelineParameters `json:"sageMakerPipelineParameters,omitempty"`
	// The parameters for using a Amazon SQS stream as a source.
	SQSQueueParameters *PipeTargetSQSQueueParameters `json:"sqsQueueParameters,omitempty"`
	// The parameters for using a Step Functions state machine as a target.
	StepFunctionStateMachineParameters *PipeTargetStateMachineParameters `json:"stepFunctionStateMachineParameters,omitempty"`
}

type PipeTargetRedshiftDataParameters struct {
	// // Redshift Database
	Database *string `json:"database,omitempty"`
	// // Database user name
	DBUser *string `json:"dbUser,omitempty"`
	// // For targets, can either specify an ARN or a jsonpath pointing to the ARN.
	SecretManagerARN *string `json:"secretManagerARN,omitempty"`
	// // A list of SQLs.
	SQLs []*string `json:"sqls,omitempty"`
	// // A name for Redshift DataAPI statement which can be used as filter of //
	// ListStatement.
	StatementName *string `json:"statementName,omitempty"`
	WithEvent     *bool   `json:"withEvent,omitempty"`
}

type PipeTargetSQSQueueParameters struct {
	MessageDeduplicationID *string `json:"messageDeduplicationID,omitempty"`
	MessageGroupID         *string `json:"messageGroupID,omitempty"`
}

type PipeTargetSageMakerPipelineParameters struct {
	PipelineParameterList []*SageMakerPipelineParameter `json:"pipelineParameterList,omitempty"`
}

type PipeTargetStateMachineParameters struct {
	InvocationType *string `json:"invocationType,omitempty"`
}

type Pipe_SDK struct {
	ARN              *string      `json:"arn,omitempty"`
	CreationTime     *metav1.Time `json:"creationTime,omitempty"`
	CurrentState     *string      `json:"currentState,omitempty"`
	DesiredState     *string      `json:"desiredState,omitempty"`
	Enrichment       *string      `json:"enrichment,omitempty"`
	LastModifiedTime *metav1.Time `json:"lastModifiedTime,omitempty"`
	Name             *string      `json:"name,omitempty"`
	Source           *string      `json:"source,omitempty"`
	StateReason      *string      `json:"stateReason,omitempty"`
	Target           *string      `json:"target,omitempty"`
}

type PlacementConstraint struct {
	Expression *string `json:"expression,omitempty"`
	Type       *string `json:"type_,omitempty"`
}

type PlacementConstraintType string

type PlacementStrategy struct {
	Field *string `json:"field,omitempty"`
	Type  *string `json:"type_,omitempty"`
}

type PlacementStrategyType string

type PropagateTags string

type RequestedPipeState string

type RequestedPipeStateDescribeResponse string

type SageMakerPipelineParameter struct {
	Name  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
}

type SelfManagedKafkaAccessConfigurationCredentials struct {
	// // Optional SecretManager ARN which stores the database credentials
	BasicAuth *string `json:"basicAuth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	ClientCertificateTLSAuth *string `json:"clientCertificateTLSAuth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	SASLSCRAM256Auth *string `json:"saslSCRAM256Auth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	SASLSCRAM512Auth *string `json:"saslSCRAM512Auth,omitempty"`
}

type SelfManagedKafkaAccessConfigurationVPC struct {
	// List of SecurityGroupId.
	SecurityGroup []*string `json:"securityGroup,omitempty"`
	// List of SubnetId.
	Subnets []*string `json:"subnets,omitempty"`
}

type SelfManagedKafkaStartPosition string

type Tag struct {
	Key   *string `json:"key,omitempty"`
	Value *string `json:"value,omitempty"`
}

type UpdatePipeSourceActiveMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
}

type UpdatePipeSourceDynamoDBStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
}

type UpdatePipeSourceKinesisStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
}

type UpdatePipeSourceManagedStreamingKafkaParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *MSKAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                `json:"maximumBatchingWindowInSeconds,omitempty"`
}

type UpdatePipeSourceParameters struct {
	// The parameters for using an Active MQ broker as a source.
	ActiveMQBrokerParameters *UpdatePipeSourceActiveMQBrokerParameters `json:"activeMQBrokerParameters,omitempty"`
	// The parameters for using a DynamoDB stream as a source.
	DynamoDBStreamParameters *UpdatePipeSourceDynamoDBStreamParameters `json:"dynamoDBStreamParameters,omitempty"`
	// The collection of event patterns used to filter events. For more information,
	// see Events and Event Patterns (https://docs.aws.amazon.com/eventbridge/latest/userguide/eventbridge-and-event-patterns.html)
	// in the Amazon EventBridge User Guide.
	FilterCriteria *FilterCriteria `json:"filterCriteria,omitempty"`
	// The parameters for using a Kinesis stream as a source.
	KinesisStreamParameters *UpdatePipeSourceKinesisStreamParameters `json:"kinesisStreamParameters,omitempty"`
	// The parameters for using an MSK stream as a source.
	ManagedStreamingKafkaParameters *UpdatePipeSourceManagedStreamingKafkaParameters `json:"managedStreamingKafkaParameters,omitempty"`
	// The parameters for using a Rabbit MQ broker as a source.
	RabbitMQBrokerParameters *UpdatePipeSourceRabbitMQBrokerParameters `json:"rabbitMQBrokerParameters,omitempty"`
	// The parameters for using a self-managed Apache Kafka stream as a source.
	SelfManagedKafkaParameters *UpdatePipeSourceSelfManagedKafkaParameters `json:"selfManagedKafkaParameters,omitempty"`
	// The parameters for using a Amazon SQS stream as a source.
	SQSQueueParameters *UpdatePipeSourceSQSQueueParameters `json:"sqsQueueParameters,omitempty"`
}

type UpdatePipeSourceRabbitMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
}

type UpdatePipeSourceSQSQueueParameters struct {
	BatchSize                      *int64 `json:"batchSize,omitempty"`
	MaximumBatchingWindowInSeconds *int64 `json:"maximumBatchingWindowInSeconds,omitempty"`
}

type UpdatePipeSourceSelfManagedKafkaParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *SelfManagedKafkaAccessConfigurationCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                                          `json:"maximumBatchingWindowInSeconds,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	ServerRootCaCertificate *string `json:"serverRootCaCertificate,omitempty"`
	// This structure specifies the VPC subnets and security groups for the stream,
	// and whether a public IP address is to be used.
	VPC *SelfManagedKafkaAccessConfigurationVPC `json:"vpc,omitempty"`
}

type ValidationExceptionField struct {
	Name *string `json:"name,omitempty"`
}