Versions in this module Expand all Collapse all v1 v1.0.1 Jul 4, 2024 v1.0.0 Jul 4, 2024 Changes in this version + const AssignPublicIpDisabled + const AssignPublicIpEnabled + const BatchJobDependencyTypeNToN + const BatchJobDependencyTypeSequential + const BatchResourceRequirementTypeGpu + const BatchResourceRequirementTypeMemory + const BatchResourceRequirementTypeVcpu + const DynamoDBStreamStartPositionLatest + const DynamoDBStreamStartPositionTrimHorizon + const EcsEnvironmentFileTypeS3 + const EcsResourceRequirementTypeGpu + const EcsResourceRequirementTypeInferenceAccelerator + const EndpointsID + const ErrCodeConflictException + const ErrCodeInternalException + const ErrCodeNotFoundException + const ErrCodeServiceQuotaExceededException + const ErrCodeThrottlingException + const ErrCodeValidationException + const KinesisStreamStartPositionAtTimestamp + const KinesisStreamStartPositionLatest + const KinesisStreamStartPositionTrimHorizon + const LaunchTypeEc2 + const LaunchTypeExternal + const LaunchTypeFargate + const MSKStartPositionLatest + const MSKStartPositionTrimHorizon + const OnPartialBatchItemFailureStreamsAutomaticBisect + const PipeStateCreateFailed + const PipeStateCreating + const PipeStateDeleting + const PipeStateRunning + const PipeStateStartFailed + const PipeStateStarting + const PipeStateStopFailed + const PipeStateStopped + const PipeStateStopping + const PipeStateUpdateFailed + const PipeStateUpdating + const PipeTargetInvocationTypeFireAndForget + const PipeTargetInvocationTypeRequestResponse + const PlacementConstraintTypeDistinctInstance + const PlacementConstraintTypeMemberOf + const PlacementStrategyTypeBinpack + const PlacementStrategyTypeRandom + const PlacementStrategyTypeSpread + const PropagateTagsTaskDefinition + const RequestedPipeStateDescribeResponseDeleted + const RequestedPipeStateDescribeResponseRunning + const RequestedPipeStateDescribeResponseStopped + const RequestedPipeStateRunning + const RequestedPipeStateStopped + const SelfManagedKafkaStartPositionLatest + const SelfManagedKafkaStartPositionTrimHorizon + const ServiceID + const ServiceName + func AssignPublicIp_Values() []string + func BatchJobDependencyType_Values() []string + func BatchResourceRequirementType_Values() []string + func DynamoDBStreamStartPosition_Values() []string + func EcsEnvironmentFileType_Values() []string + func EcsResourceRequirementType_Values() []string + func KinesisStreamStartPosition_Values() []string + func LaunchType_Values() []string + func MSKStartPosition_Values() []string + func OnPartialBatchItemFailureStreams_Values() []string + func PipeState_Values() []string + func PipeTargetInvocationType_Values() []string + func PlacementConstraintType_Values() []string + func PlacementStrategyType_Values() []string + func PropagateTags_Values() []string + func RequestedPipeStateDescribeResponse_Values() []string + func RequestedPipeState_Values() []string + func SelfManagedKafkaStartPosition_Values() []string + type AwsVpcConfiguration struct + AssignPublicIp *string + SecurityGroups []*string + Subnets []*string + func (s *AwsVpcConfiguration) SetAssignPublicIp(v string) *AwsVpcConfiguration + func (s *AwsVpcConfiguration) SetSecurityGroups(v []*string) *AwsVpcConfiguration + func (s *AwsVpcConfiguration) SetSubnets(v []*string) *AwsVpcConfiguration + func (s *AwsVpcConfiguration) Validate() error + func (s AwsVpcConfiguration) GoString() string + func (s AwsVpcConfiguration) String() string + type BatchArrayProperties struct + Size *int64 + func (s *BatchArrayProperties) SetSize(v int64) *BatchArrayProperties + func (s *BatchArrayProperties) Validate() error + func (s BatchArrayProperties) GoString() string + func (s BatchArrayProperties) String() string + type BatchContainerOverrides struct + Command []*string + Environment []*BatchEnvironmentVariable + InstanceType *string + ResourceRequirements []*BatchResourceRequirement + func (s *BatchContainerOverrides) SetCommand(v []*string) *BatchContainerOverrides + func (s *BatchContainerOverrides) SetEnvironment(v []*BatchEnvironmentVariable) *BatchContainerOverrides + func (s *BatchContainerOverrides) SetInstanceType(v string) *BatchContainerOverrides + func (s *BatchContainerOverrides) SetResourceRequirements(v []*BatchResourceRequirement) *BatchContainerOverrides + func (s *BatchContainerOverrides) Validate() error + func (s BatchContainerOverrides) GoString() string + func (s BatchContainerOverrides) String() string + type BatchEnvironmentVariable struct + Name *string + Value *string + func (s *BatchEnvironmentVariable) SetName(v string) *BatchEnvironmentVariable + func (s *BatchEnvironmentVariable) SetValue(v string) *BatchEnvironmentVariable + func (s BatchEnvironmentVariable) GoString() string + func (s BatchEnvironmentVariable) String() string + type BatchJobDependency struct + JobId *string + Type *string + func (s *BatchJobDependency) SetJobId(v string) *BatchJobDependency + func (s *BatchJobDependency) SetType(v string) *BatchJobDependency + func (s BatchJobDependency) GoString() string + func (s BatchJobDependency) String() string + type BatchResourceRequirement struct + Type *string + Value *string + func (s *BatchResourceRequirement) SetType(v string) *BatchResourceRequirement + func (s *BatchResourceRequirement) SetValue(v string) *BatchResourceRequirement + func (s *BatchResourceRequirement) Validate() error + func (s BatchResourceRequirement) GoString() string + func (s BatchResourceRequirement) String() string + type BatchRetryStrategy struct + Attempts *int64 + func (s *BatchRetryStrategy) SetAttempts(v int64) *BatchRetryStrategy + func (s *BatchRetryStrategy) Validate() error + func (s BatchRetryStrategy) GoString() string + func (s BatchRetryStrategy) String() string + type CapacityProviderStrategyItem struct + Base *int64 + CapacityProvider *string + Weight *int64 + func (s *CapacityProviderStrategyItem) SetBase(v int64) *CapacityProviderStrategyItem + func (s *CapacityProviderStrategyItem) SetCapacityProvider(v string) *CapacityProviderStrategyItem + func (s *CapacityProviderStrategyItem) SetWeight(v int64) *CapacityProviderStrategyItem + func (s *CapacityProviderStrategyItem) Validate() error + func (s CapacityProviderStrategyItem) GoString() string + func (s CapacityProviderStrategyItem) String() string + type ConflictException struct + Message_ *string + ResourceId *string + ResourceType *string + RespMetadata protocol.ResponseMetadata + func (s *ConflictException) Code() string + func (s *ConflictException) Error() string + func (s *ConflictException) Message() string + func (s *ConflictException) OrigErr() error + func (s *ConflictException) RequestID() string + func (s *ConflictException) StatusCode() int + func (s ConflictException) GoString() string + func (s ConflictException) String() string + type CreatePipeInput struct + Description *string + DesiredState *string + Enrichment *string + EnrichmentParameters *PipeEnrichmentParameters + Name *string + RoleArn *string + Source *string + SourceParameters *PipeSourceParameters + Tags map[string]*string + Target *string + TargetParameters *PipeTargetParameters + func (s *CreatePipeInput) SetDescription(v string) *CreatePipeInput + func (s *CreatePipeInput) SetDesiredState(v string) *CreatePipeInput + func (s *CreatePipeInput) SetEnrichment(v string) *CreatePipeInput + func (s *CreatePipeInput) SetEnrichmentParameters(v *PipeEnrichmentParameters) *CreatePipeInput + func (s *CreatePipeInput) SetName(v string) *CreatePipeInput + func (s *CreatePipeInput) SetRoleArn(v string) *CreatePipeInput + func (s *CreatePipeInput) SetSource(v string) *CreatePipeInput + func (s *CreatePipeInput) SetSourceParameters(v *PipeSourceParameters) *CreatePipeInput + func (s *CreatePipeInput) SetTags(v map[string]*string) *CreatePipeInput + func (s *CreatePipeInput) SetTarget(v string) *CreatePipeInput + func (s *CreatePipeInput) SetTargetParameters(v *PipeTargetParameters) *CreatePipeInput + func (s *CreatePipeInput) Validate() error + func (s CreatePipeInput) GoString() string + func (s CreatePipeInput) String() string + type CreatePipeOutput struct + Arn *string + CreationTime *time.Time + CurrentState *string + DesiredState *string + LastModifiedTime *time.Time + Name *string + func (s *CreatePipeOutput) SetArn(v string) *CreatePipeOutput + func (s *CreatePipeOutput) SetCreationTime(v time.Time) *CreatePipeOutput + func (s *CreatePipeOutput) SetCurrentState(v string) *CreatePipeOutput + func (s *CreatePipeOutput) SetDesiredState(v string) *CreatePipeOutput + func (s *CreatePipeOutput) SetLastModifiedTime(v time.Time) *CreatePipeOutput + func (s *CreatePipeOutput) SetName(v string) *CreatePipeOutput + func (s CreatePipeOutput) GoString() string + func (s CreatePipeOutput) String() string + type DeadLetterConfig struct + Arn *string + func (s *DeadLetterConfig) SetArn(v string) *DeadLetterConfig + func (s *DeadLetterConfig) Validate() error + func (s DeadLetterConfig) GoString() string + func (s DeadLetterConfig) String() string + type DeletePipeInput struct + Name *string + func (s *DeletePipeInput) SetName(v string) *DeletePipeInput + func (s *DeletePipeInput) Validate() error + func (s DeletePipeInput) GoString() string + func (s DeletePipeInput) String() string + type DeletePipeOutput struct + Arn *string + CreationTime *time.Time + CurrentState *string + DesiredState *string + LastModifiedTime *time.Time + Name *string + func (s *DeletePipeOutput) SetArn(v string) *DeletePipeOutput + func (s *DeletePipeOutput) SetCreationTime(v time.Time) *DeletePipeOutput + func (s *DeletePipeOutput) SetCurrentState(v string) *DeletePipeOutput + func (s *DeletePipeOutput) SetDesiredState(v string) *DeletePipeOutput + func (s *DeletePipeOutput) SetLastModifiedTime(v time.Time) *DeletePipeOutput + func (s *DeletePipeOutput) SetName(v string) *DeletePipeOutput + func (s DeletePipeOutput) GoString() string + func (s DeletePipeOutput) String() string + type DescribePipeInput struct + Name *string + func (s *DescribePipeInput) SetName(v string) *DescribePipeInput + func (s *DescribePipeInput) Validate() error + func (s DescribePipeInput) GoString() string + func (s DescribePipeInput) String() string + type DescribePipeOutput struct + Arn *string + CreationTime *time.Time + CurrentState *string + Description *string + DesiredState *string + Enrichment *string + EnrichmentParameters *PipeEnrichmentParameters + LastModifiedTime *time.Time + Name *string + RoleArn *string + Source *string + SourceParameters *PipeSourceParameters + StateReason *string + Tags map[string]*string + Target *string + TargetParameters *PipeTargetParameters + func (s *DescribePipeOutput) SetArn(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetCreationTime(v time.Time) *DescribePipeOutput + func (s *DescribePipeOutput) SetCurrentState(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetDescription(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetDesiredState(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetEnrichment(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetEnrichmentParameters(v *PipeEnrichmentParameters) *DescribePipeOutput + func (s *DescribePipeOutput) SetLastModifiedTime(v time.Time) *DescribePipeOutput + func (s *DescribePipeOutput) SetName(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetRoleArn(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetSource(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetSourceParameters(v *PipeSourceParameters) *DescribePipeOutput + func (s *DescribePipeOutput) SetStateReason(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetTags(v map[string]*string) *DescribePipeOutput + func (s *DescribePipeOutput) SetTarget(v string) *DescribePipeOutput + func (s *DescribePipeOutput) SetTargetParameters(v *PipeTargetParameters) *DescribePipeOutput + func (s DescribePipeOutput) GoString() string + func (s DescribePipeOutput) String() string + type EcsContainerOverride struct + Command []*string + Cpu *int64 + Environment []*EcsEnvironmentVariable + EnvironmentFiles []*EcsEnvironmentFile + Memory *int64 + MemoryReservation *int64 + Name *string + ResourceRequirements []*EcsResourceRequirement + func (s *EcsContainerOverride) SetCommand(v []*string) *EcsContainerOverride + func (s *EcsContainerOverride) SetCpu(v int64) *EcsContainerOverride + func (s *EcsContainerOverride) SetEnvironment(v []*EcsEnvironmentVariable) *EcsContainerOverride + func (s *EcsContainerOverride) SetEnvironmentFiles(v []*EcsEnvironmentFile) *EcsContainerOverride + func (s *EcsContainerOverride) SetMemory(v int64) *EcsContainerOverride + func (s *EcsContainerOverride) SetMemoryReservation(v int64) *EcsContainerOverride + func (s *EcsContainerOverride) SetName(v string) *EcsContainerOverride + func (s *EcsContainerOverride) SetResourceRequirements(v []*EcsResourceRequirement) *EcsContainerOverride + func (s *EcsContainerOverride) Validate() error + func (s EcsContainerOverride) GoString() string + func (s EcsContainerOverride) String() string + type EcsEnvironmentFile struct + Type *string + Value *string + func (s *EcsEnvironmentFile) SetType(v string) *EcsEnvironmentFile + func (s *EcsEnvironmentFile) SetValue(v string) *EcsEnvironmentFile + func (s *EcsEnvironmentFile) Validate() error + func (s EcsEnvironmentFile) GoString() string + func (s EcsEnvironmentFile) String() string + type EcsEnvironmentVariable struct + Name *string + Value *string + func (s *EcsEnvironmentVariable) SetName(v string) *EcsEnvironmentVariable + func (s *EcsEnvironmentVariable) SetValue(v string) *EcsEnvironmentVariable + func (s EcsEnvironmentVariable) GoString() string + func (s EcsEnvironmentVariable) String() string + type EcsEphemeralStorage struct + SizeInGiB *int64 + func (s *EcsEphemeralStorage) SetSizeInGiB(v int64) *EcsEphemeralStorage + func (s *EcsEphemeralStorage) Validate() error + func (s EcsEphemeralStorage) GoString() string + func (s EcsEphemeralStorage) String() string + type EcsInferenceAcceleratorOverride struct + DeviceName *string + DeviceType *string + func (s *EcsInferenceAcceleratorOverride) SetDeviceName(v string) *EcsInferenceAcceleratorOverride + func (s *EcsInferenceAcceleratorOverride) SetDeviceType(v string) *EcsInferenceAcceleratorOverride + func (s EcsInferenceAcceleratorOverride) GoString() string + func (s EcsInferenceAcceleratorOverride) String() string + type EcsResourceRequirement struct + Type *string + Value *string + func (s *EcsResourceRequirement) SetType(v string) *EcsResourceRequirement + func (s *EcsResourceRequirement) SetValue(v string) *EcsResourceRequirement + func (s *EcsResourceRequirement) Validate() error + func (s EcsResourceRequirement) GoString() string + func (s EcsResourceRequirement) String() string + type EcsTaskOverride struct + ContainerOverrides []*EcsContainerOverride + Cpu *string + EphemeralStorage *EcsEphemeralStorage + ExecutionRoleArn *string + InferenceAcceleratorOverrides []*EcsInferenceAcceleratorOverride + Memory *string + TaskRoleArn *string + func (s *EcsTaskOverride) SetContainerOverrides(v []*EcsContainerOverride) *EcsTaskOverride + func (s *EcsTaskOverride) SetCpu(v string) *EcsTaskOverride + func (s *EcsTaskOverride) SetEphemeralStorage(v *EcsEphemeralStorage) *EcsTaskOverride + func (s *EcsTaskOverride) SetExecutionRoleArn(v string) *EcsTaskOverride + func (s *EcsTaskOverride) SetInferenceAcceleratorOverrides(v []*EcsInferenceAcceleratorOverride) *EcsTaskOverride + func (s *EcsTaskOverride) SetMemory(v string) *EcsTaskOverride + func (s *EcsTaskOverride) SetTaskRoleArn(v string) *EcsTaskOverride + func (s *EcsTaskOverride) Validate() error + func (s EcsTaskOverride) GoString() string + func (s EcsTaskOverride) String() string + type Filter struct + Pattern *string + func (s *Filter) SetPattern(v string) *Filter + func (s Filter) GoString() string + func (s Filter) String() string + type FilterCriteria struct + Filters []*Filter + func (s *FilterCriteria) SetFilters(v []*Filter) *FilterCriteria + func (s FilterCriteria) GoString() string + func (s FilterCriteria) String() string + type InternalException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + RetryAfterSeconds *int64 + func (s *InternalException) Code() string + func (s *InternalException) Error() string + func (s *InternalException) Message() string + func (s *InternalException) OrigErr() error + func (s *InternalException) RequestID() string + func (s *InternalException) StatusCode() int + func (s InternalException) GoString() string + func (s InternalException) String() string + type ListPipesInput struct + CurrentState *string + DesiredState *string + Limit *int64 + NamePrefix *string + NextToken *string + SourcePrefix *string + TargetPrefix *string + func (s *ListPipesInput) SetCurrentState(v string) *ListPipesInput + func (s *ListPipesInput) SetDesiredState(v string) *ListPipesInput + func (s *ListPipesInput) SetLimit(v int64) *ListPipesInput + func (s *ListPipesInput) SetNamePrefix(v string) *ListPipesInput + func (s *ListPipesInput) SetNextToken(v string) *ListPipesInput + func (s *ListPipesInput) SetSourcePrefix(v string) *ListPipesInput + func (s *ListPipesInput) SetTargetPrefix(v string) *ListPipesInput + func (s *ListPipesInput) Validate() error + func (s ListPipesInput) GoString() string + func (s ListPipesInput) String() string + type ListPipesOutput struct + NextToken *string + Pipes []*Pipe + func (s *ListPipesOutput) SetNextToken(v string) *ListPipesOutput + func (s *ListPipesOutput) SetPipes(v []*Pipe) *ListPipesOutput + func (s ListPipesOutput) GoString() string + func (s ListPipesOutput) String() string + type ListTagsForResourceInput struct + ResourceArn *string + func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput + func (s *ListTagsForResourceInput) Validate() error + func (s ListTagsForResourceInput) GoString() string + func (s ListTagsForResourceInput) String() string + type ListTagsForResourceOutput struct + Tags map[string]*string + func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput + func (s ListTagsForResourceOutput) GoString() string + func (s ListTagsForResourceOutput) String() string + type MQBrokerAccessCredentials struct + BasicAuth *string + func (s *MQBrokerAccessCredentials) SetBasicAuth(v string) *MQBrokerAccessCredentials + func (s *MQBrokerAccessCredentials) Validate() error + func (s MQBrokerAccessCredentials) GoString() string + func (s MQBrokerAccessCredentials) String() string + type MSKAccessCredentials struct + ClientCertificateTlsAuth *string + SaslScram512Auth *string + func (s *MSKAccessCredentials) SetClientCertificateTlsAuth(v string) *MSKAccessCredentials + func (s *MSKAccessCredentials) SetSaslScram512Auth(v string) *MSKAccessCredentials + func (s *MSKAccessCredentials) Validate() error + func (s MSKAccessCredentials) GoString() string + func (s MSKAccessCredentials) String() string + type NetworkConfiguration struct + AwsvpcConfiguration *AwsVpcConfiguration + func (s *NetworkConfiguration) SetAwsvpcConfiguration(v *AwsVpcConfiguration) *NetworkConfiguration + func (s *NetworkConfiguration) Validate() error + func (s NetworkConfiguration) GoString() string + func (s NetworkConfiguration) String() string + type NotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *NotFoundException) Code() string + func (s *NotFoundException) Error() string + func (s *NotFoundException) Message() string + func (s *NotFoundException) OrigErr() error + func (s *NotFoundException) RequestID() string + func (s *NotFoundException) StatusCode() int + func (s NotFoundException) GoString() string + func (s NotFoundException) String() string + type Pipe struct + Arn *string + CreationTime *time.Time + CurrentState *string + DesiredState *string + Enrichment *string + LastModifiedTime *time.Time + Name *string + Source *string + StateReason *string + Target *string + func (s *Pipe) SetArn(v string) *Pipe + func (s *Pipe) SetCreationTime(v time.Time) *Pipe + func (s *Pipe) SetCurrentState(v string) *Pipe + func (s *Pipe) SetDesiredState(v string) *Pipe + func (s *Pipe) SetEnrichment(v string) *Pipe + func (s *Pipe) SetLastModifiedTime(v time.Time) *Pipe + func (s *Pipe) SetName(v string) *Pipe + func (s *Pipe) SetSource(v string) *Pipe + func (s *Pipe) SetStateReason(v string) *Pipe + func (s *Pipe) SetTarget(v string) *Pipe + func (s Pipe) GoString() string + func (s Pipe) String() string + type PipeEnrichmentHttpParameters struct + HeaderParameters map[string]*string + PathParameterValues []*string + QueryStringParameters map[string]*string + func (s *PipeEnrichmentHttpParameters) SetHeaderParameters(v map[string]*string) *PipeEnrichmentHttpParameters + func (s *PipeEnrichmentHttpParameters) SetPathParameterValues(v []*string) *PipeEnrichmentHttpParameters + func (s *PipeEnrichmentHttpParameters) SetQueryStringParameters(v map[string]*string) *PipeEnrichmentHttpParameters + func (s PipeEnrichmentHttpParameters) GoString() string + func (s PipeEnrichmentHttpParameters) String() string + type PipeEnrichmentParameters struct + HttpParameters *PipeEnrichmentHttpParameters + InputTemplate *string + func (s *PipeEnrichmentParameters) SetHttpParameters(v *PipeEnrichmentHttpParameters) *PipeEnrichmentParameters + func (s *PipeEnrichmentParameters) SetInputTemplate(v string) *PipeEnrichmentParameters + func (s PipeEnrichmentParameters) GoString() string + func (s PipeEnrichmentParameters) String() string + type PipeSourceActiveMQBrokerParameters struct + BatchSize *int64 + Credentials *MQBrokerAccessCredentials + MaximumBatchingWindowInSeconds *int64 + QueueName *string + func (s *PipeSourceActiveMQBrokerParameters) SetBatchSize(v int64) *PipeSourceActiveMQBrokerParameters + func (s *PipeSourceActiveMQBrokerParameters) SetCredentials(v *MQBrokerAccessCredentials) *PipeSourceActiveMQBrokerParameters + func (s *PipeSourceActiveMQBrokerParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceActiveMQBrokerParameters + func (s *PipeSourceActiveMQBrokerParameters) SetQueueName(v string) *PipeSourceActiveMQBrokerParameters + func (s *PipeSourceActiveMQBrokerParameters) Validate() error + func (s PipeSourceActiveMQBrokerParameters) GoString() string + func (s PipeSourceActiveMQBrokerParameters) String() string + type PipeSourceDynamoDBStreamParameters struct + BatchSize *int64 + DeadLetterConfig *DeadLetterConfig + MaximumBatchingWindowInSeconds *int64 + MaximumRecordAgeInSeconds *int64 + MaximumRetryAttempts *int64 + OnPartialBatchItemFailure *string + ParallelizationFactor *int64 + StartingPosition *string + func (s *PipeSourceDynamoDBStreamParameters) SetBatchSize(v int64) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) SetDeadLetterConfig(v *DeadLetterConfig) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) SetMaximumRecordAgeInSeconds(v int64) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) SetMaximumRetryAttempts(v int64) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) SetOnPartialBatchItemFailure(v string) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) SetParallelizationFactor(v int64) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) SetStartingPosition(v string) *PipeSourceDynamoDBStreamParameters + func (s *PipeSourceDynamoDBStreamParameters) Validate() error + func (s PipeSourceDynamoDBStreamParameters) GoString() string + func (s PipeSourceDynamoDBStreamParameters) String() string + type PipeSourceKinesisStreamParameters struct + BatchSize *int64 + DeadLetterConfig *DeadLetterConfig + MaximumBatchingWindowInSeconds *int64 + MaximumRecordAgeInSeconds *int64 + MaximumRetryAttempts *int64 + OnPartialBatchItemFailure *string + ParallelizationFactor *int64 + StartingPosition *string + StartingPositionTimestamp *time.Time + func (s *PipeSourceKinesisStreamParameters) SetBatchSize(v int64) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetDeadLetterConfig(v *DeadLetterConfig) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetMaximumRecordAgeInSeconds(v int64) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetMaximumRetryAttempts(v int64) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetOnPartialBatchItemFailure(v string) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetParallelizationFactor(v int64) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetStartingPosition(v string) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) SetStartingPositionTimestamp(v time.Time) *PipeSourceKinesisStreamParameters + func (s *PipeSourceKinesisStreamParameters) Validate() error + func (s PipeSourceKinesisStreamParameters) GoString() string + func (s PipeSourceKinesisStreamParameters) String() string + type PipeSourceManagedStreamingKafkaParameters struct + BatchSize *int64 + ConsumerGroupID *string + Credentials *MSKAccessCredentials + MaximumBatchingWindowInSeconds *int64 + StartingPosition *string + TopicName *string + func (s *PipeSourceManagedStreamingKafkaParameters) SetBatchSize(v int64) *PipeSourceManagedStreamingKafkaParameters + func (s *PipeSourceManagedStreamingKafkaParameters) SetConsumerGroupID(v string) *PipeSourceManagedStreamingKafkaParameters + func (s *PipeSourceManagedStreamingKafkaParameters) SetCredentials(v *MSKAccessCredentials) *PipeSourceManagedStreamingKafkaParameters + func (s *PipeSourceManagedStreamingKafkaParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceManagedStreamingKafkaParameters + func (s *PipeSourceManagedStreamingKafkaParameters) SetStartingPosition(v string) *PipeSourceManagedStreamingKafkaParameters + func (s *PipeSourceManagedStreamingKafkaParameters) SetTopicName(v string) *PipeSourceManagedStreamingKafkaParameters + func (s *PipeSourceManagedStreamingKafkaParameters) Validate() error + func (s PipeSourceManagedStreamingKafkaParameters) GoString() string + func (s PipeSourceManagedStreamingKafkaParameters) String() string + type PipeSourceParameters struct + ActiveMQBrokerParameters *PipeSourceActiveMQBrokerParameters + DynamoDBStreamParameters *PipeSourceDynamoDBStreamParameters + FilterCriteria *FilterCriteria + KinesisStreamParameters *PipeSourceKinesisStreamParameters + ManagedStreamingKafkaParameters *PipeSourceManagedStreamingKafkaParameters + RabbitMQBrokerParameters *PipeSourceRabbitMQBrokerParameters + SelfManagedKafkaParameters *PipeSourceSelfManagedKafkaParameters + SqsQueueParameters *PipeSourceSqsQueueParameters + func (s *PipeSourceParameters) SetActiveMQBrokerParameters(v *PipeSourceActiveMQBrokerParameters) *PipeSourceParameters + func (s *PipeSourceParameters) SetDynamoDBStreamParameters(v *PipeSourceDynamoDBStreamParameters) *PipeSourceParameters + func (s *PipeSourceParameters) SetFilterCriteria(v *FilterCriteria) *PipeSourceParameters + func (s *PipeSourceParameters) SetKinesisStreamParameters(v *PipeSourceKinesisStreamParameters) *PipeSourceParameters + func (s *PipeSourceParameters) SetManagedStreamingKafkaParameters(v *PipeSourceManagedStreamingKafkaParameters) *PipeSourceParameters + func (s *PipeSourceParameters) SetRabbitMQBrokerParameters(v *PipeSourceRabbitMQBrokerParameters) *PipeSourceParameters + func (s *PipeSourceParameters) SetSelfManagedKafkaParameters(v *PipeSourceSelfManagedKafkaParameters) *PipeSourceParameters + func (s *PipeSourceParameters) SetSqsQueueParameters(v *PipeSourceSqsQueueParameters) *PipeSourceParameters + func (s *PipeSourceParameters) Validate() error + func (s PipeSourceParameters) GoString() string + func (s PipeSourceParameters) String() string + type PipeSourceRabbitMQBrokerParameters struct + BatchSize *int64 + Credentials *MQBrokerAccessCredentials + MaximumBatchingWindowInSeconds *int64 + QueueName *string + VirtualHost *string + func (s *PipeSourceRabbitMQBrokerParameters) SetBatchSize(v int64) *PipeSourceRabbitMQBrokerParameters + func (s *PipeSourceRabbitMQBrokerParameters) SetCredentials(v *MQBrokerAccessCredentials) *PipeSourceRabbitMQBrokerParameters + func (s *PipeSourceRabbitMQBrokerParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceRabbitMQBrokerParameters + func (s *PipeSourceRabbitMQBrokerParameters) SetQueueName(v string) *PipeSourceRabbitMQBrokerParameters + func (s *PipeSourceRabbitMQBrokerParameters) SetVirtualHost(v string) *PipeSourceRabbitMQBrokerParameters + func (s *PipeSourceRabbitMQBrokerParameters) Validate() error + func (s PipeSourceRabbitMQBrokerParameters) GoString() string + func (s PipeSourceRabbitMQBrokerParameters) String() string + type PipeSourceSelfManagedKafkaParameters struct + AdditionalBootstrapServers []*string + BatchSize *int64 + ConsumerGroupID *string + Credentials *SelfManagedKafkaAccessConfigurationCredentials + MaximumBatchingWindowInSeconds *int64 + ServerRootCaCertificate *string + StartingPosition *string + TopicName *string + Vpc *SelfManagedKafkaAccessConfigurationVpc + func (s *PipeSourceSelfManagedKafkaParameters) SetAdditionalBootstrapServers(v []*string) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetBatchSize(v int64) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetConsumerGroupID(v string) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetCredentials(v *SelfManagedKafkaAccessConfigurationCredentials) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetServerRootCaCertificate(v string) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetStartingPosition(v string) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetTopicName(v string) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) SetVpc(v *SelfManagedKafkaAccessConfigurationVpc) *PipeSourceSelfManagedKafkaParameters + func (s *PipeSourceSelfManagedKafkaParameters) Validate() error + func (s PipeSourceSelfManagedKafkaParameters) GoString() string + func (s PipeSourceSelfManagedKafkaParameters) String() string + type PipeSourceSqsQueueParameters struct + BatchSize *int64 + MaximumBatchingWindowInSeconds *int64 + func (s *PipeSourceSqsQueueParameters) SetBatchSize(v int64) *PipeSourceSqsQueueParameters + func (s *PipeSourceSqsQueueParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceSqsQueueParameters + func (s *PipeSourceSqsQueueParameters) Validate() error + func (s PipeSourceSqsQueueParameters) GoString() string + func (s PipeSourceSqsQueueParameters) String() string + type PipeTargetBatchJobParameters struct + ArrayProperties *BatchArrayProperties + ContainerOverrides *BatchContainerOverrides + DependsOn []*BatchJobDependency + JobDefinition *string + JobName *string + Parameters map[string]*string + RetryStrategy *BatchRetryStrategy + func (s *PipeTargetBatchJobParameters) SetArrayProperties(v *BatchArrayProperties) *PipeTargetBatchJobParameters + func (s *PipeTargetBatchJobParameters) SetContainerOverrides(v *BatchContainerOverrides) *PipeTargetBatchJobParameters + func (s *PipeTargetBatchJobParameters) SetDependsOn(v []*BatchJobDependency) *PipeTargetBatchJobParameters + func (s *PipeTargetBatchJobParameters) SetJobDefinition(v string) *PipeTargetBatchJobParameters + func (s *PipeTargetBatchJobParameters) SetJobName(v string) *PipeTargetBatchJobParameters + func (s *PipeTargetBatchJobParameters) SetParameters(v map[string]*string) *PipeTargetBatchJobParameters + func (s *PipeTargetBatchJobParameters) SetRetryStrategy(v *BatchRetryStrategy) *PipeTargetBatchJobParameters + func (s *PipeTargetBatchJobParameters) Validate() error + func (s PipeTargetBatchJobParameters) GoString() string + func (s PipeTargetBatchJobParameters) String() string + type PipeTargetCloudWatchLogsParameters struct + LogStreamName *string + Timestamp *string + func (s *PipeTargetCloudWatchLogsParameters) SetLogStreamName(v string) *PipeTargetCloudWatchLogsParameters + func (s *PipeTargetCloudWatchLogsParameters) SetTimestamp(v string) *PipeTargetCloudWatchLogsParameters + func (s *PipeTargetCloudWatchLogsParameters) Validate() error + func (s PipeTargetCloudWatchLogsParameters) GoString() string + func (s PipeTargetCloudWatchLogsParameters) String() string + type PipeTargetEcsTaskParameters struct + CapacityProviderStrategy []*CapacityProviderStrategyItem + EnableECSManagedTags *bool + EnableExecuteCommand *bool + Group *string + LaunchType *string + NetworkConfiguration *NetworkConfiguration + Overrides *EcsTaskOverride + PlacementConstraints []*PlacementConstraint + PlacementStrategy []*PlacementStrategy + PlatformVersion *string + PropagateTags *string + ReferenceId *string + Tags []*Tag + TaskCount *int64 + TaskDefinitionArn *string + func (s *PipeTargetEcsTaskParameters) SetCapacityProviderStrategy(v []*CapacityProviderStrategyItem) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetEnableECSManagedTags(v bool) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetEnableExecuteCommand(v bool) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetGroup(v string) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetLaunchType(v string) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetNetworkConfiguration(v *NetworkConfiguration) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetOverrides(v *EcsTaskOverride) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetPlacementConstraints(v []*PlacementConstraint) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetPlacementStrategy(v []*PlacementStrategy) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetPlatformVersion(v string) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetPropagateTags(v string) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetReferenceId(v string) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetTags(v []*Tag) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetTaskCount(v int64) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) SetTaskDefinitionArn(v string) *PipeTargetEcsTaskParameters + func (s *PipeTargetEcsTaskParameters) Validate() error + func (s PipeTargetEcsTaskParameters) GoString() string + func (s PipeTargetEcsTaskParameters) String() string + type PipeTargetEventBridgeEventBusParameters struct + DetailType *string + EndpointId *string + Resources []*string + Source *string + Time *string + func (s *PipeTargetEventBridgeEventBusParameters) SetDetailType(v string) *PipeTargetEventBridgeEventBusParameters + func (s *PipeTargetEventBridgeEventBusParameters) SetEndpointId(v string) *PipeTargetEventBridgeEventBusParameters + func (s *PipeTargetEventBridgeEventBusParameters) SetResources(v []*string) *PipeTargetEventBridgeEventBusParameters + func (s *PipeTargetEventBridgeEventBusParameters) SetSource(v string) *PipeTargetEventBridgeEventBusParameters + func (s *PipeTargetEventBridgeEventBusParameters) SetTime(v string) *PipeTargetEventBridgeEventBusParameters + func (s *PipeTargetEventBridgeEventBusParameters) Validate() error + func (s PipeTargetEventBridgeEventBusParameters) GoString() string + func (s PipeTargetEventBridgeEventBusParameters) String() string + type PipeTargetHttpParameters struct + HeaderParameters map[string]*string + PathParameterValues []*string + QueryStringParameters map[string]*string + func (s *PipeTargetHttpParameters) SetHeaderParameters(v map[string]*string) *PipeTargetHttpParameters + func (s *PipeTargetHttpParameters) SetPathParameterValues(v []*string) *PipeTargetHttpParameters + func (s *PipeTargetHttpParameters) SetQueryStringParameters(v map[string]*string) *PipeTargetHttpParameters + func (s PipeTargetHttpParameters) GoString() string + func (s PipeTargetHttpParameters) String() string + type PipeTargetKinesisStreamParameters struct + PartitionKey *string + func (s *PipeTargetKinesisStreamParameters) SetPartitionKey(v string) *PipeTargetKinesisStreamParameters + func (s *PipeTargetKinesisStreamParameters) Validate() error + func (s PipeTargetKinesisStreamParameters) GoString() string + func (s PipeTargetKinesisStreamParameters) String() string + type PipeTargetLambdaFunctionParameters struct + InvocationType *string + func (s *PipeTargetLambdaFunctionParameters) SetInvocationType(v string) *PipeTargetLambdaFunctionParameters + func (s PipeTargetLambdaFunctionParameters) GoString() string + func (s PipeTargetLambdaFunctionParameters) String() string + type PipeTargetParameters struct + BatchJobParameters *PipeTargetBatchJobParameters + CloudWatchLogsParameters *PipeTargetCloudWatchLogsParameters + EcsTaskParameters *PipeTargetEcsTaskParameters + EventBridgeEventBusParameters *PipeTargetEventBridgeEventBusParameters + HttpParameters *PipeTargetHttpParameters + InputTemplate *string + KinesisStreamParameters *PipeTargetKinesisStreamParameters + LambdaFunctionParameters *PipeTargetLambdaFunctionParameters + RedshiftDataParameters *PipeTargetRedshiftDataParameters + SageMakerPipelineParameters *PipeTargetSageMakerPipelineParameters + SqsQueueParameters *PipeTargetSqsQueueParameters + StepFunctionStateMachineParameters *PipeTargetStateMachineParameters + func (s *PipeTargetParameters) SetBatchJobParameters(v *PipeTargetBatchJobParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetCloudWatchLogsParameters(v *PipeTargetCloudWatchLogsParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetEcsTaskParameters(v *PipeTargetEcsTaskParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetEventBridgeEventBusParameters(v *PipeTargetEventBridgeEventBusParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetHttpParameters(v *PipeTargetHttpParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetInputTemplate(v string) *PipeTargetParameters + func (s *PipeTargetParameters) SetKinesisStreamParameters(v *PipeTargetKinesisStreamParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetLambdaFunctionParameters(v *PipeTargetLambdaFunctionParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetRedshiftDataParameters(v *PipeTargetRedshiftDataParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetSageMakerPipelineParameters(v *PipeTargetSageMakerPipelineParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetSqsQueueParameters(v *PipeTargetSqsQueueParameters) *PipeTargetParameters + func (s *PipeTargetParameters) SetStepFunctionStateMachineParameters(v *PipeTargetStateMachineParameters) *PipeTargetParameters + func (s *PipeTargetParameters) Validate() error + func (s PipeTargetParameters) GoString() string + func (s PipeTargetParameters) String() string + type PipeTargetRedshiftDataParameters struct + Database *string + DbUser *string + SecretManagerArn *string + Sqls []*string + StatementName *string + WithEvent *bool + func (s *PipeTargetRedshiftDataParameters) SetDatabase(v string) *PipeTargetRedshiftDataParameters + func (s *PipeTargetRedshiftDataParameters) SetDbUser(v string) *PipeTargetRedshiftDataParameters + func (s *PipeTargetRedshiftDataParameters) SetSecretManagerArn(v string) *PipeTargetRedshiftDataParameters + func (s *PipeTargetRedshiftDataParameters) SetSqls(v []*string) *PipeTargetRedshiftDataParameters + func (s *PipeTargetRedshiftDataParameters) SetStatementName(v string) *PipeTargetRedshiftDataParameters + func (s *PipeTargetRedshiftDataParameters) SetWithEvent(v bool) *PipeTargetRedshiftDataParameters + func (s *PipeTargetRedshiftDataParameters) Validate() error + func (s PipeTargetRedshiftDataParameters) GoString() string + func (s PipeTargetRedshiftDataParameters) String() string + type PipeTargetSageMakerPipelineParameters struct + PipelineParameterList []*SageMakerPipelineParameter + func (s *PipeTargetSageMakerPipelineParameters) SetPipelineParameterList(v []*SageMakerPipelineParameter) *PipeTargetSageMakerPipelineParameters + func (s *PipeTargetSageMakerPipelineParameters) Validate() error + func (s PipeTargetSageMakerPipelineParameters) GoString() string + func (s PipeTargetSageMakerPipelineParameters) String() string + type PipeTargetSqsQueueParameters struct + MessageDeduplicationId *string + MessageGroupId *string + func (s *PipeTargetSqsQueueParameters) SetMessageDeduplicationId(v string) *PipeTargetSqsQueueParameters + func (s *PipeTargetSqsQueueParameters) SetMessageGroupId(v string) *PipeTargetSqsQueueParameters + func (s PipeTargetSqsQueueParameters) GoString() string + func (s PipeTargetSqsQueueParameters) String() string + type PipeTargetStateMachineParameters struct + InvocationType *string + func (s *PipeTargetStateMachineParameters) SetInvocationType(v string) *PipeTargetStateMachineParameters + func (s PipeTargetStateMachineParameters) GoString() string + func (s PipeTargetStateMachineParameters) String() string + type Pipes struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *Pipes + func (c *Pipes) CreatePipe(input *CreatePipeInput) (*CreatePipeOutput, error) + func (c *Pipes) CreatePipeRequest(input *CreatePipeInput) (req *request.Request, output *CreatePipeOutput) + func (c *Pipes) CreatePipeWithContext(ctx aws.Context, input *CreatePipeInput, opts ...request.Option) (*CreatePipeOutput, error) + func (c *Pipes) DeletePipe(input *DeletePipeInput) (*DeletePipeOutput, error) + func (c *Pipes) DeletePipeRequest(input *DeletePipeInput) (req *request.Request, output *DeletePipeOutput) + func (c *Pipes) DeletePipeWithContext(ctx aws.Context, input *DeletePipeInput, opts ...request.Option) (*DeletePipeOutput, error) + func (c *Pipes) DescribePipe(input *DescribePipeInput) (*DescribePipeOutput, error) + func (c *Pipes) DescribePipeRequest(input *DescribePipeInput) (req *request.Request, output *DescribePipeOutput) + func (c *Pipes) DescribePipeWithContext(ctx aws.Context, input *DescribePipeInput, opts ...request.Option) (*DescribePipeOutput, error) + func (c *Pipes) ListPipes(input *ListPipesInput) (*ListPipesOutput, error) + func (c *Pipes) ListPipesPages(input *ListPipesInput, fn func(*ListPipesOutput, bool) bool) error + func (c *Pipes) ListPipesPagesWithContext(ctx aws.Context, input *ListPipesInput, fn func(*ListPipesOutput, bool) bool, ...) error + func (c *Pipes) ListPipesRequest(input *ListPipesInput) (req *request.Request, output *ListPipesOutput) + func (c *Pipes) ListPipesWithContext(ctx aws.Context, input *ListPipesInput, opts ...request.Option) (*ListPipesOutput, error) + func (c *Pipes) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error) + func (c *Pipes) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput) + func (c *Pipes) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error) + func (c *Pipes) StartPipe(input *StartPipeInput) (*StartPipeOutput, error) + func (c *Pipes) StartPipeRequest(input *StartPipeInput) (req *request.Request, output *StartPipeOutput) + func (c *Pipes) StartPipeWithContext(ctx aws.Context, input *StartPipeInput, opts ...request.Option) (*StartPipeOutput, error) + func (c *Pipes) StopPipe(input *StopPipeInput) (*StopPipeOutput, error) + func (c *Pipes) StopPipeRequest(input *StopPipeInput) (req *request.Request, output *StopPipeOutput) + func (c *Pipes) StopPipeWithContext(ctx aws.Context, input *StopPipeInput, opts ...request.Option) (*StopPipeOutput, error) + func (c *Pipes) TagResource(input *TagResourceInput) (*TagResourceOutput, error) + func (c *Pipes) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput) + func (c *Pipes) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error) + func (c *Pipes) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error) + func (c *Pipes) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput) + func (c *Pipes) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error) + func (c *Pipes) UpdatePipe(input *UpdatePipeInput) (*UpdatePipeOutput, error) + func (c *Pipes) UpdatePipeRequest(input *UpdatePipeInput) (req *request.Request, output *UpdatePipeOutput) + func (c *Pipes) UpdatePipeWithContext(ctx aws.Context, input *UpdatePipeInput, opts ...request.Option) (*UpdatePipeOutput, error) + type PlacementConstraint struct + Expression *string + Type *string + func (s *PlacementConstraint) SetExpression(v string) *PlacementConstraint + func (s *PlacementConstraint) SetType(v string) *PlacementConstraint + func (s PlacementConstraint) GoString() string + func (s PlacementConstraint) String() string + type PlacementStrategy struct + Field *string + Type *string + func (s *PlacementStrategy) SetField(v string) *PlacementStrategy + func (s *PlacementStrategy) SetType(v string) *PlacementStrategy + func (s PlacementStrategy) GoString() string + func (s PlacementStrategy) String() string + type SageMakerPipelineParameter struct + Name *string + Value *string + func (s *SageMakerPipelineParameter) SetName(v string) *SageMakerPipelineParameter + func (s *SageMakerPipelineParameter) SetValue(v string) *SageMakerPipelineParameter + func (s *SageMakerPipelineParameter) Validate() error + func (s SageMakerPipelineParameter) GoString() string + func (s SageMakerPipelineParameter) String() string + type SelfManagedKafkaAccessConfigurationCredentials struct + BasicAuth *string + ClientCertificateTlsAuth *string + SaslScram256Auth *string + SaslScram512Auth *string + func (s *SelfManagedKafkaAccessConfigurationCredentials) SetBasicAuth(v string) *SelfManagedKafkaAccessConfigurationCredentials + func (s *SelfManagedKafkaAccessConfigurationCredentials) SetClientCertificateTlsAuth(v string) *SelfManagedKafkaAccessConfigurationCredentials + func (s *SelfManagedKafkaAccessConfigurationCredentials) SetSaslScram256Auth(v string) *SelfManagedKafkaAccessConfigurationCredentials + func (s *SelfManagedKafkaAccessConfigurationCredentials) SetSaslScram512Auth(v string) *SelfManagedKafkaAccessConfigurationCredentials + func (s *SelfManagedKafkaAccessConfigurationCredentials) Validate() error + func (s SelfManagedKafkaAccessConfigurationCredentials) GoString() string + func (s SelfManagedKafkaAccessConfigurationCredentials) String() string + type SelfManagedKafkaAccessConfigurationVpc struct + SecurityGroup []*string + Subnets []*string + func (s *SelfManagedKafkaAccessConfigurationVpc) SetSecurityGroup(v []*string) *SelfManagedKafkaAccessConfigurationVpc + func (s *SelfManagedKafkaAccessConfigurationVpc) SetSubnets(v []*string) *SelfManagedKafkaAccessConfigurationVpc + func (s SelfManagedKafkaAccessConfigurationVpc) GoString() string + func (s SelfManagedKafkaAccessConfigurationVpc) String() string + type ServiceQuotaExceededException struct + Message_ *string + QuotaCode *string + ResourceId *string + ResourceType *string + RespMetadata protocol.ResponseMetadata + ServiceCode *string + func (s *ServiceQuotaExceededException) Code() string + func (s *ServiceQuotaExceededException) Error() string + func (s *ServiceQuotaExceededException) Message() string + func (s *ServiceQuotaExceededException) OrigErr() error + func (s *ServiceQuotaExceededException) RequestID() string + func (s *ServiceQuotaExceededException) StatusCode() int + func (s ServiceQuotaExceededException) GoString() string + func (s ServiceQuotaExceededException) String() string + type StartPipeInput struct + Name *string + func (s *StartPipeInput) SetName(v string) *StartPipeInput + func (s *StartPipeInput) Validate() error + func (s StartPipeInput) GoString() string + func (s StartPipeInput) String() string + type StartPipeOutput struct + Arn *string + CreationTime *time.Time + CurrentState *string + DesiredState *string + LastModifiedTime *time.Time + Name *string + func (s *StartPipeOutput) SetArn(v string) *StartPipeOutput + func (s *StartPipeOutput) SetCreationTime(v time.Time) *StartPipeOutput + func (s *StartPipeOutput) SetCurrentState(v string) *StartPipeOutput + func (s *StartPipeOutput) SetDesiredState(v string) *StartPipeOutput + func (s *StartPipeOutput) SetLastModifiedTime(v time.Time) *StartPipeOutput + func (s *StartPipeOutput) SetName(v string) *StartPipeOutput + func (s StartPipeOutput) GoString() string + func (s StartPipeOutput) String() string + type StopPipeInput struct + Name *string + func (s *StopPipeInput) SetName(v string) *StopPipeInput + func (s *StopPipeInput) Validate() error + func (s StopPipeInput) GoString() string + func (s StopPipeInput) String() string + type StopPipeOutput struct + Arn *string + CreationTime *time.Time + CurrentState *string + DesiredState *string + LastModifiedTime *time.Time + Name *string + func (s *StopPipeOutput) SetArn(v string) *StopPipeOutput + func (s *StopPipeOutput) SetCreationTime(v time.Time) *StopPipeOutput + func (s *StopPipeOutput) SetCurrentState(v string) *StopPipeOutput + func (s *StopPipeOutput) SetDesiredState(v string) *StopPipeOutput + func (s *StopPipeOutput) SetLastModifiedTime(v time.Time) *StopPipeOutput + func (s *StopPipeOutput) SetName(v string) *StopPipeOutput + func (s StopPipeOutput) GoString() string + func (s StopPipeOutput) String() string + type Tag struct + Key *string + Value *string + func (s *Tag) SetKey(v string) *Tag + func (s *Tag) SetValue(v string) *Tag + func (s *Tag) Validate() error + func (s Tag) GoString() string + func (s Tag) String() string + type TagResourceInput struct + ResourceArn *string + Tags map[string]*string + func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput + func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput + func (s *TagResourceInput) Validate() error + func (s TagResourceInput) GoString() string + func (s TagResourceInput) String() string + type TagResourceOutput struct + func (s TagResourceOutput) GoString() string + func (s TagResourceOutput) String() string + type ThrottlingException struct + Message_ *string + QuotaCode *string + RespMetadata protocol.ResponseMetadata + RetryAfterSeconds *int64 + ServiceCode *string + func (s *ThrottlingException) Code() string + func (s *ThrottlingException) Error() string + func (s *ThrottlingException) Message() string + func (s *ThrottlingException) OrigErr() error + func (s *ThrottlingException) RequestID() string + func (s *ThrottlingException) StatusCode() int + func (s ThrottlingException) GoString() string + func (s ThrottlingException) String() string + type UntagResourceInput struct + ResourceArn *string + TagKeys []*string + func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput + func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput + func (s *UntagResourceInput) Validate() error + func (s UntagResourceInput) GoString() string + func (s UntagResourceInput) String() string + type UntagResourceOutput struct + func (s UntagResourceOutput) GoString() string + func (s UntagResourceOutput) String() string + type UpdatePipeInput struct + Description *string + DesiredState *string + Enrichment *string + EnrichmentParameters *PipeEnrichmentParameters + Name *string + RoleArn *string + SourceParameters *UpdatePipeSourceParameters + Target *string + TargetParameters *PipeTargetParameters + func (s *UpdatePipeInput) SetDescription(v string) *UpdatePipeInput + func (s *UpdatePipeInput) SetDesiredState(v string) *UpdatePipeInput + func (s *UpdatePipeInput) SetEnrichment(v string) *UpdatePipeInput + func (s *UpdatePipeInput) SetEnrichmentParameters(v *PipeEnrichmentParameters) *UpdatePipeInput + func (s *UpdatePipeInput) SetName(v string) *UpdatePipeInput + func (s *UpdatePipeInput) SetRoleArn(v string) *UpdatePipeInput + func (s *UpdatePipeInput) SetSourceParameters(v *UpdatePipeSourceParameters) *UpdatePipeInput + func (s *UpdatePipeInput) SetTarget(v string) *UpdatePipeInput + func (s *UpdatePipeInput) SetTargetParameters(v *PipeTargetParameters) *UpdatePipeInput + func (s *UpdatePipeInput) Validate() error + func (s UpdatePipeInput) GoString() string + func (s UpdatePipeInput) String() string + type UpdatePipeOutput struct + Arn *string + CreationTime *time.Time + CurrentState *string + DesiredState *string + LastModifiedTime *time.Time + Name *string + func (s *UpdatePipeOutput) SetArn(v string) *UpdatePipeOutput + func (s *UpdatePipeOutput) SetCreationTime(v time.Time) *UpdatePipeOutput + func (s *UpdatePipeOutput) SetCurrentState(v string) *UpdatePipeOutput + func (s *UpdatePipeOutput) SetDesiredState(v string) *UpdatePipeOutput + func (s *UpdatePipeOutput) SetLastModifiedTime(v time.Time) *UpdatePipeOutput + func (s *UpdatePipeOutput) SetName(v string) *UpdatePipeOutput + func (s UpdatePipeOutput) GoString() string + func (s UpdatePipeOutput) String() string + type UpdatePipeSourceActiveMQBrokerParameters struct + BatchSize *int64 + Credentials *MQBrokerAccessCredentials + MaximumBatchingWindowInSeconds *int64 + func (s *UpdatePipeSourceActiveMQBrokerParameters) SetBatchSize(v int64) *UpdatePipeSourceActiveMQBrokerParameters + func (s *UpdatePipeSourceActiveMQBrokerParameters) SetCredentials(v *MQBrokerAccessCredentials) *UpdatePipeSourceActiveMQBrokerParameters + func (s *UpdatePipeSourceActiveMQBrokerParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceActiveMQBrokerParameters + func (s *UpdatePipeSourceActiveMQBrokerParameters) Validate() error + func (s UpdatePipeSourceActiveMQBrokerParameters) GoString() string + func (s UpdatePipeSourceActiveMQBrokerParameters) String() string + type UpdatePipeSourceDynamoDBStreamParameters struct + BatchSize *int64 + DeadLetterConfig *DeadLetterConfig + MaximumBatchingWindowInSeconds *int64 + MaximumRecordAgeInSeconds *int64 + MaximumRetryAttempts *int64 + OnPartialBatchItemFailure *string + ParallelizationFactor *int64 + func (s *UpdatePipeSourceDynamoDBStreamParameters) SetBatchSize(v int64) *UpdatePipeSourceDynamoDBStreamParameters + func (s *UpdatePipeSourceDynamoDBStreamParameters) SetDeadLetterConfig(v *DeadLetterConfig) *UpdatePipeSourceDynamoDBStreamParameters + func (s *UpdatePipeSourceDynamoDBStreamParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceDynamoDBStreamParameters + func (s *UpdatePipeSourceDynamoDBStreamParameters) SetMaximumRecordAgeInSeconds(v int64) *UpdatePipeSourceDynamoDBStreamParameters + func (s *UpdatePipeSourceDynamoDBStreamParameters) SetMaximumRetryAttempts(v int64) *UpdatePipeSourceDynamoDBStreamParameters + func (s *UpdatePipeSourceDynamoDBStreamParameters) SetOnPartialBatchItemFailure(v string) *UpdatePipeSourceDynamoDBStreamParameters + func (s *UpdatePipeSourceDynamoDBStreamParameters) SetParallelizationFactor(v int64) *UpdatePipeSourceDynamoDBStreamParameters + func (s *UpdatePipeSourceDynamoDBStreamParameters) Validate() error + func (s UpdatePipeSourceDynamoDBStreamParameters) GoString() string + func (s UpdatePipeSourceDynamoDBStreamParameters) String() string + type UpdatePipeSourceKinesisStreamParameters struct + BatchSize *int64 + DeadLetterConfig *DeadLetterConfig + MaximumBatchingWindowInSeconds *int64 + MaximumRecordAgeInSeconds *int64 + MaximumRetryAttempts *int64 + OnPartialBatchItemFailure *string + ParallelizationFactor *int64 + func (s *UpdatePipeSourceKinesisStreamParameters) SetBatchSize(v int64) *UpdatePipeSourceKinesisStreamParameters + func (s *UpdatePipeSourceKinesisStreamParameters) SetDeadLetterConfig(v *DeadLetterConfig) *UpdatePipeSourceKinesisStreamParameters + func (s *UpdatePipeSourceKinesisStreamParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceKinesisStreamParameters + func (s *UpdatePipeSourceKinesisStreamParameters) SetMaximumRecordAgeInSeconds(v int64) *UpdatePipeSourceKinesisStreamParameters + func (s *UpdatePipeSourceKinesisStreamParameters) SetMaximumRetryAttempts(v int64) *UpdatePipeSourceKinesisStreamParameters + func (s *UpdatePipeSourceKinesisStreamParameters) SetOnPartialBatchItemFailure(v string) *UpdatePipeSourceKinesisStreamParameters + func (s *UpdatePipeSourceKinesisStreamParameters) SetParallelizationFactor(v int64) *UpdatePipeSourceKinesisStreamParameters + func (s *UpdatePipeSourceKinesisStreamParameters) Validate() error + func (s UpdatePipeSourceKinesisStreamParameters) GoString() string + func (s UpdatePipeSourceKinesisStreamParameters) String() string + type UpdatePipeSourceManagedStreamingKafkaParameters struct + BatchSize *int64 + Credentials *MSKAccessCredentials + MaximumBatchingWindowInSeconds *int64 + func (s *UpdatePipeSourceManagedStreamingKafkaParameters) SetBatchSize(v int64) *UpdatePipeSourceManagedStreamingKafkaParameters + func (s *UpdatePipeSourceManagedStreamingKafkaParameters) SetCredentials(v *MSKAccessCredentials) *UpdatePipeSourceManagedStreamingKafkaParameters + func (s *UpdatePipeSourceManagedStreamingKafkaParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceManagedStreamingKafkaParameters + func (s *UpdatePipeSourceManagedStreamingKafkaParameters) Validate() error + func (s UpdatePipeSourceManagedStreamingKafkaParameters) GoString() string + func (s UpdatePipeSourceManagedStreamingKafkaParameters) String() string + type UpdatePipeSourceParameters struct + ActiveMQBrokerParameters *UpdatePipeSourceActiveMQBrokerParameters + DynamoDBStreamParameters *UpdatePipeSourceDynamoDBStreamParameters + FilterCriteria *FilterCriteria + KinesisStreamParameters *UpdatePipeSourceKinesisStreamParameters + ManagedStreamingKafkaParameters *UpdatePipeSourceManagedStreamingKafkaParameters + RabbitMQBrokerParameters *UpdatePipeSourceRabbitMQBrokerParameters + SelfManagedKafkaParameters *UpdatePipeSourceSelfManagedKafkaParameters + SqsQueueParameters *UpdatePipeSourceSqsQueueParameters + func (s *UpdatePipeSourceParameters) SetActiveMQBrokerParameters(v *UpdatePipeSourceActiveMQBrokerParameters) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) SetDynamoDBStreamParameters(v *UpdatePipeSourceDynamoDBStreamParameters) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) SetFilterCriteria(v *FilterCriteria) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) SetKinesisStreamParameters(v *UpdatePipeSourceKinesisStreamParameters) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) SetManagedStreamingKafkaParameters(v *UpdatePipeSourceManagedStreamingKafkaParameters) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) SetRabbitMQBrokerParameters(v *UpdatePipeSourceRabbitMQBrokerParameters) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) SetSelfManagedKafkaParameters(v *UpdatePipeSourceSelfManagedKafkaParameters) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) SetSqsQueueParameters(v *UpdatePipeSourceSqsQueueParameters) *UpdatePipeSourceParameters + func (s *UpdatePipeSourceParameters) Validate() error + func (s UpdatePipeSourceParameters) GoString() string + func (s UpdatePipeSourceParameters) String() string + type UpdatePipeSourceRabbitMQBrokerParameters struct + BatchSize *int64 + Credentials *MQBrokerAccessCredentials + MaximumBatchingWindowInSeconds *int64 + func (s *UpdatePipeSourceRabbitMQBrokerParameters) SetBatchSize(v int64) *UpdatePipeSourceRabbitMQBrokerParameters + func (s *UpdatePipeSourceRabbitMQBrokerParameters) SetCredentials(v *MQBrokerAccessCredentials) *UpdatePipeSourceRabbitMQBrokerParameters + func (s *UpdatePipeSourceRabbitMQBrokerParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceRabbitMQBrokerParameters + func (s *UpdatePipeSourceRabbitMQBrokerParameters) Validate() error + func (s UpdatePipeSourceRabbitMQBrokerParameters) GoString() string + func (s UpdatePipeSourceRabbitMQBrokerParameters) String() string + type UpdatePipeSourceSelfManagedKafkaParameters struct + BatchSize *int64 + Credentials *SelfManagedKafkaAccessConfigurationCredentials + MaximumBatchingWindowInSeconds *int64 + ServerRootCaCertificate *string + Vpc *SelfManagedKafkaAccessConfigurationVpc + func (s *UpdatePipeSourceSelfManagedKafkaParameters) SetBatchSize(v int64) *UpdatePipeSourceSelfManagedKafkaParameters + func (s *UpdatePipeSourceSelfManagedKafkaParameters) SetCredentials(v *SelfManagedKafkaAccessConfigurationCredentials) *UpdatePipeSourceSelfManagedKafkaParameters + func (s *UpdatePipeSourceSelfManagedKafkaParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceSelfManagedKafkaParameters + func (s *UpdatePipeSourceSelfManagedKafkaParameters) SetServerRootCaCertificate(v string) *UpdatePipeSourceSelfManagedKafkaParameters + func (s *UpdatePipeSourceSelfManagedKafkaParameters) SetVpc(v *SelfManagedKafkaAccessConfigurationVpc) *UpdatePipeSourceSelfManagedKafkaParameters + func (s *UpdatePipeSourceSelfManagedKafkaParameters) Validate() error + func (s UpdatePipeSourceSelfManagedKafkaParameters) GoString() string + func (s UpdatePipeSourceSelfManagedKafkaParameters) String() string + type UpdatePipeSourceSqsQueueParameters struct + BatchSize *int64 + MaximumBatchingWindowInSeconds *int64 + func (s *UpdatePipeSourceSqsQueueParameters) SetBatchSize(v int64) *UpdatePipeSourceSqsQueueParameters + func (s *UpdatePipeSourceSqsQueueParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceSqsQueueParameters + func (s *UpdatePipeSourceSqsQueueParameters) Validate() error + func (s UpdatePipeSourceSqsQueueParameters) GoString() string + func (s UpdatePipeSourceSqsQueueParameters) String() string + type ValidationException struct + FieldList []*ValidationExceptionField + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ValidationException) Code() string + func (s *ValidationException) Error() string + func (s *ValidationException) Message() string + func (s *ValidationException) OrigErr() error + func (s *ValidationException) RequestID() string + func (s *ValidationException) StatusCode() int + func (s ValidationException) GoString() string + func (s ValidationException) String() string + type ValidationExceptionField struct + Message *string + Name *string + func (s *ValidationExceptionField) SetMessage(v string) *ValidationExceptionField + func (s *ValidationExceptionField) SetName(v string) *ValidationExceptionField + func (s ValidationExceptionField) GoString() string + func (s ValidationExceptionField) String() string