pipes

package
v1.48.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package pipes provides the client and types for making API requests to Amazon EventBridge Pipes.

Amazon EventBridge Pipes connects event sources to targets. Pipes reduces the need for specialized knowledge and integration code when developing event driven architectures. This helps ensures consistency across your company’s applications. With Pipes, the target can be any available EventBridge target. To set up a pipe, you select the event source, add optional event filtering, define optional enrichment, and select the target for the event data.

See https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07 for more information on this service.

See pipes package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/pipes/

Using the Client

To contact Amazon EventBridge Pipes with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.

See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/

See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config

See the Amazon EventBridge Pipes client Pipes for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/pipes/#New

Index

Constants

View Source
const (
	// AssignPublicIpEnabled is a AssignPublicIp enum value
	AssignPublicIpEnabled = "ENABLED"

	// AssignPublicIpDisabled is a AssignPublicIp enum value
	AssignPublicIpDisabled = "DISABLED"
)
View Source
const (
	// BatchJobDependencyTypeNToN is a BatchJobDependencyType enum value
	BatchJobDependencyTypeNToN = "N_TO_N"

	// BatchJobDependencyTypeSequential is a BatchJobDependencyType enum value
	BatchJobDependencyTypeSequential = "SEQUENTIAL"
)
View Source
const (
	// BatchResourceRequirementTypeGpu is a BatchResourceRequirementType enum value
	BatchResourceRequirementTypeGpu = "GPU"

	// BatchResourceRequirementTypeMemory is a BatchResourceRequirementType enum value
	BatchResourceRequirementTypeMemory = "MEMORY"

	// BatchResourceRequirementTypeVcpu is a BatchResourceRequirementType enum value
	BatchResourceRequirementTypeVcpu = "VCPU"
)
View Source
const (
	// DynamoDBStreamStartPositionTrimHorizon is a DynamoDBStreamStartPosition enum value
	DynamoDBStreamStartPositionTrimHorizon = "TRIM_HORIZON"

	// DynamoDBStreamStartPositionLatest is a DynamoDBStreamStartPosition enum value
	DynamoDBStreamStartPositionLatest = "LATEST"
)
View Source
const (
	// EcsResourceRequirementTypeGpu is a EcsResourceRequirementType enum value
	EcsResourceRequirementTypeGpu = "GPU"

	// EcsResourceRequirementTypeInferenceAccelerator is a EcsResourceRequirementType enum value
	EcsResourceRequirementTypeInferenceAccelerator = "InferenceAccelerator"
)
View Source
const (
	// KinesisStreamStartPositionTrimHorizon is a KinesisStreamStartPosition enum value
	KinesisStreamStartPositionTrimHorizon = "TRIM_HORIZON"

	// KinesisStreamStartPositionLatest is a KinesisStreamStartPosition enum value
	KinesisStreamStartPositionLatest = "LATEST"

	// KinesisStreamStartPositionAtTimestamp is a KinesisStreamStartPosition enum value
	KinesisStreamStartPositionAtTimestamp = "AT_TIMESTAMP"
)
View Source
const (
	// LaunchTypeEc2 is a LaunchType enum value
	LaunchTypeEc2 = "EC2"

	// LaunchTypeFargate is a LaunchType enum value
	LaunchTypeFargate = "FARGATE"

	// LaunchTypeExternal is a LaunchType enum value
	LaunchTypeExternal = "EXTERNAL"
)
View Source
const (
	// LogLevelOff is a LogLevel enum value
	LogLevelOff = "OFF"

	// LogLevelError is a LogLevel enum value
	LogLevelError = "ERROR"

	// LogLevelInfo is a LogLevel enum value
	LogLevelInfo = "INFO"

	// LogLevelTrace is a LogLevel enum value
	LogLevelTrace = "TRACE"
)
View Source
const (
	// MSKStartPositionTrimHorizon is a MSKStartPosition enum value
	MSKStartPositionTrimHorizon = "TRIM_HORIZON"

	// MSKStartPositionLatest is a MSKStartPosition enum value
	MSKStartPositionLatest = "LATEST"
)
View Source
const (
	// PipeStateRunning is a PipeState enum value
	PipeStateRunning = "RUNNING"

	// PipeStateStopped is a PipeState enum value
	PipeStateStopped = "STOPPED"

	// PipeStateCreating is a PipeState enum value
	PipeStateCreating = "CREATING"

	// PipeStateUpdating is a PipeState enum value
	PipeStateUpdating = "UPDATING"

	// PipeStateDeleting is a PipeState enum value
	PipeStateDeleting = "DELETING"

	// PipeStateStarting is a PipeState enum value
	PipeStateStarting = "STARTING"

	// PipeStateStopping is a PipeState enum value
	PipeStateStopping = "STOPPING"

	// PipeStateCreateFailed is a PipeState enum value
	PipeStateCreateFailed = "CREATE_FAILED"

	// PipeStateUpdateFailed is a PipeState enum value
	PipeStateUpdateFailed = "UPDATE_FAILED"

	// PipeStateStartFailed is a PipeState enum value
	PipeStateStartFailed = "START_FAILED"

	// PipeStateStopFailed is a PipeState enum value
	PipeStateStopFailed = "STOP_FAILED"

	// PipeStateDeleteFailed is a PipeState enum value
	PipeStateDeleteFailed = "DELETE_FAILED"

	// PipeStateCreateRollbackFailed is a PipeState enum value
	PipeStateCreateRollbackFailed = "CREATE_ROLLBACK_FAILED"

	// PipeStateDeleteRollbackFailed is a PipeState enum value
	PipeStateDeleteRollbackFailed = "DELETE_ROLLBACK_FAILED"

	// PipeStateUpdateRollbackFailed is a PipeState enum value
	PipeStateUpdateRollbackFailed = "UPDATE_ROLLBACK_FAILED"
)
View Source
const (
	// PipeTargetInvocationTypeRequestResponse is a PipeTargetInvocationType enum value
	PipeTargetInvocationTypeRequestResponse = "REQUEST_RESPONSE"

	// PipeTargetInvocationTypeFireAndForget is a PipeTargetInvocationType enum value
	PipeTargetInvocationTypeFireAndForget = "FIRE_AND_FORGET"
)
View Source
const (
	// PlacementConstraintTypeDistinctInstance is a PlacementConstraintType enum value
	PlacementConstraintTypeDistinctInstance = "distinctInstance"

	// PlacementConstraintTypeMemberOf is a PlacementConstraintType enum value
	PlacementConstraintTypeMemberOf = "memberOf"
)
View Source
const (
	// PlacementStrategyTypeRandom is a PlacementStrategyType enum value
	PlacementStrategyTypeRandom = "random"

	// PlacementStrategyTypeSpread is a PlacementStrategyType enum value
	PlacementStrategyTypeSpread = "spread"

	// PlacementStrategyTypeBinpack is a PlacementStrategyType enum value
	PlacementStrategyTypeBinpack = "binpack"
)
View Source
const (
	// RequestedPipeStateRunning is a RequestedPipeState enum value
	RequestedPipeStateRunning = "RUNNING"

	// RequestedPipeStateStopped is a RequestedPipeState enum value
	RequestedPipeStateStopped = "STOPPED"
)
View Source
const (
	// RequestedPipeStateDescribeResponseRunning is a RequestedPipeStateDescribeResponse enum value
	RequestedPipeStateDescribeResponseRunning = "RUNNING"

	// RequestedPipeStateDescribeResponseStopped is a RequestedPipeStateDescribeResponse enum value
	RequestedPipeStateDescribeResponseStopped = "STOPPED"

	// RequestedPipeStateDescribeResponseDeleted is a RequestedPipeStateDescribeResponse enum value
	RequestedPipeStateDescribeResponseDeleted = "DELETED"
)
View Source
const (
	// S3OutputFormatJson is a S3OutputFormat enum value
	S3OutputFormatJson = "json"

	// S3OutputFormatPlain is a S3OutputFormat enum value
	S3OutputFormatPlain = "plain"

	// S3OutputFormatW3c is a S3OutputFormat enum value
	S3OutputFormatW3c = "w3c"
)
View Source
const (
	// SelfManagedKafkaStartPositionTrimHorizon is a SelfManagedKafkaStartPosition enum value
	SelfManagedKafkaStartPositionTrimHorizon = "TRIM_HORIZON"

	// SelfManagedKafkaStartPositionLatest is a SelfManagedKafkaStartPosition enum value
	SelfManagedKafkaStartPositionLatest = "LATEST"
)
View Source
const (

	// ErrCodeConflictException for service response error code
	// "ConflictException".
	//
	// An action you attempted resulted in an exception.
	ErrCodeConflictException = "ConflictException"

	// ErrCodeInternalException for service response error code
	// "InternalException".
	//
	// This exception occurs due to unexpected causes.
	ErrCodeInternalException = "InternalException"

	// ErrCodeNotFoundException for service response error code
	// "NotFoundException".
	//
	// An entity that you specified does not exist.
	ErrCodeNotFoundException = "NotFoundException"

	// ErrCodeServiceQuotaExceededException for service response error code
	// "ServiceQuotaExceededException".
	//
	// A quota has been exceeded.
	ErrCodeServiceQuotaExceededException = "ServiceQuotaExceededException"

	// ErrCodeThrottlingException for service response error code
	// "ThrottlingException".
	//
	// An action was throttled.
	ErrCodeThrottlingException = "ThrottlingException"

	// ErrCodeValidationException for service response error code
	// "ValidationException".
	//
	// Indicates that an error has occurred while performing a validate operation.
	ErrCodeValidationException = "ValidationException"
)
View Source
const (
	ServiceName = "Pipes" // Name of service.
	EndpointsID = "pipes" // ID to lookup a service endpoint with.
	ServiceID   = "Pipes" // ServiceID is a unique identifier of a specific service.
)

Service information constants

View Source
const (
	// EcsEnvironmentFileTypeS3 is a EcsEnvironmentFileType enum value
	EcsEnvironmentFileTypeS3 = "s3"
)
View Source
const (
	// IncludeExecutionDataOptionAll is a IncludeExecutionDataOption enum value
	IncludeExecutionDataOptionAll = "ALL"
)
View Source
const (
	// OnPartialBatchItemFailureStreamsAutomaticBisect is a OnPartialBatchItemFailureStreams enum value
	OnPartialBatchItemFailureStreamsAutomaticBisect = "AUTOMATIC_BISECT"
)
View Source
const (
	// PropagateTagsTaskDefinition is a PropagateTags enum value
	PropagateTagsTaskDefinition = "TASK_DEFINITION"
)

Variables

This section is empty.

Functions

func AssignPublicIp_Values

func AssignPublicIp_Values() []string

AssignPublicIp_Values returns all elements of the AssignPublicIp enum

func BatchJobDependencyType_Values

func BatchJobDependencyType_Values() []string

BatchJobDependencyType_Values returns all elements of the BatchJobDependencyType enum

func BatchResourceRequirementType_Values

func BatchResourceRequirementType_Values() []string

BatchResourceRequirementType_Values returns all elements of the BatchResourceRequirementType enum

func DynamoDBStreamStartPosition_Values

func DynamoDBStreamStartPosition_Values() []string

DynamoDBStreamStartPosition_Values returns all elements of the DynamoDBStreamStartPosition enum

func EcsEnvironmentFileType_Values

func EcsEnvironmentFileType_Values() []string

EcsEnvironmentFileType_Values returns all elements of the EcsEnvironmentFileType enum

func EcsResourceRequirementType_Values

func EcsResourceRequirementType_Values() []string

EcsResourceRequirementType_Values returns all elements of the EcsResourceRequirementType enum

func IncludeExecutionDataOption_Values

func IncludeExecutionDataOption_Values() []string

IncludeExecutionDataOption_Values returns all elements of the IncludeExecutionDataOption enum

func KinesisStreamStartPosition_Values

func KinesisStreamStartPosition_Values() []string

KinesisStreamStartPosition_Values returns all elements of the KinesisStreamStartPosition enum

func LaunchType_Values

func LaunchType_Values() []string

LaunchType_Values returns all elements of the LaunchType enum

func LogLevel_Values

func LogLevel_Values() []string

LogLevel_Values returns all elements of the LogLevel enum

func MSKStartPosition_Values

func MSKStartPosition_Values() []string

MSKStartPosition_Values returns all elements of the MSKStartPosition enum

func OnPartialBatchItemFailureStreams_Values

func OnPartialBatchItemFailureStreams_Values() []string

OnPartialBatchItemFailureStreams_Values returns all elements of the OnPartialBatchItemFailureStreams enum

func PipeState_Values

func PipeState_Values() []string

PipeState_Values returns all elements of the PipeState enum

func PipeTargetInvocationType_Values

func PipeTargetInvocationType_Values() []string

PipeTargetInvocationType_Values returns all elements of the PipeTargetInvocationType enum

func PlacementConstraintType_Values

func PlacementConstraintType_Values() []string

PlacementConstraintType_Values returns all elements of the PlacementConstraintType enum

func PlacementStrategyType_Values

func PlacementStrategyType_Values() []string

PlacementStrategyType_Values returns all elements of the PlacementStrategyType enum

func PropagateTags_Values

func PropagateTags_Values() []string

PropagateTags_Values returns all elements of the PropagateTags enum

func RequestedPipeStateDescribeResponse_Values

func RequestedPipeStateDescribeResponse_Values() []string

RequestedPipeStateDescribeResponse_Values returns all elements of the RequestedPipeStateDescribeResponse enum

func RequestedPipeState_Values

func RequestedPipeState_Values() []string

RequestedPipeState_Values returns all elements of the RequestedPipeState enum

func S3OutputFormat_Values

func S3OutputFormat_Values() []string

S3OutputFormat_Values returns all elements of the S3OutputFormat enum

func SelfManagedKafkaStartPosition_Values

func SelfManagedKafkaStartPosition_Values() []string

SelfManagedKafkaStartPosition_Values returns all elements of the SelfManagedKafkaStartPosition enum

Types

type AwsVpcConfiguration

type AwsVpcConfiguration struct {

	// Specifies whether the task's elastic network interface receives a public
	// IP address. You can specify ENABLED only when LaunchType in EcsParameters
	// is set to FARGATE.
	AssignPublicIp *string `type:"string" enum:"AssignPublicIp"`

	// Specifies the security groups associated with the task. These security groups
	// must all be in the same VPC. You can specify as many as five security groups.
	// If you do not specify a security group, the default security group for the
	// VPC is used.
	SecurityGroups []*string `type:"list"`

	// Specifies the subnets associated with the task. These subnets must all be
	// in the same VPC. You can specify as many as 16 subnets.
	//
	// Subnets is a required field
	Subnets []*string `type:"list" required:"true"`
	// contains filtered or unexported fields
}

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.

func (AwsVpcConfiguration) GoString

func (s AwsVpcConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*AwsVpcConfiguration) SetAssignPublicIp

func (s *AwsVpcConfiguration) SetAssignPublicIp(v string) *AwsVpcConfiguration

SetAssignPublicIp sets the AssignPublicIp field's value.

func (*AwsVpcConfiguration) SetSecurityGroups

func (s *AwsVpcConfiguration) SetSecurityGroups(v []*string) *AwsVpcConfiguration

SetSecurityGroups sets the SecurityGroups field's value.

func (*AwsVpcConfiguration) SetSubnets

func (s *AwsVpcConfiguration) SetSubnets(v []*string) *AwsVpcConfiguration

SetSubnets sets the Subnets field's value.

func (AwsVpcConfiguration) String

func (s AwsVpcConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*AwsVpcConfiguration) Validate

func (s *AwsVpcConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type BatchArrayProperties

type BatchArrayProperties struct {

	// The size of the array, if this is an array batch job.
	Size *int64 `min:"2" type:"integer"`
	// contains filtered or unexported fields
}

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.

func (BatchArrayProperties) GoString

func (s BatchArrayProperties) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchArrayProperties) SetSize

SetSize sets the Size field's value.

func (BatchArrayProperties) String

func (s BatchArrayProperties) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchArrayProperties) Validate

func (s *BatchArrayProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type BatchContainerOverrides

type BatchContainerOverrides struct {

	// The command to send to the container that overrides the default command from
	// the Docker image or the task definition.
	Command []*string `type:"list"`

	// The environment variables to send to the container. You can add new environment
	// variables, which are added to the container at launch, or you can override
	// the existing environment variables from the Docker image or the task definition.
	//
	// Environment variables cannot start with "Batch". This naming convention is
	// reserved for variables that Batch sets.
	Environment []*BatchEnvironmentVariable `type:"list"`

	// The instance type to use for a multi-node parallel job.
	//
	// This parameter isn't applicable to single-node container jobs or jobs that
	// run on Fargate resources, and shouldn't be provided.
	InstanceType *string `type:"string"`

	// The type and amount of resources to assign to a container. This overrides
	// the settings in the job definition. The supported resources include GPU,
	// MEMORY, and VCPU.
	ResourceRequirements []*BatchResourceRequirement `type:"list"`
	// contains filtered or unexported fields
}

The overrides that are sent to a container.

func (BatchContainerOverrides) GoString

func (s BatchContainerOverrides) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchContainerOverrides) SetCommand

SetCommand sets the Command field's value.

func (*BatchContainerOverrides) SetEnvironment

SetEnvironment sets the Environment field's value.

func (*BatchContainerOverrides) SetInstanceType

SetInstanceType sets the InstanceType field's value.

func (*BatchContainerOverrides) SetResourceRequirements

SetResourceRequirements sets the ResourceRequirements field's value.

func (BatchContainerOverrides) String

func (s BatchContainerOverrides) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchContainerOverrides) Validate

func (s *BatchContainerOverrides) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type BatchEnvironmentVariable

type BatchEnvironmentVariable struct {

	// The name of the key-value pair. For environment variables, this is the name
	// of the environment variable.
	Name *string `type:"string"`

	// The value of the key-value pair. For environment variables, this is the value
	// of the environment variable.
	Value *string `type:"string"`
	// contains filtered or unexported fields
}

The environment variables to send to the container. You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition.

Environment variables cannot start with "Batch". This naming convention is reserved for variables that Batch sets.

func (BatchEnvironmentVariable) GoString

func (s BatchEnvironmentVariable) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchEnvironmentVariable) SetName

SetName sets the Name field's value.

func (*BatchEnvironmentVariable) SetValue

SetValue sets the Value field's value.

func (BatchEnvironmentVariable) String

func (s BatchEnvironmentVariable) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type BatchJobDependency

type BatchJobDependency struct {

	// The job ID of the Batch job that's associated with this dependency.
	JobId *string `type:"string"`

	// The type of the job dependency.
	Type *string `type:"string" enum:"BatchJobDependencyType"`
	// contains filtered or unexported fields
}

An object that represents an Batch job dependency.

func (BatchJobDependency) GoString

func (s BatchJobDependency) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchJobDependency) SetJobId

SetJobId sets the JobId field's value.

func (*BatchJobDependency) SetType

SetType sets the Type field's value.

func (BatchJobDependency) String

func (s BatchJobDependency) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type BatchResourceRequirement

type BatchResourceRequirement struct {

	// The type of resource to assign to a container. The supported resources include
	// GPU, MEMORY, and VCPU.
	//
	// Type is a required field
	Type *string `type:"string" required:"true" enum:"BatchResourceRequirementType"`

	// The quantity of the specified resource to reserve for the container. The
	// values vary based on the type specified.
	//
	// type="GPU"
	//
	// The number of physical GPUs to reserve for the container. Make sure that
	// the number of GPUs reserved for all containers in a job doesn't exceed the
	// number of available GPUs on the compute resource that the job is launched
	// on.
	//
	// GPUs aren't available for jobs that are running on Fargate resources.
	//
	// type="MEMORY"
	//
	// The memory hard limit (in MiB) present to the container. This parameter is
	// supported for jobs that are running on EC2 resources. If your container attempts
	// to exceed the memory specified, the container is terminated. This parameter
	// maps to Memory in the Create a container (https://docs.docker.com/engine/api/v1.23/#create-a-container)
	// section of the Docker Remote API (https://docs.docker.com/engine/api/v1.23/)
	// and the --memory option to docker run (https://docs.docker.com/engine/reference/run/).
	// You must specify at least 4 MiB of memory for a job. This is required but
	// can be specified in several places for multi-node parallel (MNP) jobs. It
	// must be specified for each node at least once. This parameter maps to Memory
	// in the Create a container (https://docs.docker.com/engine/api/v1.23/#create-a-container)
	// section of the Docker Remote API (https://docs.docker.com/engine/api/v1.23/)
	// and the --memory option to docker run (https://docs.docker.com/engine/reference/run/).
	//
	// If you're trying to maximize your resource utilization by providing your
	// jobs as much memory as possible for a particular instance type, see Memory
	// management (https://docs.aws.amazon.com/batch/latest/userguide/memory-management.html)
	// in the Batch User Guide.
	//
	// For jobs that are running on Fargate resources, then value is the hard limit
	// (in MiB), and must match one of the supported values and the VCPU values
	// must be one of the values supported for that memory value.
	//
	// value = 512
	//
	// VCPU = 0.25
	//
	// value = 1024
	//
	// VCPU = 0.25 or 0.5
	//
	// value = 2048
	//
	// VCPU = 0.25, 0.5, or 1
	//
	// value = 3072
	//
	// VCPU = 0.5, or 1
	//
	// value = 4096
	//
	// VCPU = 0.5, 1, or 2
	//
	// value = 5120, 6144, or 7168
	//
	// VCPU = 1 or 2
	//
	// value = 8192
	//
	// VCPU = 1, 2, 4, or 8
	//
	// value = 9216, 10240, 11264, 12288, 13312, 14336, or 15360
	//
	// VCPU = 2 or 4
	//
	// value = 16384
	//
	// VCPU = 2, 4, or 8
	//
	// value = 17408, 18432, 19456, 21504, 22528, 23552, 25600, 26624, 27648, 29696,
	// or 30720
	//
	// VCPU = 4
	//
	// value = 20480, 24576, or 28672
	//
	// VCPU = 4 or 8
	//
	// value = 36864, 45056, 53248, or 61440
	//
	// VCPU = 8
	//
	// value = 32768, 40960, 49152, or 57344
	//
	// VCPU = 8 or 16
	//
	// value = 65536, 73728, 81920, 90112, 98304, 106496, 114688, or 122880
	//
	// VCPU = 16
	//
	// type="VCPU"
	//
	// The number of vCPUs reserved for the container. This parameter maps to CpuShares
	// in the Create a container (https://docs.docker.com/engine/api/v1.23/#create-a-container)
	// section of the Docker Remote API (https://docs.docker.com/engine/api/v1.23/)
	// and the --cpu-shares option to docker run (https://docs.docker.com/engine/reference/run/).
	// Each vCPU is equivalent to 1,024 CPU shares. For EC2 resources, you must
	// specify at least one vCPU. This is required but can be specified in several
	// places; it must be specified for each node at least once.
	//
	// The default for the Fargate On-Demand vCPU resource count quota is 6 vCPUs.
	// For more information about Fargate quotas, see Fargate quotas (https://docs.aws.amazon.com/general/latest/gr/ecs-service.html#service-quotas-fargate)
	// in the Amazon Web Services General Reference.
	//
	// For jobs that are running on Fargate resources, then value must match one
	// of the supported values and the MEMORY values must be one of the values supported
	// for that VCPU value. The supported values are 0.25, 0.5, 1, 2, 4, 8, and
	// 16
	//
	// value = 0.25
	//
	// MEMORY = 512, 1024, or 2048
	//
	// value = 0.5
	//
	// MEMORY = 1024, 2048, 3072, or 4096
	//
	// value = 1
	//
	// MEMORY = 2048, 3072, 4096, 5120, 6144, 7168, or 8192
	//
	// value = 2
	//
	// MEMORY = 4096, 5120, 6144, 7168, 8192, 9216, 10240, 11264, 12288, 13312,
	// 14336, 15360, or 16384
	//
	// value = 4
	//
	// MEMORY = 8192, 9216, 10240, 11264, 12288, 13312, 14336, 15360, 16384, 17408,
	// 18432, 19456, 20480, 21504, 22528, 23552, 24576, 25600, 26624, 27648, 28672,
	// 29696, or 30720
	//
	// value = 8
	//
	// MEMORY = 16384, 20480, 24576, 28672, 32768, 36864, 40960, 45056, 49152, 53248,
	// 57344, or 61440
	//
	// value = 16
	//
	// MEMORY = 32768, 40960, 49152, 57344, 65536, 73728, 81920, 90112, 98304, 106496,
	// 114688, or 122880
	//
	// Value is a required field
	Value *string `type:"string" required:"true"`
	// contains filtered or unexported fields
}

The type and amount of a resource to assign to a container. The supported resources include GPU, MEMORY, and VCPU.

func (BatchResourceRequirement) GoString

func (s BatchResourceRequirement) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchResourceRequirement) SetType

SetType sets the Type field's value.

func (*BatchResourceRequirement) SetValue

SetValue sets the Value field's value.

func (BatchResourceRequirement) String

func (s BatchResourceRequirement) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchResourceRequirement) Validate

func (s *BatchResourceRequirement) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type BatchRetryStrategy

type BatchRetryStrategy struct {

	// The number of times to move a job to the RUNNABLE status. If the value of
	// attempts is greater than one, the job is retried on failure the same number
	// of attempts as the value.
	Attempts *int64 `min:"1" type:"integer"`
	// contains filtered or unexported fields
}

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.

func (BatchRetryStrategy) GoString

func (s BatchRetryStrategy) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchRetryStrategy) SetAttempts

func (s *BatchRetryStrategy) SetAttempts(v int64) *BatchRetryStrategy

SetAttempts sets the Attempts field's value.

func (BatchRetryStrategy) String

func (s BatchRetryStrategy) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*BatchRetryStrategy) Validate

func (s *BatchRetryStrategy) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CapacityProviderStrategyItem

type CapacityProviderStrategyItem struct {

	// The base value designates how many tasks, at a minimum, to run on the specified
	// capacity provider. Only one capacity provider in a capacity provider strategy
	// can have a base defined. If no value is specified, the default value of 0
	// is used.
	Base *int64 `locationName:"base" type:"integer"`

	// The short name of the capacity provider.
	//
	// CapacityProvider is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by CapacityProviderStrategyItem's
	// String and GoString methods.
	//
	// CapacityProvider is a required field
	CapacityProvider *string `locationName:"capacityProvider" min:"1" type:"string" required:"true" sensitive:"true"`

	// The weight value designates the relative percentage of the total number of
	// tasks launched that should use the specified capacity provider. The weight
	// value is taken into consideration after the base value, if defined, is satisfied.
	Weight *int64 `locationName:"weight" type:"integer"`
	// contains filtered or unexported fields
}

The details of a capacity provider strategy. To learn more, see CapacityProviderStrategyItem (https://docs.aws.amazon.com/AmazonECS/latest/APIReference/API_CapacityProviderStrategyItem.html) in the Amazon ECS API Reference.

func (CapacityProviderStrategyItem) GoString

func (s CapacityProviderStrategyItem) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CapacityProviderStrategyItem) SetBase

SetBase sets the Base field's value.

func (*CapacityProviderStrategyItem) SetCapacityProvider

SetCapacityProvider sets the CapacityProvider field's value.

func (*CapacityProviderStrategyItem) SetWeight

SetWeight sets the Weight field's value.

func (CapacityProviderStrategyItem) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CapacityProviderStrategyItem) Validate

func (s *CapacityProviderStrategyItem) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CloudwatchLogsLogDestination

type CloudwatchLogsLogDestination struct {

	// The Amazon Web Services Resource Name (ARN) for the CloudWatch log group
	// to which EventBridge sends the log records.
	LogGroupArn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The Amazon CloudWatch Logs logging configuration settings for the pipe.

func (CloudwatchLogsLogDestination) GoString

func (s CloudwatchLogsLogDestination) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CloudwatchLogsLogDestination) SetLogGroupArn

SetLogGroupArn sets the LogGroupArn field's value.

func (CloudwatchLogsLogDestination) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CloudwatchLogsLogDestinationParameters

type CloudwatchLogsLogDestinationParameters struct {

	// The Amazon Web Services Resource Name (ARN) for the CloudWatch log group
	// to which EventBridge sends the log records.
	//
	// LogGroupArn is a required field
	LogGroupArn *string `min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The Amazon CloudWatch Logs logging configuration settings for the pipe.

func (CloudwatchLogsLogDestinationParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CloudwatchLogsLogDestinationParameters) SetLogGroupArn

SetLogGroupArn sets the LogGroupArn field's value.

func (CloudwatchLogsLogDestinationParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CloudwatchLogsLogDestinationParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type ConflictException

type ConflictException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`

	// The ID of the resource that caused the exception.
	//
	// ResourceId is a required field
	ResourceId *string `locationName:"resourceId" type:"string" required:"true"`

	// The type of resource that caused the exception.
	//
	// ResourceType is a required field
	ResourceType *string `locationName:"resourceType" type:"string" required:"true"`
	// contains filtered or unexported fields
}

An action you attempted resulted in an exception.

func (*ConflictException) Code

func (s *ConflictException) Code() string

Code returns the exception type name.

func (*ConflictException) Error

func (s *ConflictException) Error() string

func (ConflictException) GoString

func (s ConflictException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ConflictException) Message

func (s *ConflictException) Message() string

Message returns the exception's message.

func (*ConflictException) OrigErr

func (s *ConflictException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConflictException) RequestID

func (s *ConflictException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConflictException) StatusCode

func (s *ConflictException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ConflictException) String

func (s ConflictException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CreatePipeInput

type CreatePipeInput struct {

	// A description of the pipe.
	//
	// Description is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by CreatePipeInput's
	// String and GoString methods.
	Description *string `type:"string" sensitive:"true"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeState"`

	// The ARN of the enrichment resource.
	Enrichment *string `type:"string"`

	// The parameters required to set up enrichment on your pipe.
	EnrichmentParameters *PipeEnrichmentParameters `type:"structure"`

	// The logging configuration settings for the pipe.
	LogConfiguration *PipeLogConfigurationParameters `type:"structure"`

	// The name of the pipe.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`

	// The ARN of the role that allows the pipe to send data to the target.
	//
	// RoleArn is a required field
	RoleArn *string `min:"1" type:"string" required:"true"`

	// The ARN of the source resource.
	//
	// Source is a required field
	Source *string `min:"1" type:"string" required:"true"`

	// The parameters required to set up a source for your pipe.
	SourceParameters *PipeSourceParameters `type:"structure"`

	// The list of key-value pairs to associate with the pipe.
	Tags map[string]*string `min:"1" type:"map"`

	// The ARN of the target resource.
	//
	// Target is a required field
	Target *string `min:"1" type:"string" required:"true"`

	// The parameters required to set up a target for your pipe.
	//
	// For more information about pipe target parameters, including how to use dynamic
	// path parameters, see Target parameters (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-target.html)
	// in the Amazon EventBridge User Guide.
	TargetParameters *PipeTargetParameters `type:"structure"`
	// contains filtered or unexported fields
}

func (CreatePipeInput) GoString

func (s CreatePipeInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreatePipeInput) SetDescription

func (s *CreatePipeInput) SetDescription(v string) *CreatePipeInput

SetDescription sets the Description field's value.

func (*CreatePipeInput) SetDesiredState

func (s *CreatePipeInput) SetDesiredState(v string) *CreatePipeInput

SetDesiredState sets the DesiredState field's value.

func (*CreatePipeInput) SetEnrichment

func (s *CreatePipeInput) SetEnrichment(v string) *CreatePipeInput

SetEnrichment sets the Enrichment field's value.

func (*CreatePipeInput) SetEnrichmentParameters

func (s *CreatePipeInput) SetEnrichmentParameters(v *PipeEnrichmentParameters) *CreatePipeInput

SetEnrichmentParameters sets the EnrichmentParameters field's value.

func (*CreatePipeInput) SetLogConfiguration

SetLogConfiguration sets the LogConfiguration field's value.

func (*CreatePipeInput) SetName

func (s *CreatePipeInput) SetName(v string) *CreatePipeInput

SetName sets the Name field's value.

func (*CreatePipeInput) SetRoleArn

func (s *CreatePipeInput) SetRoleArn(v string) *CreatePipeInput

SetRoleArn sets the RoleArn field's value.

func (*CreatePipeInput) SetSource

func (s *CreatePipeInput) SetSource(v string) *CreatePipeInput

SetSource sets the Source field's value.

func (*CreatePipeInput) SetSourceParameters

func (s *CreatePipeInput) SetSourceParameters(v *PipeSourceParameters) *CreatePipeInput

SetSourceParameters sets the SourceParameters field's value.

func (*CreatePipeInput) SetTags

func (s *CreatePipeInput) SetTags(v map[string]*string) *CreatePipeInput

SetTags sets the Tags field's value.

func (*CreatePipeInput) SetTarget

func (s *CreatePipeInput) SetTarget(v string) *CreatePipeInput

SetTarget sets the Target field's value.

func (*CreatePipeInput) SetTargetParameters

func (s *CreatePipeInput) SetTargetParameters(v *PipeTargetParameters) *CreatePipeInput

SetTargetParameters sets the TargetParameters field's value.

func (CreatePipeInput) String

func (s CreatePipeInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreatePipeInput) Validate

func (s *CreatePipeInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreatePipeOutput

type CreatePipeOutput struct {

	// The ARN of the pipe.
	Arn *string `min:"1" type:"string"`

	// The time the pipe was created.
	CreationTime *time.Time `type:"timestamp"`

	// The state the pipe is in.
	CurrentState *string `type:"string" enum:"PipeState"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeState"`

	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	LastModifiedTime *time.Time `type:"timestamp"`

	// The name of the pipe.
	Name *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (CreatePipeOutput) GoString

func (s CreatePipeOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreatePipeOutput) SetArn

SetArn sets the Arn field's value.

func (*CreatePipeOutput) SetCreationTime

func (s *CreatePipeOutput) SetCreationTime(v time.Time) *CreatePipeOutput

SetCreationTime sets the CreationTime field's value.

func (*CreatePipeOutput) SetCurrentState

func (s *CreatePipeOutput) SetCurrentState(v string) *CreatePipeOutput

SetCurrentState sets the CurrentState field's value.

func (*CreatePipeOutput) SetDesiredState

func (s *CreatePipeOutput) SetDesiredState(v string) *CreatePipeOutput

SetDesiredState sets the DesiredState field's value.

func (*CreatePipeOutput) SetLastModifiedTime

func (s *CreatePipeOutput) SetLastModifiedTime(v time.Time) *CreatePipeOutput

SetLastModifiedTime sets the LastModifiedTime field's value.

func (*CreatePipeOutput) SetName

func (s *CreatePipeOutput) SetName(v string) *CreatePipeOutput

SetName sets the Name field's value.

func (CreatePipeOutput) String

func (s CreatePipeOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type DeadLetterConfig

type DeadLetterConfig struct {

	// The ARN of the specified target for the dead-letter queue.
	//
	// For Amazon Kinesis stream and Amazon DynamoDB stream sources, specify either
	// an Amazon SNS topic or Amazon SQS queue ARN.
	Arn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

A DeadLetterConfig object that contains information about a dead-letter queue configuration.

func (DeadLetterConfig) GoString

func (s DeadLetterConfig) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeadLetterConfig) SetArn

SetArn sets the Arn field's value.

func (DeadLetterConfig) String

func (s DeadLetterConfig) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeadLetterConfig) Validate

func (s *DeadLetterConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeletePipeInput

type DeletePipeInput struct {

	// The name of the pipe.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DeletePipeInput) GoString

func (s DeletePipeInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeletePipeInput) SetName

func (s *DeletePipeInput) SetName(v string) *DeletePipeInput

SetName sets the Name field's value.

func (DeletePipeInput) String

func (s DeletePipeInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeletePipeInput) Validate

func (s *DeletePipeInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeletePipeOutput

type DeletePipeOutput struct {

	// The ARN of the pipe.
	Arn *string `min:"1" type:"string"`

	// The time the pipe was created.
	CreationTime *time.Time `type:"timestamp"`

	// The state the pipe is in.
	CurrentState *string `type:"string" enum:"PipeState"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeStateDescribeResponse"`

	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	LastModifiedTime *time.Time `type:"timestamp"`

	// The name of the pipe.
	Name *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (DeletePipeOutput) GoString

func (s DeletePipeOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeletePipeOutput) SetArn

SetArn sets the Arn field's value.

func (*DeletePipeOutput) SetCreationTime

func (s *DeletePipeOutput) SetCreationTime(v time.Time) *DeletePipeOutput

SetCreationTime sets the CreationTime field's value.

func (*DeletePipeOutput) SetCurrentState

func (s *DeletePipeOutput) SetCurrentState(v string) *DeletePipeOutput

SetCurrentState sets the CurrentState field's value.

func (*DeletePipeOutput) SetDesiredState

func (s *DeletePipeOutput) SetDesiredState(v string) *DeletePipeOutput

SetDesiredState sets the DesiredState field's value.

func (*DeletePipeOutput) SetLastModifiedTime

func (s *DeletePipeOutput) SetLastModifiedTime(v time.Time) *DeletePipeOutput

SetLastModifiedTime sets the LastModifiedTime field's value.

func (*DeletePipeOutput) SetName

func (s *DeletePipeOutput) SetName(v string) *DeletePipeOutput

SetName sets the Name field's value.

func (DeletePipeOutput) String

func (s DeletePipeOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type DescribePipeInput

type DescribePipeInput struct {

	// The name of the pipe.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DescribePipeInput) GoString

func (s DescribePipeInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribePipeInput) SetName

SetName sets the Name field's value.

func (DescribePipeInput) String

func (s DescribePipeInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribePipeInput) Validate

func (s *DescribePipeInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribePipeOutput

type DescribePipeOutput struct {

	// The ARN of the pipe.
	Arn *string `min:"1" type:"string"`

	// The time the pipe was created.
	CreationTime *time.Time `type:"timestamp"`

	// The state the pipe is in.
	CurrentState *string `type:"string" enum:"PipeState"`

	// A description of the pipe.
	//
	// Description is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by DescribePipeOutput's
	// String and GoString methods.
	Description *string `type:"string" sensitive:"true"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeStateDescribeResponse"`

	// The ARN of the enrichment resource.
	Enrichment *string `type:"string"`

	// The parameters required to set up enrichment on your pipe.
	EnrichmentParameters *PipeEnrichmentParameters `type:"structure"`

	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	LastModifiedTime *time.Time `type:"timestamp"`

	// The logging configuration settings for the pipe.
	LogConfiguration *PipeLogConfiguration `type:"structure"`

	// The name of the pipe.
	Name *string `min:"1" type:"string"`

	// The ARN of the role that allows the pipe to send data to the target.
	RoleArn *string `min:"1" type:"string"`

	// The ARN of the source resource.
	Source *string `min:"1" type:"string"`

	// The parameters required to set up a source for your pipe.
	SourceParameters *PipeSourceParameters `type:"structure"`

	// The reason the pipe is in its current state.
	StateReason *string `type:"string"`

	// The list of key-value pairs to associate with the pipe.
	Tags map[string]*string `min:"1" type:"map"`

	// The ARN of the target resource.
	Target *string `min:"1" type:"string"`

	// The parameters required to set up a target for your pipe.
	//
	// For more information about pipe target parameters, including how to use dynamic
	// path parameters, see Target parameters (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-target.html)
	// in the Amazon EventBridge User Guide.
	TargetParameters *PipeTargetParameters `type:"structure"`
	// contains filtered or unexported fields
}

func (DescribePipeOutput) GoString

func (s DescribePipeOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribePipeOutput) SetArn

SetArn sets the Arn field's value.

func (*DescribePipeOutput) SetCreationTime

func (s *DescribePipeOutput) SetCreationTime(v time.Time) *DescribePipeOutput

SetCreationTime sets the CreationTime field's value.

func (*DescribePipeOutput) SetCurrentState

func (s *DescribePipeOutput) SetCurrentState(v string) *DescribePipeOutput

SetCurrentState sets the CurrentState field's value.

func (*DescribePipeOutput) SetDescription

func (s *DescribePipeOutput) SetDescription(v string) *DescribePipeOutput

SetDescription sets the Description field's value.

func (*DescribePipeOutput) SetDesiredState

func (s *DescribePipeOutput) SetDesiredState(v string) *DescribePipeOutput

SetDesiredState sets the DesiredState field's value.

func (*DescribePipeOutput) SetEnrichment

func (s *DescribePipeOutput) SetEnrichment(v string) *DescribePipeOutput

SetEnrichment sets the Enrichment field's value.

func (*DescribePipeOutput) SetEnrichmentParameters

func (s *DescribePipeOutput) SetEnrichmentParameters(v *PipeEnrichmentParameters) *DescribePipeOutput

SetEnrichmentParameters sets the EnrichmentParameters field's value.

func (*DescribePipeOutput) SetLastModifiedTime

func (s *DescribePipeOutput) SetLastModifiedTime(v time.Time) *DescribePipeOutput

SetLastModifiedTime sets the LastModifiedTime field's value.

func (*DescribePipeOutput) SetLogConfiguration

func (s *DescribePipeOutput) SetLogConfiguration(v *PipeLogConfiguration) *DescribePipeOutput

SetLogConfiguration sets the LogConfiguration field's value.

func (*DescribePipeOutput) SetName

SetName sets the Name field's value.

func (*DescribePipeOutput) SetRoleArn

func (s *DescribePipeOutput) SetRoleArn(v string) *DescribePipeOutput

SetRoleArn sets the RoleArn field's value.

func (*DescribePipeOutput) SetSource

func (s *DescribePipeOutput) SetSource(v string) *DescribePipeOutput

SetSource sets the Source field's value.

func (*DescribePipeOutput) SetSourceParameters

func (s *DescribePipeOutput) SetSourceParameters(v *PipeSourceParameters) *DescribePipeOutput

SetSourceParameters sets the SourceParameters field's value.

func (*DescribePipeOutput) SetStateReason

func (s *DescribePipeOutput) SetStateReason(v string) *DescribePipeOutput

SetStateReason sets the StateReason field's value.

func (*DescribePipeOutput) SetTags

func (s *DescribePipeOutput) SetTags(v map[string]*string) *DescribePipeOutput

SetTags sets the Tags field's value.

func (*DescribePipeOutput) SetTarget

func (s *DescribePipeOutput) SetTarget(v string) *DescribePipeOutput

SetTarget sets the Target field's value.

func (*DescribePipeOutput) SetTargetParameters

func (s *DescribePipeOutput) SetTargetParameters(v *PipeTargetParameters) *DescribePipeOutput

SetTargetParameters sets the TargetParameters field's value.

func (DescribePipeOutput) String

func (s DescribePipeOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type EcsContainerOverride

type EcsContainerOverride struct {

	// The command to send to the container that overrides the default command from
	// the Docker image or the task definition. You must also specify a container
	// name.
	Command []*string `type:"list"`

	// The number of cpu units reserved for the container, instead of the default
	// value from the task definition. You must also specify a container name.
	Cpu *int64 `type:"integer"`

	// The environment variables to send to the container. You can add new environment
	// variables, which are added to the container at launch, or you can override
	// the existing environment variables from the Docker image or the task definition.
	// You must also specify a container name.
	Environment []*EcsEnvironmentVariable `type:"list"`

	// A list of files containing the environment variables to pass to a container,
	// instead of the value from the container definition.
	EnvironmentFiles []*EcsEnvironmentFile `type:"list"`

	// The hard limit (in MiB) of memory to present to the container, instead of
	// the default value from the task definition. If your container attempts to
	// exceed the memory specified here, the container is killed. You must also
	// specify a container name.
	Memory *int64 `type:"integer"`

	// The soft limit (in MiB) of memory to reserve for the container, instead of
	// the default value from the task definition. You must also specify a container
	// name.
	MemoryReservation *int64 `type:"integer"`

	// The name of the container that receives the override. This parameter is required
	// if any override is specified.
	Name *string `type:"string"`

	// The type and amount of a resource to assign to a container, instead of the
	// default value from the task definition. The only supported resource is a
	// GPU.
	ResourceRequirements []*EcsResourceRequirement `type:"list"`
	// contains filtered or unexported fields
}

The overrides that are sent to a container. An empty container override can be passed in. An example of an empty container override is {"containerOverrides": [ ] }. If a non-empty container override is specified, the name parameter must be included.

func (EcsContainerOverride) GoString

func (s EcsContainerOverride) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsContainerOverride) SetCommand

func (s *EcsContainerOverride) SetCommand(v []*string) *EcsContainerOverride

SetCommand sets the Command field's value.

func (*EcsContainerOverride) SetCpu

SetCpu sets the Cpu field's value.

func (*EcsContainerOverride) SetEnvironment

SetEnvironment sets the Environment field's value.

func (*EcsContainerOverride) SetEnvironmentFiles

func (s *EcsContainerOverride) SetEnvironmentFiles(v []*EcsEnvironmentFile) *EcsContainerOverride

SetEnvironmentFiles sets the EnvironmentFiles field's value.

func (*EcsContainerOverride) SetMemory

SetMemory sets the Memory field's value.

func (*EcsContainerOverride) SetMemoryReservation

func (s *EcsContainerOverride) SetMemoryReservation(v int64) *EcsContainerOverride

SetMemoryReservation sets the MemoryReservation field's value.

func (*EcsContainerOverride) SetName

SetName sets the Name field's value.

func (*EcsContainerOverride) SetResourceRequirements

func (s *EcsContainerOverride) SetResourceRequirements(v []*EcsResourceRequirement) *EcsContainerOverride

SetResourceRequirements sets the ResourceRequirements field's value.

func (EcsContainerOverride) String

func (s EcsContainerOverride) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsContainerOverride) Validate

func (s *EcsContainerOverride) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type EcsEnvironmentFile

type EcsEnvironmentFile struct {

	// The file type to use. The only supported value is s3.
	//
	// Type is a required field
	Type *string `locationName:"type" type:"string" required:"true" enum:"EcsEnvironmentFileType"`

	// The Amazon Resource Name (ARN) of the Amazon S3 object containing the environment
	// variable file.
	//
	// Value is a required field
	Value *string `locationName:"value" type:"string" required:"true"`
	// contains filtered or unexported fields
}

A list of files containing the environment variables to pass to a container. You can specify up to ten environment files. The file must have a .env file extension. Each line in an environment file should contain an environment variable in VARIABLE=VALUE format. Lines beginning with # are treated as comments and are ignored. For more information about the environment variable file syntax, see Declare default environment variables in file (https://docs.docker.com/compose/env-file/).

If there are environment variables specified using the environment parameter in a container definition, they take precedence over the variables contained within an environment file. If multiple environment files are specified that contain the same variable, they're processed from the top down. We recommend that you use unique variable names. For more information, see Specifying environment variables (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/taskdef-envfiles.html) in the Amazon Elastic Container Service Developer Guide.

This parameter is only supported for tasks hosted on Fargate using the following platform versions:

  • Linux platform version 1.4.0 or later.

  • Windows platform version 1.0.0 or later.

func (EcsEnvironmentFile) GoString

func (s EcsEnvironmentFile) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsEnvironmentFile) SetType

SetType sets the Type field's value.

func (*EcsEnvironmentFile) SetValue

SetValue sets the Value field's value.

func (EcsEnvironmentFile) String

func (s EcsEnvironmentFile) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsEnvironmentFile) Validate

func (s *EcsEnvironmentFile) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type EcsEnvironmentVariable

type EcsEnvironmentVariable struct {

	// The name of the key-value pair. For environment variables, this is the name
	// of the environment variable.
	Name *string `locationName:"name" type:"string"`

	// The value of the key-value pair. For environment variables, this is the value
	// of the environment variable.
	Value *string `locationName:"value" type:"string"`
	// contains filtered or unexported fields
}

The environment variables to send to the container. You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. You must also specify a container name.

func (EcsEnvironmentVariable) GoString

func (s EcsEnvironmentVariable) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsEnvironmentVariable) SetName

SetName sets the Name field's value.

func (*EcsEnvironmentVariable) SetValue

SetValue sets the Value field's value.

func (EcsEnvironmentVariable) String

func (s EcsEnvironmentVariable) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type EcsEphemeralStorage

type EcsEphemeralStorage struct {

	// The total amount, in GiB, of ephemeral storage to set for the task. The minimum
	// supported value is 21 GiB and the maximum supported value is 200 GiB.
	//
	// SizeInGiB is a required field
	SizeInGiB *int64 `locationName:"sizeInGiB" min:"21" type:"integer" required:"true"`
	// contains filtered or unexported fields
}

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.

func (EcsEphemeralStorage) GoString

func (s EcsEphemeralStorage) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsEphemeralStorage) SetSizeInGiB

func (s *EcsEphemeralStorage) SetSizeInGiB(v int64) *EcsEphemeralStorage

SetSizeInGiB sets the SizeInGiB field's value.

func (EcsEphemeralStorage) String

func (s EcsEphemeralStorage) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsEphemeralStorage) Validate

func (s *EcsEphemeralStorage) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type EcsInferenceAcceleratorOverride

type EcsInferenceAcceleratorOverride struct {

	// The Elastic Inference accelerator device name to override for the task. This
	// parameter must match a deviceName specified in the task definition.
	DeviceName *string `locationName:"deviceName" type:"string"`

	// The Elastic Inference accelerator type to use.
	DeviceType *string `locationName:"deviceType" type:"string"`
	// contains filtered or unexported fields
}

Details on an Elastic Inference accelerator task override. This parameter is used to override the Elastic Inference accelerator specified in the task definition. For more information, see Working with Amazon Elastic Inference on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/userguide/ecs-inference.html) in the Amazon Elastic Container Service Developer Guide.

func (EcsInferenceAcceleratorOverride) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsInferenceAcceleratorOverride) SetDeviceName

SetDeviceName sets the DeviceName field's value.

func (*EcsInferenceAcceleratorOverride) SetDeviceType

SetDeviceType sets the DeviceType field's value.

func (EcsInferenceAcceleratorOverride) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type EcsResourceRequirement

type EcsResourceRequirement struct {

	// The type of resource to assign to a container. The supported values are GPU
	// or InferenceAccelerator.
	//
	// Type is a required field
	Type *string `locationName:"type" type:"string" required:"true" enum:"EcsResourceRequirementType"`

	// The value for the specified resource type.
	//
	// If the GPU type is used, the value is the number of physical GPUs the Amazon
	// ECS container agent reserves for the container. The number of GPUs that's
	// reserved for all containers in a task can't exceed the number of available
	// GPUs on the container instance that the task is launched on.
	//
	// If the InferenceAccelerator type is used, the value matches the deviceName
	// for an InferenceAccelerator specified in a task definition.
	//
	// Value is a required field
	Value *string `locationName:"value" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The type and amount of a resource to assign to a container. The supported resource types are GPUs and Elastic Inference accelerators. For more information, see Working with GPUs on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs-gpu.html) or Working with Amazon Elastic Inference on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs-inference.html) in the Amazon Elastic Container Service Developer Guide

func (EcsResourceRequirement) GoString

func (s EcsResourceRequirement) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsResourceRequirement) SetType

SetType sets the Type field's value.

func (*EcsResourceRequirement) SetValue

SetValue sets the Value field's value.

func (EcsResourceRequirement) String

func (s EcsResourceRequirement) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsResourceRequirement) Validate

func (s *EcsResourceRequirement) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type EcsTaskOverride

type EcsTaskOverride struct {

	// One or more container overrides that are sent to a task.
	ContainerOverrides []*EcsContainerOverride `type:"list"`

	// The cpu override for the task.
	Cpu *string `type:"string"`

	// The ephemeral storage setting override for the task.
	//
	// This parameter is only supported for tasks hosted on Fargate that use the
	// following platform versions:
	//
	//    * Linux platform version 1.4.0 or later.
	//
	//    * Windows platform version 1.0.0 or later.
	EphemeralStorage *EcsEphemeralStorage `type:"structure"`

	// The Amazon Resource Name (ARN) of the task execution IAM role override for
	// the task. For more information, see Amazon ECS task execution IAM role (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task_execution_IAM_role.html)
	// in the Amazon Elastic Container Service Developer Guide.
	ExecutionRoleArn *string `min:"1" type:"string"`

	// The Elastic Inference accelerator override for the task.
	InferenceAcceleratorOverrides []*EcsInferenceAcceleratorOverride `type:"list"`

	// The memory override for the task.
	Memory *string `type:"string"`

	// The Amazon Resource Name (ARN) of the IAM role that containers in this task
	// can assume. All containers in this task are granted the permissions that
	// are specified in this role. For more information, see IAM Role for Tasks
	// (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task-iam-roles.html)
	// in the Amazon Elastic Container Service Developer Guide.
	TaskRoleArn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The overrides that are associated with a task.

func (EcsTaskOverride) GoString

func (s EcsTaskOverride) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsTaskOverride) SetContainerOverrides

func (s *EcsTaskOverride) SetContainerOverrides(v []*EcsContainerOverride) *EcsTaskOverride

SetContainerOverrides sets the ContainerOverrides field's value.

func (*EcsTaskOverride) SetCpu

func (s *EcsTaskOverride) SetCpu(v string) *EcsTaskOverride

SetCpu sets the Cpu field's value.

func (*EcsTaskOverride) SetEphemeralStorage

func (s *EcsTaskOverride) SetEphemeralStorage(v *EcsEphemeralStorage) *EcsTaskOverride

SetEphemeralStorage sets the EphemeralStorage field's value.

func (*EcsTaskOverride) SetExecutionRoleArn

func (s *EcsTaskOverride) SetExecutionRoleArn(v string) *EcsTaskOverride

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*EcsTaskOverride) SetInferenceAcceleratorOverrides

func (s *EcsTaskOverride) SetInferenceAcceleratorOverrides(v []*EcsInferenceAcceleratorOverride) *EcsTaskOverride

SetInferenceAcceleratorOverrides sets the InferenceAcceleratorOverrides field's value.

func (*EcsTaskOverride) SetMemory

func (s *EcsTaskOverride) SetMemory(v string) *EcsTaskOverride

SetMemory sets the Memory field's value.

func (*EcsTaskOverride) SetTaskRoleArn

func (s *EcsTaskOverride) SetTaskRoleArn(v string) *EcsTaskOverride

SetTaskRoleArn sets the TaskRoleArn field's value.

func (EcsTaskOverride) String

func (s EcsTaskOverride) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*EcsTaskOverride) Validate

func (s *EcsTaskOverride) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type Filter

type Filter struct {

	// The event pattern.
	//
	// Pattern is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by Filter's
	// String and GoString methods.
	Pattern *string `type:"string" sensitive:"true"`
	// contains filtered or unexported fields
}

Filter events using an event pattern. 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.

func (Filter) GoString

func (s Filter) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Filter) SetPattern

func (s *Filter) SetPattern(v string) *Filter

SetPattern sets the Pattern field's value.

func (Filter) String

func (s Filter) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type FilterCriteria

type FilterCriteria struct {

	// The event patterns.
	Filters []*Filter `type:"list"`
	// contains filtered or unexported fields
}

The collection of event patterns used to filter events.

To remove a filter, specify a FilterCriteria object with an empty array of Filter objects.

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.

func (FilterCriteria) GoString

func (s FilterCriteria) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*FilterCriteria) SetFilters

func (s *FilterCriteria) SetFilters(v []*Filter) *FilterCriteria

SetFilters sets the Filters field's value.

func (FilterCriteria) String

func (s FilterCriteria) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type FirehoseLogDestination

type FirehoseLogDestination struct {

	// The Amazon Resource Name (ARN) of the Kinesis Data Firehose delivery stream
	// to which EventBridge delivers the pipe log records.
	DeliveryStreamArn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The Amazon Kinesis Data Firehose logging configuration settings for the pipe.

func (FirehoseLogDestination) GoString

func (s FirehoseLogDestination) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*FirehoseLogDestination) SetDeliveryStreamArn

func (s *FirehoseLogDestination) SetDeliveryStreamArn(v string) *FirehoseLogDestination

SetDeliveryStreamArn sets the DeliveryStreamArn field's value.

func (FirehoseLogDestination) String

func (s FirehoseLogDestination) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type FirehoseLogDestinationParameters

type FirehoseLogDestinationParameters struct {

	// Specifies the Amazon Resource Name (ARN) of the Kinesis Data Firehose delivery
	// stream to which EventBridge delivers the pipe log records.
	//
	// DeliveryStreamArn is a required field
	DeliveryStreamArn *string `min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The Amazon Kinesis Data Firehose logging configuration settings for the pipe.

func (FirehoseLogDestinationParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*FirehoseLogDestinationParameters) SetDeliveryStreamArn

SetDeliveryStreamArn sets the DeliveryStreamArn field's value.

func (FirehoseLogDestinationParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*FirehoseLogDestinationParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type InternalException

type InternalException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`

	// The number of seconds to wait before retrying the action that caused the
	// exception.
	RetryAfterSeconds *int64 `location:"header" locationName:"Retry-After" type:"integer"`
	// contains filtered or unexported fields
}

This exception occurs due to unexpected causes.

func (*InternalException) Code

func (s *InternalException) Code() string

Code returns the exception type name.

func (*InternalException) Error

func (s *InternalException) Error() string

func (InternalException) GoString

func (s InternalException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*InternalException) Message

func (s *InternalException) Message() string

Message returns the exception's message.

func (*InternalException) OrigErr

func (s *InternalException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalException) RequestID

func (s *InternalException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalException) StatusCode

func (s *InternalException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (InternalException) String

func (s InternalException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ListPipesInput

type ListPipesInput struct {

	// The state the pipe is in.
	CurrentState *string `location:"querystring" locationName:"CurrentState" type:"string" enum:"PipeState"`

	// The state the pipe should be in.
	DesiredState *string `location:"querystring" locationName:"DesiredState" type:"string" enum:"RequestedPipeState"`

	// The maximum number of pipes to include in the response.
	Limit *int64 `location:"querystring" locationName:"Limit" min:"1" type:"integer"`

	// A value that will return a subset of the pipes associated with this account.
	// For example, "NamePrefix": "ABC" will return all endpoints with "ABC" in
	// the name.
	NamePrefix *string `location:"querystring" locationName:"NamePrefix" min:"1" type:"string"`

	// If nextToken is returned, there are more results available. The value of
	// nextToken is a unique pagination token for each page. Make the call again
	// using the returned token to retrieve the next page. Keep all other arguments
	// unchanged. Each pagination token expires after 24 hours. Using an expired
	// pagination token will return an HTTP 400 InvalidToken error.
	//
	// NextToken is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by ListPipesInput's
	// String and GoString methods.
	NextToken *string `location:"querystring" locationName:"NextToken" min:"1" type:"string" sensitive:"true"`

	// The prefix matching the pipe source.
	SourcePrefix *string `location:"querystring" locationName:"SourcePrefix" min:"1" type:"string"`

	// The prefix matching the pipe target.
	TargetPrefix *string `location:"querystring" locationName:"TargetPrefix" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (ListPipesInput) GoString

func (s ListPipesInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListPipesInput) SetCurrentState

func (s *ListPipesInput) SetCurrentState(v string) *ListPipesInput

SetCurrentState sets the CurrentState field's value.

func (*ListPipesInput) SetDesiredState

func (s *ListPipesInput) SetDesiredState(v string) *ListPipesInput

SetDesiredState sets the DesiredState field's value.

func (*ListPipesInput) SetLimit

func (s *ListPipesInput) SetLimit(v int64) *ListPipesInput

SetLimit sets the Limit field's value.

func (*ListPipesInput) SetNamePrefix

func (s *ListPipesInput) SetNamePrefix(v string) *ListPipesInput

SetNamePrefix sets the NamePrefix field's value.

func (*ListPipesInput) SetNextToken

func (s *ListPipesInput) SetNextToken(v string) *ListPipesInput

SetNextToken sets the NextToken field's value.

func (*ListPipesInput) SetSourcePrefix

func (s *ListPipesInput) SetSourcePrefix(v string) *ListPipesInput

SetSourcePrefix sets the SourcePrefix field's value.

func (*ListPipesInput) SetTargetPrefix

func (s *ListPipesInput) SetTargetPrefix(v string) *ListPipesInput

SetTargetPrefix sets the TargetPrefix field's value.

func (ListPipesInput) String

func (s ListPipesInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListPipesInput) Validate

func (s *ListPipesInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListPipesOutput

type ListPipesOutput struct {

	// If nextToken is returned, there are more results available. The value of
	// nextToken is a unique pagination token for each page. Make the call again
	// using the returned token to retrieve the next page. Keep all other arguments
	// unchanged. Each pagination token expires after 24 hours. Using an expired
	// pagination token will return an HTTP 400 InvalidToken error.
	//
	// NextToken is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by ListPipesOutput's
	// String and GoString methods.
	NextToken *string `min:"1" type:"string" sensitive:"true"`

	// The pipes returned by the call.
	Pipes []*Pipe `type:"list"`
	// contains filtered or unexported fields
}

func (ListPipesOutput) GoString

func (s ListPipesOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListPipesOutput) SetNextToken

func (s *ListPipesOutput) SetNextToken(v string) *ListPipesOutput

SetNextToken sets the NextToken field's value.

func (*ListPipesOutput) SetPipes

func (s *ListPipesOutput) SetPipes(v []*Pipe) *ListPipesOutput

SetPipes sets the Pipes field's value.

func (ListPipesOutput) String

func (s ListPipesOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ListTagsForResourceInput

type ListTagsForResourceInput struct {

	// The ARN of the pipe for which you want to view tags.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceInput) GoString

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceInput) SetResourceArn

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String

func (s ListTagsForResourceInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceInput) Validate

func (s *ListTagsForResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListTagsForResourceOutput

type ListTagsForResourceOutput struct {

	// The list of key-value pairs to associate with the pipe.
	Tags map[string]*string `locationName:"tags" min:"1" type:"map"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceOutput) GoString

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceOutput) SetTags

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String

func (s ListTagsForResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type MQBrokerAccessCredentials

type MQBrokerAccessCredentials struct {

	// The ARN of the Secrets Manager secret.
	BasicAuth *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The Secrets Manager secret that stores your broker credentials.

func (MQBrokerAccessCredentials) GoString

func (s MQBrokerAccessCredentials) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MQBrokerAccessCredentials) SetBasicAuth

SetBasicAuth sets the BasicAuth field's value.

func (MQBrokerAccessCredentials) String

func (s MQBrokerAccessCredentials) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MQBrokerAccessCredentials) Validate

func (s *MQBrokerAccessCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type MSKAccessCredentials

type MSKAccessCredentials struct {

	// The ARN of the Secrets Manager secret.
	ClientCertificateTlsAuth *string `min:"1" type:"string"`

	// The ARN of the Secrets Manager secret.
	SaslScram512Auth *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The Secrets Manager secret that stores your stream credentials.

func (MSKAccessCredentials) GoString

func (s MSKAccessCredentials) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MSKAccessCredentials) SetClientCertificateTlsAuth

func (s *MSKAccessCredentials) SetClientCertificateTlsAuth(v string) *MSKAccessCredentials

SetClientCertificateTlsAuth sets the ClientCertificateTlsAuth field's value.

func (*MSKAccessCredentials) SetSaslScram512Auth

func (s *MSKAccessCredentials) SetSaslScram512Auth(v string) *MSKAccessCredentials

SetSaslScram512Auth sets the SaslScram512Auth field's value.

func (MSKAccessCredentials) String

func (s MSKAccessCredentials) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MSKAccessCredentials) Validate

func (s *MSKAccessCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type NetworkConfiguration

type NetworkConfiguration struct {

	// Use this structure to specify 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 `locationName:"awsvpcConfiguration" type:"structure"`
	// contains filtered or unexported fields
}

This structure specifies the network configuration for an Amazon ECS task.

func (NetworkConfiguration) GoString

func (s NetworkConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*NetworkConfiguration) SetAwsvpcConfiguration

func (s *NetworkConfiguration) SetAwsvpcConfiguration(v *AwsVpcConfiguration) *NetworkConfiguration

SetAwsvpcConfiguration sets the AwsvpcConfiguration field's value.

func (NetworkConfiguration) String

func (s NetworkConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*NetworkConfiguration) Validate

func (s *NetworkConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type NotFoundException

type NotFoundException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

An entity that you specified does not exist.

func (*NotFoundException) Code

func (s *NotFoundException) Code() string

Code returns the exception type name.

func (*NotFoundException) Error

func (s *NotFoundException) Error() string

func (NotFoundException) GoString

func (s NotFoundException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*NotFoundException) Message

func (s *NotFoundException) Message() string

Message returns the exception's message.

func (*NotFoundException) OrigErr

func (s *NotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*NotFoundException) RequestID

func (s *NotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*NotFoundException) StatusCode

func (s *NotFoundException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (NotFoundException) String

func (s NotFoundException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type Pipe

type Pipe struct {

	// The ARN of the pipe.
	Arn *string `min:"1" type:"string"`

	// The time the pipe was created.
	CreationTime *time.Time `type:"timestamp"`

	// The state the pipe is in.
	CurrentState *string `type:"string" enum:"PipeState"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeState"`

	// The ARN of the enrichment resource.
	Enrichment *string `type:"string"`

	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	LastModifiedTime *time.Time `type:"timestamp"`

	// The name of the pipe.
	Name *string `min:"1" type:"string"`

	// The ARN of the source resource.
	Source *string `min:"1" type:"string"`

	// The reason the pipe is in its current state.
	StateReason *string `type:"string"`

	// The ARN of the target resource.
	Target *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

An object that represents a pipe. Amazon EventBridgePipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

func (Pipe) GoString

func (s Pipe) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Pipe) SetArn

func (s *Pipe) SetArn(v string) *Pipe

SetArn sets the Arn field's value.

func (*Pipe) SetCreationTime

func (s *Pipe) SetCreationTime(v time.Time) *Pipe

SetCreationTime sets the CreationTime field's value.

func (*Pipe) SetCurrentState

func (s *Pipe) SetCurrentState(v string) *Pipe

SetCurrentState sets the CurrentState field's value.

func (*Pipe) SetDesiredState

func (s *Pipe) SetDesiredState(v string) *Pipe

SetDesiredState sets the DesiredState field's value.

func (*Pipe) SetEnrichment

func (s *Pipe) SetEnrichment(v string) *Pipe

SetEnrichment sets the Enrichment field's value.

func (*Pipe) SetLastModifiedTime

func (s *Pipe) SetLastModifiedTime(v time.Time) *Pipe

SetLastModifiedTime sets the LastModifiedTime field's value.

func (*Pipe) SetName

func (s *Pipe) SetName(v string) *Pipe

SetName sets the Name field's value.

func (*Pipe) SetSource

func (s *Pipe) SetSource(v string) *Pipe

SetSource sets the Source field's value.

func (*Pipe) SetStateReason

func (s *Pipe) SetStateReason(v string) *Pipe

SetStateReason sets the StateReason field's value.

func (*Pipe) SetTarget

func (s *Pipe) SetTarget(v string) *Pipe

SetTarget sets the Target field's value.

func (Pipe) String

func (s Pipe) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PipeEnrichmentHttpParameters

type PipeEnrichmentHttpParameters struct {

	// The headers that need to be sent as part of request invoking the API Gateway
	// REST API or EventBridge ApiDestination.
	HeaderParameters map[string]*string `type:"map"`

	// The path parameter values to be used to populate API Gateway REST API or
	// EventBridge ApiDestination path wildcards ("*").
	PathParameterValues []*string `type:"list"`

	// The query string keys/values that need to be sent as part of request invoking
	// the API Gateway REST API or EventBridge ApiDestination.
	QueryStringParameters map[string]*string `type:"map"`
	// contains filtered or unexported fields
}

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.

func (PipeEnrichmentHttpParameters) GoString

func (s PipeEnrichmentHttpParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeEnrichmentHttpParameters) SetHeaderParameters

SetHeaderParameters sets the HeaderParameters field's value.

func (*PipeEnrichmentHttpParameters) SetPathParameterValues

func (s *PipeEnrichmentHttpParameters) SetPathParameterValues(v []*string) *PipeEnrichmentHttpParameters

SetPathParameterValues sets the PathParameterValues field's value.

func (*PipeEnrichmentHttpParameters) SetQueryStringParameters

func (s *PipeEnrichmentHttpParameters) SetQueryStringParameters(v map[string]*string) *PipeEnrichmentHttpParameters

SetQueryStringParameters sets the QueryStringParameters field's value.

func (PipeEnrichmentHttpParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PipeEnrichmentParameters

type PipeEnrichmentParameters struct {

	// Contains the HTTP parameters to use when the target is a API Gateway REST
	// endpoint or EventBridge ApiDestination.
	//
	// If you specify an API Gateway REST API or EventBridge ApiDestination as a
	// target, you can use this parameter to specify headers, path parameters, and
	// query string keys/values as part of your target invoking request. If you're
	// using ApiDestinations, the corresponding Connection can also have these values
	// configured. In case of any conflicting keys, values from the Connection take
	// precedence.
	HttpParameters *PipeEnrichmentHttpParameters `type:"structure"`

	// Valid JSON text passed to the enrichment. In this case, nothing from the
	// event itself is passed to the enrichment. For more information, see The JavaScript
	// Object Notation (JSON) Data Interchange Format (http://www.rfc-editor.org/rfc/rfc7159.txt).
	//
	// To remove an input template, specify an empty string.
	//
	// InputTemplate is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeEnrichmentParameters's
	// String and GoString methods.
	InputTemplate *string `type:"string" sensitive:"true"`
	// contains filtered or unexported fields
}

The parameters required to set up enrichment on your pipe.

func (PipeEnrichmentParameters) GoString

func (s PipeEnrichmentParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeEnrichmentParameters) SetHttpParameters

SetHttpParameters sets the HttpParameters field's value.

func (*PipeEnrichmentParameters) SetInputTemplate

SetInputTemplate sets the InputTemplate field's value.

func (PipeEnrichmentParameters) String

func (s PipeEnrichmentParameters) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PipeLogConfiguration

type PipeLogConfiguration struct {

	// The Amazon CloudWatch Logs logging configuration settings for the pipe.
	CloudwatchLogsLogDestination *CloudwatchLogsLogDestination `type:"structure"`

	// The Amazon Kinesis Data Firehose logging configuration settings for the pipe.
	FirehoseLogDestination *FirehoseLogDestination `type:"structure"`

	// Whether the execution data (specifically, the payload, awsRequest, and awsResponse
	// fields) is included in the log messages for this pipe.
	//
	// This applies to all log destinations for the pipe.
	//
	// For more information, see Including execution data in logs (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-logs.html#eb-pipes-logs-execution-data)
	// in the Amazon EventBridge User Guide.
	IncludeExecutionData []*string `type:"list" enum:"IncludeExecutionDataOption"`

	// The level of logging detail to include. This applies to all log destinations
	// for the pipe.
	Level *string `type:"string" enum:"LogLevel"`

	// The Amazon S3 logging configuration settings for the pipe.
	S3LogDestination *S3LogDestination `type:"structure"`
	// contains filtered or unexported fields
}

The logging configuration settings for the pipe.

func (PipeLogConfiguration) GoString

func (s PipeLogConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeLogConfiguration) SetCloudwatchLogsLogDestination

func (s *PipeLogConfiguration) SetCloudwatchLogsLogDestination(v *CloudwatchLogsLogDestination) *PipeLogConfiguration

SetCloudwatchLogsLogDestination sets the CloudwatchLogsLogDestination field's value.

func (*PipeLogConfiguration) SetFirehoseLogDestination

func (s *PipeLogConfiguration) SetFirehoseLogDestination(v *FirehoseLogDestination) *PipeLogConfiguration

SetFirehoseLogDestination sets the FirehoseLogDestination field's value.

func (*PipeLogConfiguration) SetIncludeExecutionData

func (s *PipeLogConfiguration) SetIncludeExecutionData(v []*string) *PipeLogConfiguration

SetIncludeExecutionData sets the IncludeExecutionData field's value.

func (*PipeLogConfiguration) SetLevel

SetLevel sets the Level field's value.

func (*PipeLogConfiguration) SetS3LogDestination

func (s *PipeLogConfiguration) SetS3LogDestination(v *S3LogDestination) *PipeLogConfiguration

SetS3LogDestination sets the S3LogDestination field's value.

func (PipeLogConfiguration) String

func (s PipeLogConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PipeLogConfigurationParameters

type PipeLogConfigurationParameters struct {

	// The Amazon CloudWatch Logs logging configuration settings for the pipe.
	CloudwatchLogsLogDestination *CloudwatchLogsLogDestinationParameters `type:"structure"`

	// The Amazon Kinesis Data Firehose logging configuration settings for the pipe.
	FirehoseLogDestination *FirehoseLogDestinationParameters `type:"structure"`

	// Specify ON to include the execution data (specifically, the payload and awsRequest
	// fields) in the log messages for this pipe.
	//
	// This applies to all log destinations for the pipe.
	//
	// For more information, see Including execution data in logs (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-logs.html#eb-pipes-logs-execution-data)
	// in the Amazon EventBridge User Guide.
	//
	// The default is OFF.
	IncludeExecutionData []*string `type:"list" enum:"IncludeExecutionDataOption"`

	// The level of logging detail to include. This applies to all log destinations
	// for the pipe.
	//
	// For more information, see Specifying EventBridge Pipes log level (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-logs.html#eb-pipes-logs-level)
	// in the Amazon EventBridge User Guide.
	//
	// Level is a required field
	Level *string `type:"string" required:"true" enum:"LogLevel"`

	// The Amazon S3 logging configuration settings for the pipe.
	S3LogDestination *S3LogDestinationParameters `type:"structure"`
	// contains filtered or unexported fields
}

Specifies the logging configuration settings for the pipe.

When you call UpdatePipe, EventBridge updates the fields in the PipeLogConfigurationParameters object atomically as one and overrides existing values. This is by design. If you don't specify an optional field in any of the Amazon Web Services service parameters objects (CloudwatchLogsLogDestinationParameters, FirehoseLogDestinationParameters, or S3LogDestinationParameters), EventBridge sets that field to its system-default value during the update.

For example, suppose when you created the pipe you specified a Kinesis Data Firehose stream log destination. You then update the pipe to add an Amazon S3 log destination. In addition to specifying the S3LogDestinationParameters for the new log destination, you must also specify the fields in the FirehoseLogDestinationParameters object in order to retain the Kinesis Data Firehose stream log destination.

For more information on generating pipe log records, see Log EventBridge Pipes (eventbridge/latest/userguide/eb-pipes-logs.html) in the Amazon EventBridge User Guide.

func (PipeLogConfigurationParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeLogConfigurationParameters) SetCloudwatchLogsLogDestination

SetCloudwatchLogsLogDestination sets the CloudwatchLogsLogDestination field's value.

func (*PipeLogConfigurationParameters) SetFirehoseLogDestination

SetFirehoseLogDestination sets the FirehoseLogDestination field's value.

func (*PipeLogConfigurationParameters) SetIncludeExecutionData

func (s *PipeLogConfigurationParameters) SetIncludeExecutionData(v []*string) *PipeLogConfigurationParameters

SetIncludeExecutionData sets the IncludeExecutionData field's value.

func (*PipeLogConfigurationParameters) SetLevel

SetLevel sets the Level field's value.

func (*PipeLogConfigurationParameters) SetS3LogDestination

SetS3LogDestination sets the S3LogDestination field's value.

func (PipeLogConfigurationParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeLogConfigurationParameters) Validate

func (s *PipeLogConfigurationParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceActiveMQBrokerParameters

type PipeSourceActiveMQBrokerParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The credentials needed to access the resource.
	//
	// Credentials is a required field
	Credentials *MQBrokerAccessCredentials `type:"structure" required:"true"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// The name of the destination queue to consume.
	//
	// QueueName is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeSourceActiveMQBrokerParameters's
	// String and GoString methods.
	//
	// QueueName is a required field
	QueueName *string `min:"1" type:"string" required:"true" sensitive:"true"`
	// contains filtered or unexported fields
}

The parameters for using an Active MQ broker as a source.

func (PipeSourceActiveMQBrokerParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceActiveMQBrokerParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*PipeSourceActiveMQBrokerParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*PipeSourceActiveMQBrokerParameters) SetMaximumBatchingWindowInSeconds

func (s *PipeSourceActiveMQBrokerParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceActiveMQBrokerParameters

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*PipeSourceActiveMQBrokerParameters) SetQueueName

SetQueueName sets the QueueName field's value.

func (PipeSourceActiveMQBrokerParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceActiveMQBrokerParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceDynamoDBStreamParameters

type PipeSourceDynamoDBStreamParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// Define the target queue to send dead-letter queue events to.
	DeadLetterConfig *DeadLetterConfig `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records older than the specified age. The default
	// value is -1, which sets the maximum age to infinite. When the value is set
	// to infinite, EventBridge never discards old records.
	MaximumRecordAgeInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records after the specified number of retries. The
	// default value is -1, which sets the maximum number of retries to infinite.
	// When MaximumRetryAttempts is infinite, EventBridge retries failed records
	// until the record expires in the event source.
	MaximumRetryAttempts *int64 `type:"integer"`

	// (Streams only) Define how to handle item process failures. AUTOMATIC_BISECT
	// halves each batch and retry each half until all the records are processed
	// or there is one failed message left in the batch.
	OnPartialBatchItemFailure *string `type:"string" enum:"OnPartialBatchItemFailureStreams"`

	// (Streams only) The number of batches to process concurrently from each shard.
	// The default value is 1.
	ParallelizationFactor *int64 `min:"1" type:"integer"`

	// (Streams only) The position in a stream from which to start reading.
	//
	// StartingPosition is a required field
	StartingPosition *string `type:"string" required:"true" enum:"DynamoDBStreamStartPosition"`
	// contains filtered or unexported fields
}

The parameters for using a DynamoDB stream as a source.

func (PipeSourceDynamoDBStreamParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceDynamoDBStreamParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*PipeSourceDynamoDBStreamParameters) SetDeadLetterConfig

SetDeadLetterConfig sets the DeadLetterConfig field's value.

func (*PipeSourceDynamoDBStreamParameters) SetMaximumBatchingWindowInSeconds

func (s *PipeSourceDynamoDBStreamParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceDynamoDBStreamParameters

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*PipeSourceDynamoDBStreamParameters) SetMaximumRecordAgeInSeconds

SetMaximumRecordAgeInSeconds sets the MaximumRecordAgeInSeconds field's value.

func (*PipeSourceDynamoDBStreamParameters) SetMaximumRetryAttempts

SetMaximumRetryAttempts sets the MaximumRetryAttempts field's value.

func (*PipeSourceDynamoDBStreamParameters) SetOnPartialBatchItemFailure

SetOnPartialBatchItemFailure sets the OnPartialBatchItemFailure field's value.

func (*PipeSourceDynamoDBStreamParameters) SetParallelizationFactor

SetParallelizationFactor sets the ParallelizationFactor field's value.

func (*PipeSourceDynamoDBStreamParameters) SetStartingPosition

SetStartingPosition sets the StartingPosition field's value.

func (PipeSourceDynamoDBStreamParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceDynamoDBStreamParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceKinesisStreamParameters

type PipeSourceKinesisStreamParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// Define the target queue to send dead-letter queue events to.
	DeadLetterConfig *DeadLetterConfig `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records older than the specified age. The default
	// value is -1, which sets the maximum age to infinite. When the value is set
	// to infinite, EventBridge never discards old records.
	MaximumRecordAgeInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records after the specified number of retries. The
	// default value is -1, which sets the maximum number of retries to infinite.
	// When MaximumRetryAttempts is infinite, EventBridge retries failed records
	// until the record expires in the event source.
	MaximumRetryAttempts *int64 `type:"integer"`

	// (Streams only) Define how to handle item process failures. AUTOMATIC_BISECT
	// halves each batch and retry each half until all the records are processed
	// or there is one failed message left in the batch.
	OnPartialBatchItemFailure *string `type:"string" enum:"OnPartialBatchItemFailureStreams"`

	// (Streams only) The number of batches to process concurrently from each shard.
	// The default value is 1.
	ParallelizationFactor *int64 `min:"1" type:"integer"`

	// (Streams only) The position in a stream from which to start reading.
	//
	// StartingPosition is a required field
	StartingPosition *string `type:"string" required:"true" enum:"KinesisStreamStartPosition"`

	// With StartingPosition set to AT_TIMESTAMP, the time from which to start reading,
	// in Unix time seconds.
	StartingPositionTimestamp *time.Time `type:"timestamp"`
	// contains filtered or unexported fields
}

The parameters for using a Kinesis stream as a source.

func (PipeSourceKinesisStreamParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceKinesisStreamParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*PipeSourceKinesisStreamParameters) SetDeadLetterConfig

SetDeadLetterConfig sets the DeadLetterConfig field's value.

func (*PipeSourceKinesisStreamParameters) SetMaximumBatchingWindowInSeconds

func (s *PipeSourceKinesisStreamParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceKinesisStreamParameters

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*PipeSourceKinesisStreamParameters) SetMaximumRecordAgeInSeconds

SetMaximumRecordAgeInSeconds sets the MaximumRecordAgeInSeconds field's value.

func (*PipeSourceKinesisStreamParameters) SetMaximumRetryAttempts

SetMaximumRetryAttempts sets the MaximumRetryAttempts field's value.

func (*PipeSourceKinesisStreamParameters) SetOnPartialBatchItemFailure

SetOnPartialBatchItemFailure sets the OnPartialBatchItemFailure field's value.

func (*PipeSourceKinesisStreamParameters) SetParallelizationFactor

SetParallelizationFactor sets the ParallelizationFactor field's value.

func (*PipeSourceKinesisStreamParameters) SetStartingPosition

SetStartingPosition sets the StartingPosition field's value.

func (*PipeSourceKinesisStreamParameters) SetStartingPositionTimestamp

SetStartingPositionTimestamp sets the StartingPositionTimestamp field's value.

func (PipeSourceKinesisStreamParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceKinesisStreamParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceManagedStreamingKafkaParameters

type PipeSourceManagedStreamingKafkaParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The name of the destination queue to consume.
	//
	// ConsumerGroupID is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeSourceManagedStreamingKafkaParameters's
	// String and GoString methods.
	ConsumerGroupID *string `min:"1" type:"string" sensitive:"true"`

	// The credentials needed to access the resource.
	Credentials *MSKAccessCredentials `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// (Streams only) The position in a stream from which to start reading.
	StartingPosition *string `type:"string" enum:"MSKStartPosition"`

	// The name of the topic that the pipe will read from.
	//
	// TopicName is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeSourceManagedStreamingKafkaParameters's
	// String and GoString methods.
	//
	// TopicName is a required field
	TopicName *string `min:"1" type:"string" required:"true" sensitive:"true"`
	// contains filtered or unexported fields
}

The parameters for using an MSK stream as a source.

func (PipeSourceManagedStreamingKafkaParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceManagedStreamingKafkaParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*PipeSourceManagedStreamingKafkaParameters) SetConsumerGroupID

SetConsumerGroupID sets the ConsumerGroupID field's value.

func (*PipeSourceManagedStreamingKafkaParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*PipeSourceManagedStreamingKafkaParameters) SetMaximumBatchingWindowInSeconds

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*PipeSourceManagedStreamingKafkaParameters) SetStartingPosition

SetStartingPosition sets the StartingPosition field's value.

func (*PipeSourceManagedStreamingKafkaParameters) SetTopicName

SetTopicName sets the TopicName field's value.

func (PipeSourceManagedStreamingKafkaParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceManagedStreamingKafkaParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceParameters

type PipeSourceParameters struct {

	// The parameters for using an Active MQ broker as a source.
	ActiveMQBrokerParameters *PipeSourceActiveMQBrokerParameters `type:"structure"`

	// The parameters for using a DynamoDB stream as a source.
	DynamoDBStreamParameters *PipeSourceDynamoDBStreamParameters `type:"structure"`

	// The collection of event patterns used to filter events.
	//
	// To remove a filter, specify a FilterCriteria object with an empty array of
	// Filter objects.
	//
	// 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 `type:"structure"`

	// The parameters for using a Kinesis stream as a source.
	KinesisStreamParameters *PipeSourceKinesisStreamParameters `type:"structure"`

	// The parameters for using an MSK stream as a source.
	ManagedStreamingKafkaParameters *PipeSourceManagedStreamingKafkaParameters `type:"structure"`

	// The parameters for using a Rabbit MQ broker as a source.
	RabbitMQBrokerParameters *PipeSourceRabbitMQBrokerParameters `type:"structure"`

	// The parameters for using a self-managed Apache Kafka stream as a source.
	SelfManagedKafkaParameters *PipeSourceSelfManagedKafkaParameters `type:"structure"`

	// The parameters for using a Amazon SQS stream as a source.
	SqsQueueParameters *PipeSourceSqsQueueParameters `type:"structure"`
	// contains filtered or unexported fields
}

The parameters required to set up a source for your pipe.

func (PipeSourceParameters) GoString

func (s PipeSourceParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceParameters) SetActiveMQBrokerParameters

SetActiveMQBrokerParameters sets the ActiveMQBrokerParameters field's value.

func (*PipeSourceParameters) SetDynamoDBStreamParameters

SetDynamoDBStreamParameters sets the DynamoDBStreamParameters field's value.

func (*PipeSourceParameters) SetFilterCriteria

func (s *PipeSourceParameters) SetFilterCriteria(v *FilterCriteria) *PipeSourceParameters

SetFilterCriteria sets the FilterCriteria field's value.

func (*PipeSourceParameters) SetKinesisStreamParameters

SetKinesisStreamParameters sets the KinesisStreamParameters field's value.

func (*PipeSourceParameters) SetManagedStreamingKafkaParameters

func (s *PipeSourceParameters) SetManagedStreamingKafkaParameters(v *PipeSourceManagedStreamingKafkaParameters) *PipeSourceParameters

SetManagedStreamingKafkaParameters sets the ManagedStreamingKafkaParameters field's value.

func (*PipeSourceParameters) SetRabbitMQBrokerParameters

SetRabbitMQBrokerParameters sets the RabbitMQBrokerParameters field's value.

func (*PipeSourceParameters) SetSelfManagedKafkaParameters

SetSelfManagedKafkaParameters sets the SelfManagedKafkaParameters field's value.

func (*PipeSourceParameters) SetSqsQueueParameters

SetSqsQueueParameters sets the SqsQueueParameters field's value.

func (PipeSourceParameters) String

func (s PipeSourceParameters) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceParameters) Validate

func (s *PipeSourceParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceRabbitMQBrokerParameters

type PipeSourceRabbitMQBrokerParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The credentials needed to access the resource.
	//
	// Credentials is a required field
	Credentials *MQBrokerAccessCredentials `type:"structure" required:"true"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// The name of the destination queue to consume.
	//
	// QueueName is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeSourceRabbitMQBrokerParameters's
	// String and GoString methods.
	//
	// QueueName is a required field
	QueueName *string `min:"1" type:"string" required:"true" sensitive:"true"`

	// The name of the virtual host associated with the source broker.
	//
	// VirtualHost is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeSourceRabbitMQBrokerParameters's
	// String and GoString methods.
	VirtualHost *string `min:"1" type:"string" sensitive:"true"`
	// contains filtered or unexported fields
}

The parameters for using a Rabbit MQ broker as a source.

func (PipeSourceRabbitMQBrokerParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceRabbitMQBrokerParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*PipeSourceRabbitMQBrokerParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*PipeSourceRabbitMQBrokerParameters) SetMaximumBatchingWindowInSeconds

func (s *PipeSourceRabbitMQBrokerParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceRabbitMQBrokerParameters

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*PipeSourceRabbitMQBrokerParameters) SetQueueName

SetQueueName sets the QueueName field's value.

func (*PipeSourceRabbitMQBrokerParameters) SetVirtualHost

SetVirtualHost sets the VirtualHost field's value.

func (PipeSourceRabbitMQBrokerParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceRabbitMQBrokerParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceSelfManagedKafkaParameters

type PipeSourceSelfManagedKafkaParameters struct {

	// An array of server URLs.
	AdditionalBootstrapServers []*string `type:"list"`

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The name of the destination queue to consume.
	//
	// ConsumerGroupID is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeSourceSelfManagedKafkaParameters's
	// String and GoString methods.
	ConsumerGroupID *string `min:"1" type:"string" sensitive:"true"`

	// The credentials needed to access the resource.
	Credentials *SelfManagedKafkaAccessConfigurationCredentials `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// The ARN of the Secrets Manager secret used for certification.
	ServerRootCaCertificate *string `min:"1" type:"string"`

	// (Streams only) The position in a stream from which to start reading.
	StartingPosition *string `type:"string" enum:"SelfManagedKafkaStartPosition"`

	// The name of the topic that the pipe will read from.
	//
	// TopicName is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeSourceSelfManagedKafkaParameters's
	// String and GoString methods.
	//
	// TopicName is a required field
	TopicName *string `min:"1" type:"string" required:"true" sensitive:"true"`

	// This structure specifies the VPC subnets and security groups for the stream,
	// and whether a public IP address is to be used.
	Vpc *SelfManagedKafkaAccessConfigurationVpc `type:"structure"`
	// contains filtered or unexported fields
}

The parameters for using a self-managed Apache Kafka stream as a source.

func (PipeSourceSelfManagedKafkaParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceSelfManagedKafkaParameters) SetAdditionalBootstrapServers

SetAdditionalBootstrapServers sets the AdditionalBootstrapServers field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetConsumerGroupID

SetConsumerGroupID sets the ConsumerGroupID field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetMaximumBatchingWindowInSeconds

func (s *PipeSourceSelfManagedKafkaParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceSelfManagedKafkaParameters

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetServerRootCaCertificate

SetServerRootCaCertificate sets the ServerRootCaCertificate field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetStartingPosition

SetStartingPosition sets the StartingPosition field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetTopicName

SetTopicName sets the TopicName field's value.

func (*PipeSourceSelfManagedKafkaParameters) SetVpc

SetVpc sets the Vpc field's value.

func (PipeSourceSelfManagedKafkaParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceSelfManagedKafkaParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeSourceSqsQueueParameters

type PipeSourceSqsQueueParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`
	// contains filtered or unexported fields
}

The parameters for using a Amazon SQS stream as a source.

func (PipeSourceSqsQueueParameters) GoString

func (s PipeSourceSqsQueueParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceSqsQueueParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*PipeSourceSqsQueueParameters) SetMaximumBatchingWindowInSeconds

func (s *PipeSourceSqsQueueParameters) SetMaximumBatchingWindowInSeconds(v int64) *PipeSourceSqsQueueParameters

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (PipeSourceSqsQueueParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeSourceSqsQueueParameters) Validate

func (s *PipeSourceSqsQueueParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetBatchJobParameters

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 `type:"structure"`

	// The overrides that are sent to a container.
	ContainerOverrides *BatchContainerOverrides `type:"structure"`

	// A list of dependencies for the job. A job can depend upon a maximum of 20
	// jobs. You can specify a SEQUENTIAL type dependency without specifying a job
	// ID for array jobs so that each child array job completes sequentially, starting
	// at index 0. You can also specify an N_TO_N type dependency with a job ID
	// for array jobs. In that case, each index child of this job must wait for
	// the corresponding index child of each dependency to complete before it can
	// begin.
	DependsOn []*BatchJobDependency `type:"list"`

	// The job definition used by this job. This value can be one of name, name:revision,
	// or the Amazon Resource Name (ARN) for the job definition. If name is specified
	// without a revision then the latest active revision is used.
	//
	// JobDefinition is a required field
	JobDefinition *string `type:"string" required:"true"`

	// The name of the job. It can be up to 128 letters long. The first character
	// must be alphanumeric, can contain uppercase and lowercase letters, numbers,
	// hyphens (-), and underscores (_).
	//
	// JobName is a required field
	JobName *string `type:"string" required:"true"`

	// Additional parameters passed to the job that replace parameter substitution
	// placeholders that are set in the job definition. Parameters are specified
	// as a key and value pair mapping. Parameters included here override any corresponding
	// parameter defaults from the job definition.
	Parameters map[string]*string `type:"map"`

	// The retry strategy to use for failed jobs. When a retry strategy is specified
	// here, it overrides the retry strategy defined in the job definition.
	RetryStrategy *BatchRetryStrategy `type:"structure"`
	// contains filtered or unexported fields
}

The parameters for using an Batch job as a target.

func (PipeTargetBatchJobParameters) GoString

func (s PipeTargetBatchJobParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetBatchJobParameters) SetArrayProperties

SetArrayProperties sets the ArrayProperties field's value.

func (*PipeTargetBatchJobParameters) SetContainerOverrides

SetContainerOverrides sets the ContainerOverrides field's value.

func (*PipeTargetBatchJobParameters) SetDependsOn

SetDependsOn sets the DependsOn field's value.

func (*PipeTargetBatchJobParameters) SetJobDefinition

SetJobDefinition sets the JobDefinition field's value.

func (*PipeTargetBatchJobParameters) SetJobName

SetJobName sets the JobName field's value.

func (*PipeTargetBatchJobParameters) SetParameters

SetParameters sets the Parameters field's value.

func (*PipeTargetBatchJobParameters) SetRetryStrategy

SetRetryStrategy sets the RetryStrategy field's value.

func (PipeTargetBatchJobParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetBatchJobParameters) Validate

func (s *PipeTargetBatchJobParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetCloudWatchLogsParameters

type PipeTargetCloudWatchLogsParameters struct {

	// The name of the log stream.
	LogStreamName *string `min:"1" type:"string"`

	// The time the event occurred, expressed as the number of milliseconds after
	// Jan 1, 1970 00:00:00 UTC.
	Timestamp *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The parameters for using an CloudWatch Logs log stream as a target.

func (PipeTargetCloudWatchLogsParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetCloudWatchLogsParameters) SetLogStreamName

SetLogStreamName sets the LogStreamName field's value.

func (*PipeTargetCloudWatchLogsParameters) SetTimestamp

SetTimestamp sets the Timestamp field's value.

func (PipeTargetCloudWatchLogsParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetCloudWatchLogsParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetEcsTaskParameters

type PipeTargetEcsTaskParameters struct {

	// The capacity provider strategy to use for the task.
	//
	// If a capacityProviderStrategy is specified, the launchType parameter must
	// be omitted. If no capacityProviderStrategy or launchType is specified, the
	// defaultCapacityProviderStrategy for the cluster is used.
	CapacityProviderStrategy []*CapacityProviderStrategyItem `type:"list"`

	// Specifies whether to enable Amazon ECS managed tags for the task. For more
	// information, see Tagging Your Amazon ECS Resources (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs-using-tags.html)
	// in the Amazon Elastic Container Service Developer Guide.
	EnableECSManagedTags *bool `type:"boolean"`

	// Whether or not to enable the execute command functionality for the containers
	// in this task. If true, this enables execute command functionality on all
	// containers in the task.
	EnableExecuteCommand *bool `type:"boolean"`

	// Specifies an Amazon ECS task group for the task. The maximum length is 255
	// characters.
	Group *string `type:"string"`

	// Specifies the launch type on which your task is running. The launch type
	// that you specify here must match one of the launch type (compatibilities)
	// of the target task. The FARGATE value is supported only in the Regions where
	// Fargate with Amazon ECS is supported. For more information, see Fargate on
	// Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/AWS-Fargate.html)
	// in the Amazon Elastic Container Service Developer Guide.
	LaunchType *string `type:"string" enum:"LaunchType"`

	// Use this structure if the Amazon ECS task uses the awsvpc network mode. This
	// structure specifies the VPC subnets and security groups associated with the
	// task, and whether a public IP address is to be used. This structure is required
	// if LaunchType is FARGATE because the awsvpc mode is required for Fargate
	// tasks.
	//
	// If you specify NetworkConfiguration when the target ECS task does not use
	// the awsvpc network mode, the task fails.
	NetworkConfiguration *NetworkConfiguration `type:"structure"`

	// The overrides that are associated with a task.
	Overrides *EcsTaskOverride `type:"structure"`

	// An array of placement constraint objects to use for the task. You can specify
	// up to 10 constraints per task (including constraints in the task definition
	// and those specified at runtime).
	PlacementConstraints []*PlacementConstraint `type:"list"`

	// The placement strategy objects to use for the task. You can specify a maximum
	// of five strategy rules per task.
	PlacementStrategy []*PlacementStrategy `type:"list"`

	// Specifies the platform version for the task. Specify only the numeric portion
	// of the platform version, such as 1.1.0.
	//
	// This structure is used only if LaunchType is FARGATE. For more information
	// about valid platform versions, see Fargate Platform Versions (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/platform_versions.html)
	// in the Amazon Elastic Container Service Developer Guide.
	PlatformVersion *string `type:"string"`

	// Specifies whether to propagate the tags from the task definition to the task.
	// If no value is specified, the tags are not propagated. Tags can only be propagated
	// to the task during task creation. To add tags to a task after task creation,
	// use the TagResource API action.
	PropagateTags *string `type:"string" enum:"PropagateTags"`

	// The reference ID to use for the task.
	//
	// ReferenceId is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetEcsTaskParameters's
	// String and GoString methods.
	ReferenceId *string `type:"string" sensitive:"true"`

	// The metadata that you apply to the task to help you categorize and organize
	// them. Each tag consists of a key and an optional value, both of which you
	// define. To learn more, see RunTask (https://docs.aws.amazon.com/AmazonECS/latest/APIReference/API_RunTask.html#ECS-RunTask-request-tags)
	// in the Amazon ECS API Reference.
	Tags []*Tag `type:"list"`

	// The number of tasks to create based on TaskDefinition. The default is 1.
	TaskCount *int64 `min:"1" type:"integer"`

	// The ARN of the task definition to use if the event target is an Amazon ECS
	// task.
	//
	// TaskDefinitionArn is a required field
	TaskDefinitionArn *string `min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The parameters for using an Amazon ECS task as a target.

func (PipeTargetEcsTaskParameters) GoString

func (s PipeTargetEcsTaskParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetEcsTaskParameters) SetCapacityProviderStrategy

SetCapacityProviderStrategy sets the CapacityProviderStrategy field's value.

func (*PipeTargetEcsTaskParameters) SetEnableECSManagedTags

func (s *PipeTargetEcsTaskParameters) SetEnableECSManagedTags(v bool) *PipeTargetEcsTaskParameters

SetEnableECSManagedTags sets the EnableECSManagedTags field's value.

func (*PipeTargetEcsTaskParameters) SetEnableExecuteCommand

func (s *PipeTargetEcsTaskParameters) SetEnableExecuteCommand(v bool) *PipeTargetEcsTaskParameters

SetEnableExecuteCommand sets the EnableExecuteCommand field's value.

func (*PipeTargetEcsTaskParameters) SetGroup

SetGroup sets the Group field's value.

func (*PipeTargetEcsTaskParameters) SetLaunchType

SetLaunchType sets the LaunchType field's value.

func (*PipeTargetEcsTaskParameters) SetNetworkConfiguration

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*PipeTargetEcsTaskParameters) SetOverrides

SetOverrides sets the Overrides field's value.

func (*PipeTargetEcsTaskParameters) SetPlacementConstraints

SetPlacementConstraints sets the PlacementConstraints field's value.

func (*PipeTargetEcsTaskParameters) SetPlacementStrategy

SetPlacementStrategy sets the PlacementStrategy field's value.

func (*PipeTargetEcsTaskParameters) SetPlatformVersion

SetPlatformVersion sets the PlatformVersion field's value.

func (*PipeTargetEcsTaskParameters) SetPropagateTags

SetPropagateTags sets the PropagateTags field's value.

func (*PipeTargetEcsTaskParameters) SetReferenceId

SetReferenceId sets the ReferenceId field's value.

func (*PipeTargetEcsTaskParameters) SetTags

SetTags sets the Tags field's value.

func (*PipeTargetEcsTaskParameters) SetTaskCount

SetTaskCount sets the TaskCount field's value.

func (*PipeTargetEcsTaskParameters) SetTaskDefinitionArn

SetTaskDefinitionArn sets the TaskDefinitionArn field's value.

func (PipeTargetEcsTaskParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetEcsTaskParameters) Validate

func (s *PipeTargetEcsTaskParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetEventBridgeEventBusParameters

type PipeTargetEventBridgeEventBusParameters struct {

	// A free-form string, with a maximum of 128 characters, used to decide what
	// fields to expect in the event detail.
	//
	// DetailType is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetEventBridgeEventBusParameters's
	// String and GoString methods.
	DetailType *string `min:"1" type:"string" sensitive:"true"`

	// The URL subdomain of the endpoint. For example, if the URL for Endpoint is
	// https://abcde.veo.endpoints.event.amazonaws.com, then the EndpointId is abcde.veo.
	//
	// EndpointId is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetEventBridgeEventBusParameters's
	// String and GoString methods.
	EndpointId *string `min:"1" type:"string" sensitive:"true"`

	// Amazon Web Services resources, identified by Amazon Resource Name (ARN),
	// which the event primarily concerns. Any number, including zero, may be present.
	Resources []*string `type:"list"`

	// The source of the event.
	//
	// Source is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetEventBridgeEventBusParameters's
	// String and GoString methods.
	Source *string `min:"1" type:"string" sensitive:"true"`

	// The time stamp of the event, per RFC3339 (https://www.rfc-editor.org/rfc/rfc3339.txt).
	// If no time stamp is provided, the time stamp of the PutEvents (https://docs.aws.amazon.com/eventbridge/latest/APIReference/API_PutEvents.html)
	// call is used.
	Time *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The parameters for using an EventBridge event bus as a target.

func (PipeTargetEventBridgeEventBusParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetEventBridgeEventBusParameters) SetDetailType

SetDetailType sets the DetailType field's value.

func (*PipeTargetEventBridgeEventBusParameters) SetEndpointId

SetEndpointId sets the EndpointId field's value.

func (*PipeTargetEventBridgeEventBusParameters) SetResources

SetResources sets the Resources field's value.

func (*PipeTargetEventBridgeEventBusParameters) SetSource

SetSource sets the Source field's value.

func (*PipeTargetEventBridgeEventBusParameters) SetTime

SetTime sets the Time field's value.

func (PipeTargetEventBridgeEventBusParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetEventBridgeEventBusParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetHttpParameters

type PipeTargetHttpParameters struct {

	// The headers that need to be sent as part of request invoking the API Gateway
	// REST API or EventBridge ApiDestination.
	HeaderParameters map[string]*string `type:"map"`

	// The path parameter values to be used to populate API Gateway REST API or
	// EventBridge ApiDestination path wildcards ("*").
	PathParameterValues []*string `type:"list"`

	// The query string keys/values that need to be sent as part of request invoking
	// the API Gateway REST API or EventBridge ApiDestination.
	QueryStringParameters map[string]*string `type:"map"`
	// contains filtered or unexported fields
}

These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations.

func (PipeTargetHttpParameters) GoString

func (s PipeTargetHttpParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetHttpParameters) SetHeaderParameters

func (s *PipeTargetHttpParameters) SetHeaderParameters(v map[string]*string) *PipeTargetHttpParameters

SetHeaderParameters sets the HeaderParameters field's value.

func (*PipeTargetHttpParameters) SetPathParameterValues

func (s *PipeTargetHttpParameters) SetPathParameterValues(v []*string) *PipeTargetHttpParameters

SetPathParameterValues sets the PathParameterValues field's value.

func (*PipeTargetHttpParameters) SetQueryStringParameters

func (s *PipeTargetHttpParameters) SetQueryStringParameters(v map[string]*string) *PipeTargetHttpParameters

SetQueryStringParameters sets the QueryStringParameters field's value.

func (PipeTargetHttpParameters) String

func (s PipeTargetHttpParameters) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PipeTargetKinesisStreamParameters

type PipeTargetKinesisStreamParameters struct {

	// Determines which shard in the stream the data record is assigned to. Partition
	// keys are Unicode strings with a maximum length limit of 256 characters for
	// each key. Amazon Kinesis Data Streams uses the partition key as input to
	// a hash function that maps the partition key and associated data to a specific
	// shard. Specifically, an MD5 hash function is used to map partition keys to
	// 128-bit integer values and to map associated data records to shards. As a
	// result of this hashing mechanism, all data records with the same partition
	// key map to the same shard within the stream.
	//
	// PartitionKey is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetKinesisStreamParameters's
	// String and GoString methods.
	//
	// PartitionKey is a required field
	PartitionKey *string `type:"string" required:"true" sensitive:"true"`
	// contains filtered or unexported fields
}

The parameters for using a Kinesis stream as a target.

func (PipeTargetKinesisStreamParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetKinesisStreamParameters) SetPartitionKey

SetPartitionKey sets the PartitionKey field's value.

func (PipeTargetKinesisStreamParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetKinesisStreamParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetLambdaFunctionParameters

type PipeTargetLambdaFunctionParameters struct {

	// Specify whether to invoke the function synchronously or asynchronously.
	//
	//    * REQUEST_RESPONSE (default) - Invoke synchronously. This corresponds
	//    to the RequestResponse option in the InvocationType parameter for the
	//    Lambda Invoke (https://docs.aws.amazon.com/lambda/latest/dg/API_Invoke.html#API_Invoke_RequestSyntax)
	//    API.
	//
	//    * FIRE_AND_FORGET - Invoke asynchronously. This corresponds to the Event
	//    option in the InvocationType parameter for the Lambda Invoke (https://docs.aws.amazon.com/lambda/latest/dg/API_Invoke.html#API_Invoke_RequestSyntax)
	//    API.
	//
	// For more information, see Invocation types (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html#pipes-invocation)
	// in the Amazon EventBridge User Guide.
	InvocationType *string `type:"string" enum:"PipeTargetInvocationType"`
	// contains filtered or unexported fields
}

The parameters for using a Lambda function as a target.

func (PipeTargetLambdaFunctionParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetLambdaFunctionParameters) SetInvocationType

SetInvocationType sets the InvocationType field's value.

func (PipeTargetLambdaFunctionParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PipeTargetParameters

type PipeTargetParameters struct {

	// The parameters for using an Batch job as a target.
	BatchJobParameters *PipeTargetBatchJobParameters `type:"structure"`

	// The parameters for using an CloudWatch Logs log stream as a target.
	CloudWatchLogsParameters *PipeTargetCloudWatchLogsParameters `type:"structure"`

	// The parameters for using an Amazon ECS task as a target.
	EcsTaskParameters *PipeTargetEcsTaskParameters `type:"structure"`

	// The parameters for using an EventBridge event bus as a target.
	EventBridgeEventBusParameters *PipeTargetEventBridgeEventBusParameters `type:"structure"`

	// These are custom parameter to be used when the target is an API Gateway REST
	// APIs or EventBridge ApiDestinations.
	HttpParameters *PipeTargetHttpParameters `type:"structure"`

	// Valid JSON text passed to the target. In this case, nothing from the event
	// itself is passed to the target. For more information, see The JavaScript
	// Object Notation (JSON) Data Interchange Format (http://www.rfc-editor.org/rfc/rfc7159.txt).
	//
	// To remove an input template, specify an empty string.
	//
	// InputTemplate is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetParameters's
	// String and GoString methods.
	InputTemplate *string `type:"string" sensitive:"true"`

	// The parameters for using a Kinesis stream as a target.
	KinesisStreamParameters *PipeTargetKinesisStreamParameters `type:"structure"`

	// The parameters for using a Lambda function as a target.
	LambdaFunctionParameters *PipeTargetLambdaFunctionParameters `type:"structure"`

	// These are custom parameters to be used when the target is a Amazon Redshift
	// cluster to invoke the Amazon Redshift Data API BatchExecuteStatement.
	RedshiftDataParameters *PipeTargetRedshiftDataParameters `type:"structure"`

	// The parameters for using a SageMaker pipeline as a target.
	SageMakerPipelineParameters *PipeTargetSageMakerPipelineParameters `type:"structure"`

	// The parameters for using a Amazon SQS stream as a target.
	SqsQueueParameters *PipeTargetSqsQueueParameters `type:"structure"`

	// The parameters for using a Step Functions state machine as a target.
	StepFunctionStateMachineParameters *PipeTargetStateMachineParameters `type:"structure"`
	// contains filtered or unexported fields
}

The parameters required to set up a target for your pipe.

For more information about pipe target parameters, including how to use dynamic path parameters, see Target parameters (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-target.html) in the Amazon EventBridge User Guide.

func (PipeTargetParameters) GoString

func (s PipeTargetParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetParameters) SetBatchJobParameters

SetBatchJobParameters sets the BatchJobParameters field's value.

func (*PipeTargetParameters) SetCloudWatchLogsParameters

SetCloudWatchLogsParameters sets the CloudWatchLogsParameters field's value.

func (*PipeTargetParameters) SetEcsTaskParameters

SetEcsTaskParameters sets the EcsTaskParameters field's value.

func (*PipeTargetParameters) SetEventBridgeEventBusParameters

SetEventBridgeEventBusParameters sets the EventBridgeEventBusParameters field's value.

func (*PipeTargetParameters) SetHttpParameters

SetHttpParameters sets the HttpParameters field's value.

func (*PipeTargetParameters) SetInputTemplate

func (s *PipeTargetParameters) SetInputTemplate(v string) *PipeTargetParameters

SetInputTemplate sets the InputTemplate field's value.

func (*PipeTargetParameters) SetKinesisStreamParameters

SetKinesisStreamParameters sets the KinesisStreamParameters field's value.

func (*PipeTargetParameters) SetLambdaFunctionParameters

SetLambdaFunctionParameters sets the LambdaFunctionParameters field's value.

func (*PipeTargetParameters) SetRedshiftDataParameters

SetRedshiftDataParameters sets the RedshiftDataParameters field's value.

func (*PipeTargetParameters) SetSageMakerPipelineParameters

SetSageMakerPipelineParameters sets the SageMakerPipelineParameters field's value.

func (*PipeTargetParameters) SetSqsQueueParameters

SetSqsQueueParameters sets the SqsQueueParameters field's value.

func (*PipeTargetParameters) SetStepFunctionStateMachineParameters

func (s *PipeTargetParameters) SetStepFunctionStateMachineParameters(v *PipeTargetStateMachineParameters) *PipeTargetParameters

SetStepFunctionStateMachineParameters sets the StepFunctionStateMachineParameters field's value.

func (PipeTargetParameters) String

func (s PipeTargetParameters) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetParameters) Validate

func (s *PipeTargetParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetRedshiftDataParameters

type PipeTargetRedshiftDataParameters struct {

	// The name of the database. Required when authenticating using temporary credentials.
	//
	// Database is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetRedshiftDataParameters's
	// String and GoString methods.
	//
	// Database is a required field
	Database *string `min:"1" type:"string" required:"true" sensitive:"true"`

	// The database user name. Required when authenticating using temporary credentials.
	//
	// DbUser is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetRedshiftDataParameters's
	// String and GoString methods.
	DbUser *string `min:"1" type:"string" sensitive:"true"`

	// The name or ARN of the secret that enables access to the database. Required
	// when authenticating using Secrets Manager.
	SecretManagerArn *string `min:"1" type:"string"`

	// The SQL statement text to run.
	//
	// Sqls is a required field
	Sqls []*string `min:"1" type:"list" required:"true"`

	// The name of the SQL statement. You can name the SQL statement when you create
	// it to identify the query.
	//
	// StatementName is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetRedshiftDataParameters's
	// String and GoString methods.
	StatementName *string `min:"1" type:"string" sensitive:"true"`

	// Indicates whether to send an event back to EventBridge after the SQL statement
	// runs.
	WithEvent *bool `type:"boolean"`
	// contains filtered or unexported fields
}

These are custom parameters to be used when the target is a Amazon Redshift cluster to invoke the Amazon Redshift Data API BatchExecuteStatement.

func (PipeTargetRedshiftDataParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetRedshiftDataParameters) SetDatabase

SetDatabase sets the Database field's value.

func (*PipeTargetRedshiftDataParameters) SetDbUser

SetDbUser sets the DbUser field's value.

func (*PipeTargetRedshiftDataParameters) SetSecretManagerArn

SetSecretManagerArn sets the SecretManagerArn field's value.

func (*PipeTargetRedshiftDataParameters) SetSqls

SetSqls sets the Sqls field's value.

func (*PipeTargetRedshiftDataParameters) SetStatementName

SetStatementName sets the StatementName field's value.

func (*PipeTargetRedshiftDataParameters) SetWithEvent

SetWithEvent sets the WithEvent field's value.

func (PipeTargetRedshiftDataParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetRedshiftDataParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetSageMakerPipelineParameters

type PipeTargetSageMakerPipelineParameters struct {

	// List of Parameter names and values for SageMaker Model Building Pipeline
	// execution.
	PipelineParameterList []*SageMakerPipelineParameter `type:"list"`
	// contains filtered or unexported fields
}

The parameters for using a SageMaker pipeline as a target.

func (PipeTargetSageMakerPipelineParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetSageMakerPipelineParameters) SetPipelineParameterList

SetPipelineParameterList sets the PipelineParameterList field's value.

func (PipeTargetSageMakerPipelineParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetSageMakerPipelineParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type PipeTargetSqsQueueParameters

type PipeTargetSqsQueueParameters struct {

	// This parameter applies only to FIFO (first-in-first-out) queues.
	//
	// The token used for deduplication of sent messages.
	//
	// MessageDeduplicationId is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetSqsQueueParameters's
	// String and GoString methods.
	MessageDeduplicationId *string `type:"string" sensitive:"true"`

	// The FIFO message group ID to use as the target.
	//
	// MessageGroupId is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PipeTargetSqsQueueParameters's
	// String and GoString methods.
	MessageGroupId *string `type:"string" sensitive:"true"`
	// contains filtered or unexported fields
}

The parameters for using a Amazon SQS stream as a target.

func (PipeTargetSqsQueueParameters) GoString

func (s PipeTargetSqsQueueParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetSqsQueueParameters) SetMessageDeduplicationId

func (s *PipeTargetSqsQueueParameters) SetMessageDeduplicationId(v string) *PipeTargetSqsQueueParameters

SetMessageDeduplicationId sets the MessageDeduplicationId field's value.

func (*PipeTargetSqsQueueParameters) SetMessageGroupId

SetMessageGroupId sets the MessageGroupId field's value.

func (PipeTargetSqsQueueParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PipeTargetStateMachineParameters

type PipeTargetStateMachineParameters struct {

	// Specify whether to invoke the Step Functions state machine synchronously
	// or asynchronously.
	//
	//    * REQUEST_RESPONSE (default) - Invoke synchronously. For more information,
	//    see StartSyncExecution (https://docs.aws.amazon.com/step-functions/latest/apireference/API_StartSyncExecution.html)
	//    in the Step Functions API Reference. REQUEST_RESPONSE is not supported
	//    for STANDARD state machine workflows.
	//
	//    * FIRE_AND_FORGET - Invoke asynchronously. For more information, see StartExecution
	//    (https://docs.aws.amazon.com/step-functions/latest/apireference/API_StartExecution.html)
	//    in the Step Functions API Reference.
	//
	// For more information, see Invocation types (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html#pipes-invocation)
	// in the Amazon EventBridge User Guide.
	InvocationType *string `type:"string" enum:"PipeTargetInvocationType"`
	// contains filtered or unexported fields
}

The parameters for using a Step Functions state machine as a target.

func (PipeTargetStateMachineParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PipeTargetStateMachineParameters) SetInvocationType

SetInvocationType sets the InvocationType field's value.

func (PipeTargetStateMachineParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type Pipes

type Pipes struct {
	*client.Client
}

Pipes provides the API operation methods for making requests to Amazon EventBridge Pipes. See this package's package overview docs for details on the service.

Pipes methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

func New

func New(p client.ConfigProvider, cfgs ...*aws.Config) *Pipes

New creates a new instance of the Pipes client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.

Example:

mySession := session.Must(session.NewSession())

// Create a Pipes client from just a session.
svc := pipes.New(mySession)

// Create a Pipes client with additional configuration
svc := pipes.New(mySession, aws.NewConfig().WithRegion("us-west-2"))

func (*Pipes) CreatePipe

func (c *Pipes) CreatePipe(input *CreatePipeInput) (*CreatePipeOutput, error)

CreatePipe API operation for Amazon EventBridge Pipes.

Create a pipe. Amazon EventBridge Pipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation CreatePipe for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • ThrottlingException An action was throttled.

  • NotFoundException An entity that you specified does not exist.

  • ConflictException An action you attempted resulted in an exception.

  • ServiceQuotaExceededException A quota has been exceeded.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/CreatePipe

func (*Pipes) CreatePipeRequest

func (c *Pipes) CreatePipeRequest(input *CreatePipeInput) (req *request.Request, output *CreatePipeOutput)

CreatePipeRequest generates a "aws/request.Request" representing the client's request for the CreatePipe operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreatePipe for more information on using the CreatePipe API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the CreatePipeRequest method.
req, resp := client.CreatePipeRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/CreatePipe

func (*Pipes) CreatePipeWithContext

func (c *Pipes) CreatePipeWithContext(ctx aws.Context, input *CreatePipeInput, opts ...request.Option) (*CreatePipeOutput, error)

CreatePipeWithContext is the same as CreatePipe with the addition of the ability to pass a context and additional request options.

See CreatePipe for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) DeletePipe

func (c *Pipes) DeletePipe(input *DeletePipeInput) (*DeletePipeOutput, error)

DeletePipe API operation for Amazon EventBridge Pipes.

Delete an existing pipe. For more information about pipes, see Amazon EventBridge Pipes (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html) in the Amazon EventBridge User Guide.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation DeletePipe for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • ThrottlingException An action was throttled.

  • NotFoundException An entity that you specified does not exist.

  • ConflictException An action you attempted resulted in an exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/DeletePipe

func (*Pipes) DeletePipeRequest

func (c *Pipes) DeletePipeRequest(input *DeletePipeInput) (req *request.Request, output *DeletePipeOutput)

DeletePipeRequest generates a "aws/request.Request" representing the client's request for the DeletePipe operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DeletePipe for more information on using the DeletePipe API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DeletePipeRequest method.
req, resp := client.DeletePipeRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/DeletePipe

func (*Pipes) DeletePipeWithContext

func (c *Pipes) DeletePipeWithContext(ctx aws.Context, input *DeletePipeInput, opts ...request.Option) (*DeletePipeOutput, error)

DeletePipeWithContext is the same as DeletePipe with the addition of the ability to pass a context and additional request options.

See DeletePipe for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) DescribePipe

func (c *Pipes) DescribePipe(input *DescribePipeInput) (*DescribePipeOutput, error)

DescribePipe API operation for Amazon EventBridge Pipes.

Get the information about an existing pipe. For more information about pipes, see Amazon EventBridge Pipes (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html) in the Amazon EventBridge User Guide.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation DescribePipe for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • ThrottlingException An action was throttled.

  • NotFoundException An entity that you specified does not exist.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/DescribePipe

func (*Pipes) DescribePipeRequest

func (c *Pipes) DescribePipeRequest(input *DescribePipeInput) (req *request.Request, output *DescribePipeOutput)

DescribePipeRequest generates a "aws/request.Request" representing the client's request for the DescribePipe operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribePipe for more information on using the DescribePipe API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DescribePipeRequest method.
req, resp := client.DescribePipeRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/DescribePipe

func (*Pipes) DescribePipeWithContext

func (c *Pipes) DescribePipeWithContext(ctx aws.Context, input *DescribePipeInput, opts ...request.Option) (*DescribePipeOutput, error)

DescribePipeWithContext is the same as DescribePipe with the addition of the ability to pass a context and additional request options.

See DescribePipe for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) ListPipes

func (c *Pipes) ListPipes(input *ListPipesInput) (*ListPipesOutput, error)

ListPipes API operation for Amazon EventBridge Pipes.

Get the pipes associated with this account. For more information about pipes, see Amazon EventBridge Pipes (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html) in the Amazon EventBridge User Guide.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation ListPipes for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • ThrottlingException An action was throttled.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/ListPipes

func (*Pipes) ListPipesPages

func (c *Pipes) ListPipesPages(input *ListPipesInput, fn func(*ListPipesOutput, bool) bool) error

ListPipesPages iterates over the pages of a ListPipes operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListPipes method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListPipes operation.
pageNum := 0
err := client.ListPipesPages(params,
    func(page *pipes.ListPipesOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Pipes) ListPipesPagesWithContext

func (c *Pipes) ListPipesPagesWithContext(ctx aws.Context, input *ListPipesInput, fn func(*ListPipesOutput, bool) bool, opts ...request.Option) error

ListPipesPagesWithContext same as ListPipesPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) ListPipesRequest

func (c *Pipes) ListPipesRequest(input *ListPipesInput) (req *request.Request, output *ListPipesOutput)

ListPipesRequest generates a "aws/request.Request" representing the client's request for the ListPipes operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListPipes for more information on using the ListPipes API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListPipesRequest method.
req, resp := client.ListPipesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/ListPipes

func (*Pipes) ListPipesWithContext

func (c *Pipes) ListPipesWithContext(ctx aws.Context, input *ListPipesInput, opts ...request.Option) (*ListPipesOutput, error)

ListPipesWithContext is the same as ListPipes with the addition of the ability to pass a context and additional request options.

See ListPipes for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) ListTagsForResource

func (c *Pipes) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)

ListTagsForResource API operation for Amazon EventBridge Pipes.

Displays the tags associated with a pipe.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation ListTagsForResource for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • NotFoundException An entity that you specified does not exist.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/ListTagsForResource

func (*Pipes) ListTagsForResourceRequest

func (c *Pipes) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)

ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/ListTagsForResource

func (*Pipes) ListTagsForResourceWithContext

func (c *Pipes) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)

ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.

See ListTagsForResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) StartPipe

func (c *Pipes) StartPipe(input *StartPipeInput) (*StartPipeOutput, error)

StartPipe API operation for Amazon EventBridge Pipes.

Start an existing pipe.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation StartPipe for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • ThrottlingException An action was throttled.

  • NotFoundException An entity that you specified does not exist.

  • ConflictException An action you attempted resulted in an exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/StartPipe

func (*Pipes) StartPipeRequest

func (c *Pipes) StartPipeRequest(input *StartPipeInput) (req *request.Request, output *StartPipeOutput)

StartPipeRequest generates a "aws/request.Request" representing the client's request for the StartPipe operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StartPipe for more information on using the StartPipe API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the StartPipeRequest method.
req, resp := client.StartPipeRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/StartPipe

func (*Pipes) StartPipeWithContext

func (c *Pipes) StartPipeWithContext(ctx aws.Context, input *StartPipeInput, opts ...request.Option) (*StartPipeOutput, error)

StartPipeWithContext is the same as StartPipe with the addition of the ability to pass a context and additional request options.

See StartPipe for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) StopPipe

func (c *Pipes) StopPipe(input *StopPipeInput) (*StopPipeOutput, error)

StopPipe API operation for Amazon EventBridge Pipes.

Stop an existing pipe.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation StopPipe for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • ThrottlingException An action was throttled.

  • NotFoundException An entity that you specified does not exist.

  • ConflictException An action you attempted resulted in an exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/StopPipe

func (*Pipes) StopPipeRequest

func (c *Pipes) StopPipeRequest(input *StopPipeInput) (req *request.Request, output *StopPipeOutput)

StopPipeRequest generates a "aws/request.Request" representing the client's request for the StopPipe operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StopPipe for more information on using the StopPipe API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the StopPipeRequest method.
req, resp := client.StopPipeRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/StopPipe

func (*Pipes) StopPipeWithContext

func (c *Pipes) StopPipeWithContext(ctx aws.Context, input *StopPipeInput, opts ...request.Option) (*StopPipeOutput, error)

StopPipeWithContext is the same as StopPipe with the addition of the ability to pass a context and additional request options.

See StopPipe for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) TagResource

func (c *Pipes) TagResource(input *TagResourceInput) (*TagResourceOutput, error)

TagResource API operation for Amazon EventBridge Pipes.

Assigns one or more tags (key-value pairs) to the specified pipe. Tags can help you organize and categorize your resources. You can also use them to scope user permissions by granting a user permission to access or change only resources with certain tag values.

Tags don't have any semantic meaning to Amazon Web Services and are interpreted strictly as strings of characters.

You can use the TagResource action with a pipe that already has tags. If you specify a new tag key, this tag is appended to the list of tags associated with the pipe. If you specify a tag key that is already associated with the pipe, the new tag value that you specify replaces the previous value for that tag.

You can associate as many as 50 tags with a pipe.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation TagResource for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • NotFoundException An entity that you specified does not exist.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/TagResource

func (*Pipes) TagResourceRequest

func (c *Pipes) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)

TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See TagResource for more information on using the TagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/TagResource

func (*Pipes) TagResourceWithContext

func (c *Pipes) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)

TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.

See TagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) UntagResource

func (c *Pipes) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)

UntagResource API operation for Amazon EventBridge Pipes.

Removes one or more tags from the specified pipes.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation UntagResource for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • NotFoundException An entity that you specified does not exist.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/UntagResource

func (*Pipes) UntagResourceRequest

func (c *Pipes) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)

UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UntagResource for more information on using the UntagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/UntagResource

func (*Pipes) UntagResourceWithContext

func (c *Pipes) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)

UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.

See UntagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Pipes) UpdatePipe

func (c *Pipes) UpdatePipe(input *UpdatePipeInput) (*UpdatePipeOutput, error)

UpdatePipe API operation for Amazon EventBridge Pipes.

Update an existing pipe. When you call UpdatePipe, EventBridge only the updates fields you have specified in the request; the rest remain unchanged. The exception to this is if you modify any Amazon Web Services-service specific fields in the SourceParameters, EnrichmentParameters, or TargetParameters objects. For example, DynamoDBStreamParameters or EventBridgeEventBusParameters. EventBridge updates the fields in these objects atomically as one and overrides existing values. This is by design, and means that if you don't specify an optional field in one of these Parameters objects, EventBridge sets that field to its system-default value during the update.

For more information about pipes, see Amazon EventBridge Pipes (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html) in the Amazon EventBridge User Guide.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EventBridge Pipes's API operation UpdatePipe for usage and error information.

Returned Error Types:

  • InternalException This exception occurs due to unexpected causes.

  • ValidationException Indicates that an error has occurred while performing a validate operation.

  • ThrottlingException An action was throttled.

  • NotFoundException An entity that you specified does not exist.

  • ConflictException An action you attempted resulted in an exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/UpdatePipe

func (*Pipes) UpdatePipeRequest

func (c *Pipes) UpdatePipeRequest(input *UpdatePipeInput) (req *request.Request, output *UpdatePipeOutput)

UpdatePipeRequest generates a "aws/request.Request" representing the client's request for the UpdatePipe operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UpdatePipe for more information on using the UpdatePipe API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UpdatePipeRequest method.
req, resp := client.UpdatePipeRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/UpdatePipe

func (*Pipes) UpdatePipeWithContext

func (c *Pipes) UpdatePipeWithContext(ctx aws.Context, input *UpdatePipeInput, opts ...request.Option) (*UpdatePipeOutput, error)

UpdatePipeWithContext is the same as UpdatePipe with the addition of the ability to pass a context and additional request options.

See UpdatePipe for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

type PlacementConstraint

type PlacementConstraint struct {

	// A cluster query language expression to apply to the constraint. You cannot
	// specify an expression if the constraint type is distinctInstance. To learn
	// more, see Cluster Query Language (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/cluster-query-language.html)
	// in the Amazon Elastic Container Service Developer Guide.
	//
	// Expression is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PlacementConstraint's
	// String and GoString methods.
	Expression *string `locationName:"expression" type:"string" sensitive:"true"`

	// The type of constraint. Use distinctInstance to ensure that each task in
	// a particular group is running on a different container instance. Use memberOf
	// to restrict the selection to a group of valid candidates.
	Type *string `locationName:"type" type:"string" enum:"PlacementConstraintType"`
	// contains filtered or unexported fields
}

An object representing a constraint on task placement. To learn more, see Task Placement Constraints (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task-placement-constraints.html) in the Amazon Elastic Container Service Developer Guide.

func (PlacementConstraint) GoString

func (s PlacementConstraint) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PlacementConstraint) SetExpression

func (s *PlacementConstraint) SetExpression(v string) *PlacementConstraint

SetExpression sets the Expression field's value.

func (*PlacementConstraint) SetType

SetType sets the Type field's value.

func (PlacementConstraint) String

func (s PlacementConstraint) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type PlacementStrategy

type PlacementStrategy struct {

	// The field to apply the placement strategy against. For the spread placement
	// strategy, valid values are instanceId (or host, which has the same effect),
	// or any platform or custom attribute that is applied to a container instance,
	// such as attribute:ecs.availability-zone. For the binpack placement strategy,
	// valid values are cpu and memory. For the random placement strategy, this
	// field is not used.
	//
	// Field is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by PlacementStrategy's
	// String and GoString methods.
	Field *string `locationName:"field" type:"string" sensitive:"true"`

	// The type of placement strategy. The random placement strategy randomly places
	// tasks on available candidates. The spread placement strategy spreads placement
	// across available candidates evenly based on the field parameter. The binpack
	// strategy places tasks on available candidates that have the least available
	// amount of the resource that is specified with the field parameter. For example,
	// if you binpack on memory, a task is placed on the instance with the least
	// amount of remaining memory (but still enough to run the task).
	Type *string `locationName:"type" type:"string" enum:"PlacementStrategyType"`
	// contains filtered or unexported fields
}

The task placement strategy for a task or service. To learn more, see Task Placement Strategies (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task-placement-strategies.html) in the Amazon Elastic Container Service Service Developer Guide.

func (PlacementStrategy) GoString

func (s PlacementStrategy) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*PlacementStrategy) SetField

func (s *PlacementStrategy) SetField(v string) *PlacementStrategy

SetField sets the Field field's value.

func (*PlacementStrategy) SetType

SetType sets the Type field's value.

func (PlacementStrategy) String

func (s PlacementStrategy) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type S3LogDestination

type S3LogDestination struct {

	// The name of the Amazon S3 bucket to which EventBridge delivers the log records
	// for the pipe.
	BucketName *string `type:"string"`

	// The Amazon Web Services account that owns the Amazon S3 bucket to which EventBridge
	// delivers the log records for the pipe.
	BucketOwner *string `type:"string"`

	// The format EventBridge uses for the log records.
	//
	//    * json: JSON
	//
	//    * plain: Plain text
	//
	//    * w3c: W3C extended logging file format (https://www.w3.org/TR/WD-logfile)
	OutputFormat *string `type:"string" enum:"S3OutputFormat"`

	// The prefix text with which to begin Amazon S3 log object names.
	//
	// For more information, see Organizing objects using prefixes (https://docs.aws.amazon.com/AmazonS3/latest/userguide/using-prefixes.html)
	// in the Amazon Simple Storage Service User Guide.
	Prefix *string `type:"string"`
	// contains filtered or unexported fields
}

The Amazon S3 logging configuration settings for the pipe.

func (S3LogDestination) GoString

func (s S3LogDestination) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*S3LogDestination) SetBucketName

func (s *S3LogDestination) SetBucketName(v string) *S3LogDestination

SetBucketName sets the BucketName field's value.

func (*S3LogDestination) SetBucketOwner

func (s *S3LogDestination) SetBucketOwner(v string) *S3LogDestination

SetBucketOwner sets the BucketOwner field's value.

func (*S3LogDestination) SetOutputFormat

func (s *S3LogDestination) SetOutputFormat(v string) *S3LogDestination

SetOutputFormat sets the OutputFormat field's value.

func (*S3LogDestination) SetPrefix

func (s *S3LogDestination) SetPrefix(v string) *S3LogDestination

SetPrefix sets the Prefix field's value.

func (S3LogDestination) String

func (s S3LogDestination) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type S3LogDestinationParameters

type S3LogDestinationParameters struct {

	// Specifies the name of the Amazon S3 bucket to which EventBridge delivers
	// the log records for the pipe.
	//
	// BucketName is a required field
	BucketName *string `min:"3" type:"string" required:"true"`

	// Specifies the Amazon Web Services account that owns the Amazon S3 bucket
	// to which EventBridge delivers the log records for the pipe.
	//
	// BucketOwner is a required field
	BucketOwner *string `type:"string" required:"true"`

	// How EventBridge should format the log records.
	//
	//    * json: JSON
	//
	//    * plain: Plain text
	//
	//    * w3c: W3C extended logging file format (https://www.w3.org/TR/WD-logfile)
	OutputFormat *string `type:"string" enum:"S3OutputFormat"`

	// Specifies any prefix text with which to begin Amazon S3 log object names.
	//
	// You can use prefixes to organize the data that you store in Amazon S3 buckets.
	// A prefix is a string of characters at the beginning of the object key name.
	// A prefix can be any length, subject to the maximum length of the object key
	// name (1,024 bytes). For more information, see Organizing objects using prefixes
	// (https://docs.aws.amazon.com/AmazonS3/latest/userguide/using-prefixes.html)
	// in the Amazon Simple Storage Service User Guide.
	Prefix *string `type:"string"`
	// contains filtered or unexported fields
}

The Amazon S3 logging configuration settings for the pipe.

func (S3LogDestinationParameters) GoString

func (s S3LogDestinationParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*S3LogDestinationParameters) SetBucketName

SetBucketName sets the BucketName field's value.

func (*S3LogDestinationParameters) SetBucketOwner

SetBucketOwner sets the BucketOwner field's value.

func (*S3LogDestinationParameters) SetOutputFormat

SetOutputFormat sets the OutputFormat field's value.

func (*S3LogDestinationParameters) SetPrefix

SetPrefix sets the Prefix field's value.

func (S3LogDestinationParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*S3LogDestinationParameters) Validate

func (s *S3LogDestinationParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SageMakerPipelineParameter

type SageMakerPipelineParameter struct {

	// Name of parameter to start execution of a SageMaker Model Building Pipeline.
	//
	// Name is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by SageMakerPipelineParameter's
	// String and GoString methods.
	//
	// Name is a required field
	Name *string `min:"1" type:"string" required:"true" sensitive:"true"`

	// Value of parameter to start execution of a SageMaker Model Building Pipeline.
	//
	// Value is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by SageMakerPipelineParameter's
	// String and GoString methods.
	//
	// Value is a required field
	Value *string `type:"string" required:"true" sensitive:"true"`
	// contains filtered or unexported fields
}

Name/Value pair of a parameter to start execution of a SageMaker Model Building Pipeline.

func (SageMakerPipelineParameter) GoString

func (s SageMakerPipelineParameter) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*SageMakerPipelineParameter) SetName

SetName sets the Name field's value.

func (*SageMakerPipelineParameter) SetValue

SetValue sets the Value field's value.

func (SageMakerPipelineParameter) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*SageMakerPipelineParameter) Validate

func (s *SageMakerPipelineParameter) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SelfManagedKafkaAccessConfigurationCredentials

type SelfManagedKafkaAccessConfigurationCredentials struct {

	// The ARN of the Secrets Manager secret.
	BasicAuth *string `min:"1" type:"string"`

	// The ARN of the Secrets Manager secret.
	ClientCertificateTlsAuth *string `min:"1" type:"string"`

	// The ARN of the Secrets Manager secret.
	SaslScram256Auth *string `min:"1" type:"string"`

	// The ARN of the Secrets Manager secret.
	SaslScram512Auth *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The Secrets Manager secret that stores your stream credentials.

func (SelfManagedKafkaAccessConfigurationCredentials) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*SelfManagedKafkaAccessConfigurationCredentials) SetBasicAuth

SetBasicAuth sets the BasicAuth field's value.

func (*SelfManagedKafkaAccessConfigurationCredentials) SetClientCertificateTlsAuth

SetClientCertificateTlsAuth sets the ClientCertificateTlsAuth field's value.

func (*SelfManagedKafkaAccessConfigurationCredentials) SetSaslScram256Auth

SetSaslScram256Auth sets the SaslScram256Auth field's value.

func (*SelfManagedKafkaAccessConfigurationCredentials) SetSaslScram512Auth

SetSaslScram512Auth sets the SaslScram512Auth field's value.

func (SelfManagedKafkaAccessConfigurationCredentials) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*SelfManagedKafkaAccessConfigurationCredentials) Validate

Validate inspects the fields of the type to determine if they are valid.

type SelfManagedKafkaAccessConfigurationVpc

type SelfManagedKafkaAccessConfigurationVpc struct {

	// Specifies the security groups associated with the stream. These security
	// groups must all be in the same VPC. You can specify as many as five security
	// groups. If you do not specify a security group, the default security group
	// for the VPC is used.
	SecurityGroup []*string `type:"list"`

	// Specifies the subnets associated with the stream. These subnets must all
	// be in the same VPC. You can specify as many as 16 subnets.
	Subnets []*string `type:"list"`
	// contains filtered or unexported fields
}

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

func (SelfManagedKafkaAccessConfigurationVpc) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*SelfManagedKafkaAccessConfigurationVpc) SetSecurityGroup

SetSecurityGroup sets the SecurityGroup field's value.

func (*SelfManagedKafkaAccessConfigurationVpc) SetSubnets

SetSubnets sets the Subnets field's value.

func (SelfManagedKafkaAccessConfigurationVpc) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ServiceQuotaExceededException

type ServiceQuotaExceededException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`

	// The identifier of the quota that caused the exception.
	//
	// QuotaCode is a required field
	QuotaCode *string `locationName:"quotaCode" type:"string" required:"true"`

	// The ID of the resource that caused the exception.
	//
	// ResourceId is a required field
	ResourceId *string `locationName:"resourceId" type:"string" required:"true"`

	// The type of resource that caused the exception.
	//
	// ResourceType is a required field
	ResourceType *string `locationName:"resourceType" type:"string" required:"true"`

	// The identifier of the service that caused the exception.
	//
	// ServiceCode is a required field
	ServiceCode *string `locationName:"serviceCode" type:"string" required:"true"`
	// contains filtered or unexported fields
}

A quota has been exceeded.

func (*ServiceQuotaExceededException) Code

Code returns the exception type name.

func (*ServiceQuotaExceededException) Error

func (ServiceQuotaExceededException) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ServiceQuotaExceededException) Message

Message returns the exception's message.

func (*ServiceQuotaExceededException) OrigErr

func (s *ServiceQuotaExceededException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ServiceQuotaExceededException) RequestID

func (s *ServiceQuotaExceededException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ServiceQuotaExceededException) StatusCode

func (s *ServiceQuotaExceededException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ServiceQuotaExceededException) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type StartPipeInput

type StartPipeInput struct {

	// The name of the pipe.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (StartPipeInput) GoString

func (s StartPipeInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartPipeInput) SetName

func (s *StartPipeInput) SetName(v string) *StartPipeInput

SetName sets the Name field's value.

func (StartPipeInput) String

func (s StartPipeInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartPipeInput) Validate

func (s *StartPipeInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartPipeOutput

type StartPipeOutput struct {

	// The ARN of the pipe.
	Arn *string `min:"1" type:"string"`

	// The time the pipe was created.
	CreationTime *time.Time `type:"timestamp"`

	// The state the pipe is in.
	CurrentState *string `type:"string" enum:"PipeState"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeState"`

	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	LastModifiedTime *time.Time `type:"timestamp"`

	// The name of the pipe.
	Name *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (StartPipeOutput) GoString

func (s StartPipeOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartPipeOutput) SetArn

func (s *StartPipeOutput) SetArn(v string) *StartPipeOutput

SetArn sets the Arn field's value.

func (*StartPipeOutput) SetCreationTime

func (s *StartPipeOutput) SetCreationTime(v time.Time) *StartPipeOutput

SetCreationTime sets the CreationTime field's value.

func (*StartPipeOutput) SetCurrentState

func (s *StartPipeOutput) SetCurrentState(v string) *StartPipeOutput

SetCurrentState sets the CurrentState field's value.

func (*StartPipeOutput) SetDesiredState

func (s *StartPipeOutput) SetDesiredState(v string) *StartPipeOutput

SetDesiredState sets the DesiredState field's value.

func (*StartPipeOutput) SetLastModifiedTime

func (s *StartPipeOutput) SetLastModifiedTime(v time.Time) *StartPipeOutput

SetLastModifiedTime sets the LastModifiedTime field's value.

func (*StartPipeOutput) SetName

func (s *StartPipeOutput) SetName(v string) *StartPipeOutput

SetName sets the Name field's value.

func (StartPipeOutput) String

func (s StartPipeOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type StopPipeInput

type StopPipeInput struct {

	// The name of the pipe.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (StopPipeInput) GoString

func (s StopPipeInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StopPipeInput) SetName

func (s *StopPipeInput) SetName(v string) *StopPipeInput

SetName sets the Name field's value.

func (StopPipeInput) String

func (s StopPipeInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StopPipeInput) Validate

func (s *StopPipeInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StopPipeOutput

type StopPipeOutput struct {

	// The ARN of the pipe.
	Arn *string `min:"1" type:"string"`

	// The time the pipe was created.
	CreationTime *time.Time `type:"timestamp"`

	// The state the pipe is in.
	CurrentState *string `type:"string" enum:"PipeState"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeState"`

	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	LastModifiedTime *time.Time `type:"timestamp"`

	// The name of the pipe.
	Name *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (StopPipeOutput) GoString

func (s StopPipeOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StopPipeOutput) SetArn

func (s *StopPipeOutput) SetArn(v string) *StopPipeOutput

SetArn sets the Arn field's value.

func (*StopPipeOutput) SetCreationTime

func (s *StopPipeOutput) SetCreationTime(v time.Time) *StopPipeOutput

SetCreationTime sets the CreationTime field's value.

func (*StopPipeOutput) SetCurrentState

func (s *StopPipeOutput) SetCurrentState(v string) *StopPipeOutput

SetCurrentState sets the CurrentState field's value.

func (*StopPipeOutput) SetDesiredState

func (s *StopPipeOutput) SetDesiredState(v string) *StopPipeOutput

SetDesiredState sets the DesiredState field's value.

func (*StopPipeOutput) SetLastModifiedTime

func (s *StopPipeOutput) SetLastModifiedTime(v time.Time) *StopPipeOutput

SetLastModifiedTime sets the LastModifiedTime field's value.

func (*StopPipeOutput) SetName

func (s *StopPipeOutput) SetName(v string) *StopPipeOutput

SetName sets the Name field's value.

func (StopPipeOutput) String

func (s StopPipeOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type Tag

type Tag struct {

	// A string you can use to assign a value. The combination of tag keys and values
	// can help you organize and categorize your resources.
	//
	// Key is a required field
	Key *string `min:"1" type:"string" required:"true"`

	// The value for the specified tag key.
	//
	// Value is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by Tag's
	// String and GoString methods.
	//
	// Value is a required field
	Value *string `type:"string" required:"true" sensitive:"true"`
	// contains filtered or unexported fields
}

A key-value pair associated with an Amazon Web Services resource. In EventBridge, rules and event buses support tagging.

func (Tag) GoString

func (s Tag) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Tag) SetKey

func (s *Tag) SetKey(v string) *Tag

SetKey sets the Key field's value.

func (*Tag) SetValue

func (s *Tag) SetValue(v string) *Tag

SetValue sets the Value field's value.

func (Tag) String

func (s Tag) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Tag) Validate

func (s *Tag) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TagResourceInput

type TagResourceInput struct {

	// The ARN of the pipe.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" min:"1" type:"string" required:"true"`

	// The list of key-value pairs associated with the pipe.
	//
	// Tags is a required field
	Tags map[string]*string `locationName:"tags" min:"1" type:"map" required:"true"`
	// contains filtered or unexported fields
}

func (TagResourceInput) GoString

func (s TagResourceInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*TagResourceInput) SetResourceArn

func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags

func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput

SetTags sets the Tags field's value.

func (TagResourceInput) String

func (s TagResourceInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*TagResourceInput) Validate

func (s *TagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TagResourceOutput

type TagResourceOutput struct {
	// contains filtered or unexported fields
}

func (TagResourceOutput) GoString

func (s TagResourceOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (TagResourceOutput) String

func (s TagResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ThrottlingException

type ThrottlingException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`

	// The identifier of the quota that caused the exception.
	QuotaCode *string `locationName:"quotaCode" type:"string"`

	// The number of seconds to wait before retrying the action that caused the
	// exception.
	RetryAfterSeconds *int64 `location:"header" locationName:"Retry-After" type:"integer"`

	// The identifier of the service that caused the exception.
	ServiceCode *string `locationName:"serviceCode" type:"string"`
	// contains filtered or unexported fields
}

An action was throttled.

func (*ThrottlingException) Code

func (s *ThrottlingException) Code() string

Code returns the exception type name.

func (*ThrottlingException) Error

func (s *ThrottlingException) Error() string

func (ThrottlingException) GoString

func (s ThrottlingException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ThrottlingException) Message

func (s *ThrottlingException) Message() string

Message returns the exception's message.

func (*ThrottlingException) OrigErr

func (s *ThrottlingException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ThrottlingException) RequestID

func (s *ThrottlingException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ThrottlingException) StatusCode

func (s *ThrottlingException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ThrottlingException) String

func (s ThrottlingException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type UntagResourceInput

type UntagResourceInput struct {

	// The ARN of the pipe.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" min:"1" type:"string" required:"true"`

	// The list of tag keys to remove from the pipe.
	//
	// TagKeys is a required field
	TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
	// contains filtered or unexported fields
}

func (UntagResourceInput) GoString

func (s UntagResourceInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UntagResourceInput) SetResourceArn

func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys

func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String

func (s UntagResourceInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UntagResourceInput) Validate

func (s *UntagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UntagResourceOutput

type UntagResourceOutput struct {
	// contains filtered or unexported fields
}

func (UntagResourceOutput) GoString

func (s UntagResourceOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (UntagResourceOutput) String

func (s UntagResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type UpdatePipeInput

type UpdatePipeInput struct {

	// A description of the pipe.
	//
	// Description is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by UpdatePipeInput's
	// String and GoString methods.
	Description *string `type:"string" sensitive:"true"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeState"`

	// The ARN of the enrichment resource.
	Enrichment *string `type:"string"`

	// The parameters required to set up enrichment on your pipe.
	EnrichmentParameters *PipeEnrichmentParameters `type:"structure"`

	// The logging configuration settings for the pipe.
	LogConfiguration *PipeLogConfigurationParameters `type:"structure"`

	// The name of the pipe.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`

	// The ARN of the role that allows the pipe to send data to the target.
	//
	// RoleArn is a required field
	RoleArn *string `min:"1" type:"string" required:"true"`

	// The parameters required to set up a source for your pipe.
	SourceParameters *UpdatePipeSourceParameters `type:"structure"`

	// The ARN of the target resource.
	Target *string `min:"1" type:"string"`

	// The parameters required to set up a target for your pipe.
	//
	// For more information about pipe target parameters, including how to use dynamic
	// path parameters, see Target parameters (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-target.html)
	// in the Amazon EventBridge User Guide.
	TargetParameters *PipeTargetParameters `type:"structure"`
	// contains filtered or unexported fields
}

func (UpdatePipeInput) GoString

func (s UpdatePipeInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeInput) SetDescription

func (s *UpdatePipeInput) SetDescription(v string) *UpdatePipeInput

SetDescription sets the Description field's value.

func (*UpdatePipeInput) SetDesiredState

func (s *UpdatePipeInput) SetDesiredState(v string) *UpdatePipeInput

SetDesiredState sets the DesiredState field's value.

func (*UpdatePipeInput) SetEnrichment

func (s *UpdatePipeInput) SetEnrichment(v string) *UpdatePipeInput

SetEnrichment sets the Enrichment field's value.

func (*UpdatePipeInput) SetEnrichmentParameters

func (s *UpdatePipeInput) SetEnrichmentParameters(v *PipeEnrichmentParameters) *UpdatePipeInput

SetEnrichmentParameters sets the EnrichmentParameters field's value.

func (*UpdatePipeInput) SetLogConfiguration

SetLogConfiguration sets the LogConfiguration field's value.

func (*UpdatePipeInput) SetName

func (s *UpdatePipeInput) SetName(v string) *UpdatePipeInput

SetName sets the Name field's value.

func (*UpdatePipeInput) SetRoleArn

func (s *UpdatePipeInput) SetRoleArn(v string) *UpdatePipeInput

SetRoleArn sets the RoleArn field's value.

func (*UpdatePipeInput) SetSourceParameters

func (s *UpdatePipeInput) SetSourceParameters(v *UpdatePipeSourceParameters) *UpdatePipeInput

SetSourceParameters sets the SourceParameters field's value.

func (*UpdatePipeInput) SetTarget

func (s *UpdatePipeInput) SetTarget(v string) *UpdatePipeInput

SetTarget sets the Target field's value.

func (*UpdatePipeInput) SetTargetParameters

func (s *UpdatePipeInput) SetTargetParameters(v *PipeTargetParameters) *UpdatePipeInput

SetTargetParameters sets the TargetParameters field's value.

func (UpdatePipeInput) String

func (s UpdatePipeInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeInput) Validate

func (s *UpdatePipeInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeOutput

type UpdatePipeOutput struct {

	// The ARN of the pipe.
	Arn *string `min:"1" type:"string"`

	// The time the pipe was created.
	CreationTime *time.Time `type:"timestamp"`

	// The state the pipe is in.
	CurrentState *string `type:"string" enum:"PipeState"`

	// The state the pipe should be in.
	DesiredState *string `type:"string" enum:"RequestedPipeState"`

	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	LastModifiedTime *time.Time `type:"timestamp"`

	// The name of the pipe.
	Name *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (UpdatePipeOutput) GoString

func (s UpdatePipeOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeOutput) SetArn

SetArn sets the Arn field's value.

func (*UpdatePipeOutput) SetCreationTime

func (s *UpdatePipeOutput) SetCreationTime(v time.Time) *UpdatePipeOutput

SetCreationTime sets the CreationTime field's value.

func (*UpdatePipeOutput) SetCurrentState

func (s *UpdatePipeOutput) SetCurrentState(v string) *UpdatePipeOutput

SetCurrentState sets the CurrentState field's value.

func (*UpdatePipeOutput) SetDesiredState

func (s *UpdatePipeOutput) SetDesiredState(v string) *UpdatePipeOutput

SetDesiredState sets the DesiredState field's value.

func (*UpdatePipeOutput) SetLastModifiedTime

func (s *UpdatePipeOutput) SetLastModifiedTime(v time.Time) *UpdatePipeOutput

SetLastModifiedTime sets the LastModifiedTime field's value.

func (*UpdatePipeOutput) SetName

func (s *UpdatePipeOutput) SetName(v string) *UpdatePipeOutput

SetName sets the Name field's value.

func (UpdatePipeOutput) String

func (s UpdatePipeOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type UpdatePipeSourceActiveMQBrokerParameters

type UpdatePipeSourceActiveMQBrokerParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The credentials needed to access the resource.
	//
	// Credentials is a required field
	Credentials *MQBrokerAccessCredentials `type:"structure" required:"true"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`
	// contains filtered or unexported fields
}

The parameters for using an Active MQ broker as a source.

func (UpdatePipeSourceActiveMQBrokerParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceActiveMQBrokerParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*UpdatePipeSourceActiveMQBrokerParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*UpdatePipeSourceActiveMQBrokerParameters) SetMaximumBatchingWindowInSeconds

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (UpdatePipeSourceActiveMQBrokerParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceActiveMQBrokerParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeSourceDynamoDBStreamParameters

type UpdatePipeSourceDynamoDBStreamParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// Define the target queue to send dead-letter queue events to.
	DeadLetterConfig *DeadLetterConfig `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records older than the specified age. The default
	// value is -1, which sets the maximum age to infinite. When the value is set
	// to infinite, EventBridge never discards old records.
	MaximumRecordAgeInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records after the specified number of retries. The
	// default value is -1, which sets the maximum number of retries to infinite.
	// When MaximumRetryAttempts is infinite, EventBridge retries failed records
	// until the record expires in the event source.
	MaximumRetryAttempts *int64 `type:"integer"`

	// (Streams only) Define how to handle item process failures. AUTOMATIC_BISECT
	// halves each batch and retry each half until all the records are processed
	// or there is one failed message left in the batch.
	OnPartialBatchItemFailure *string `type:"string" enum:"OnPartialBatchItemFailureStreams"`

	// (Streams only) The number of batches to process concurrently from each shard.
	// The default value is 1.
	ParallelizationFactor *int64 `min:"1" type:"integer"`
	// contains filtered or unexported fields
}

The parameters for using a DynamoDB stream as a source.

func (UpdatePipeSourceDynamoDBStreamParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceDynamoDBStreamParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*UpdatePipeSourceDynamoDBStreamParameters) SetDeadLetterConfig

SetDeadLetterConfig sets the DeadLetterConfig field's value.

func (*UpdatePipeSourceDynamoDBStreamParameters) SetMaximumBatchingWindowInSeconds

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*UpdatePipeSourceDynamoDBStreamParameters) SetMaximumRecordAgeInSeconds

SetMaximumRecordAgeInSeconds sets the MaximumRecordAgeInSeconds field's value.

func (*UpdatePipeSourceDynamoDBStreamParameters) SetMaximumRetryAttempts

SetMaximumRetryAttempts sets the MaximumRetryAttempts field's value.

func (*UpdatePipeSourceDynamoDBStreamParameters) SetOnPartialBatchItemFailure

SetOnPartialBatchItemFailure sets the OnPartialBatchItemFailure field's value.

func (*UpdatePipeSourceDynamoDBStreamParameters) SetParallelizationFactor

SetParallelizationFactor sets the ParallelizationFactor field's value.

func (UpdatePipeSourceDynamoDBStreamParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceDynamoDBStreamParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeSourceKinesisStreamParameters

type UpdatePipeSourceKinesisStreamParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// Define the target queue to send dead-letter queue events to.
	DeadLetterConfig *DeadLetterConfig `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records older than the specified age. The default
	// value is -1, which sets the maximum age to infinite. When the value is set
	// to infinite, EventBridge never discards old records.
	MaximumRecordAgeInSeconds *int64 `type:"integer"`

	// (Streams only) Discard records after the specified number of retries. The
	// default value is -1, which sets the maximum number of retries to infinite.
	// When MaximumRetryAttempts is infinite, EventBridge retries failed records
	// until the record expires in the event source.
	MaximumRetryAttempts *int64 `type:"integer"`

	// (Streams only) Define how to handle item process failures. AUTOMATIC_BISECT
	// halves each batch and retry each half until all the records are processed
	// or there is one failed message left in the batch.
	OnPartialBatchItemFailure *string `type:"string" enum:"OnPartialBatchItemFailureStreams"`

	// (Streams only) The number of batches to process concurrently from each shard.
	// The default value is 1.
	ParallelizationFactor *int64 `min:"1" type:"integer"`
	// contains filtered or unexported fields
}

The parameters for using a Kinesis stream as a source.

func (UpdatePipeSourceKinesisStreamParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceKinesisStreamParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*UpdatePipeSourceKinesisStreamParameters) SetDeadLetterConfig

SetDeadLetterConfig sets the DeadLetterConfig field's value.

func (*UpdatePipeSourceKinesisStreamParameters) SetMaximumBatchingWindowInSeconds

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*UpdatePipeSourceKinesisStreamParameters) SetMaximumRecordAgeInSeconds

SetMaximumRecordAgeInSeconds sets the MaximumRecordAgeInSeconds field's value.

func (*UpdatePipeSourceKinesisStreamParameters) SetMaximumRetryAttempts

SetMaximumRetryAttempts sets the MaximumRetryAttempts field's value.

func (*UpdatePipeSourceKinesisStreamParameters) SetOnPartialBatchItemFailure

SetOnPartialBatchItemFailure sets the OnPartialBatchItemFailure field's value.

func (*UpdatePipeSourceKinesisStreamParameters) SetParallelizationFactor

SetParallelizationFactor sets the ParallelizationFactor field's value.

func (UpdatePipeSourceKinesisStreamParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceKinesisStreamParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeSourceManagedStreamingKafkaParameters

type UpdatePipeSourceManagedStreamingKafkaParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The credentials needed to access the resource.
	Credentials *MSKAccessCredentials `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`
	// contains filtered or unexported fields
}

The parameters for using an MSK stream as a source.

func (UpdatePipeSourceManagedStreamingKafkaParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceManagedStreamingKafkaParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*UpdatePipeSourceManagedStreamingKafkaParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*UpdatePipeSourceManagedStreamingKafkaParameters) SetMaximumBatchingWindowInSeconds

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (UpdatePipeSourceManagedStreamingKafkaParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceManagedStreamingKafkaParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeSourceParameters

type UpdatePipeSourceParameters struct {

	// The parameters for using an Active MQ broker as a source.
	ActiveMQBrokerParameters *UpdatePipeSourceActiveMQBrokerParameters `type:"structure"`

	// The parameters for using a DynamoDB stream as a source.
	DynamoDBStreamParameters *UpdatePipeSourceDynamoDBStreamParameters `type:"structure"`

	// The collection of event patterns used to filter events.
	//
	// To remove a filter, specify a FilterCriteria object with an empty array of
	// Filter objects.
	//
	// 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 `type:"structure"`

	// The parameters for using a Kinesis stream as a source.
	KinesisStreamParameters *UpdatePipeSourceKinesisStreamParameters `type:"structure"`

	// The parameters for using an MSK stream as a source.
	ManagedStreamingKafkaParameters *UpdatePipeSourceManagedStreamingKafkaParameters `type:"structure"`

	// The parameters for using a Rabbit MQ broker as a source.
	RabbitMQBrokerParameters *UpdatePipeSourceRabbitMQBrokerParameters `type:"structure"`

	// The parameters for using a self-managed Apache Kafka stream as a source.
	SelfManagedKafkaParameters *UpdatePipeSourceSelfManagedKafkaParameters `type:"structure"`

	// The parameters for using a Amazon SQS stream as a source.
	SqsQueueParameters *UpdatePipeSourceSqsQueueParameters `type:"structure"`
	// contains filtered or unexported fields
}

The parameters required to set up a source for your pipe.

func (UpdatePipeSourceParameters) GoString

func (s UpdatePipeSourceParameters) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceParameters) SetActiveMQBrokerParameters

SetActiveMQBrokerParameters sets the ActiveMQBrokerParameters field's value.

func (*UpdatePipeSourceParameters) SetDynamoDBStreamParameters

SetDynamoDBStreamParameters sets the DynamoDBStreamParameters field's value.

func (*UpdatePipeSourceParameters) SetFilterCriteria

SetFilterCriteria sets the FilterCriteria field's value.

func (*UpdatePipeSourceParameters) SetKinesisStreamParameters

SetKinesisStreamParameters sets the KinesisStreamParameters field's value.

func (*UpdatePipeSourceParameters) SetManagedStreamingKafkaParameters

SetManagedStreamingKafkaParameters sets the ManagedStreamingKafkaParameters field's value.

func (*UpdatePipeSourceParameters) SetRabbitMQBrokerParameters

SetRabbitMQBrokerParameters sets the RabbitMQBrokerParameters field's value.

func (*UpdatePipeSourceParameters) SetSelfManagedKafkaParameters

SetSelfManagedKafkaParameters sets the SelfManagedKafkaParameters field's value.

func (*UpdatePipeSourceParameters) SetSqsQueueParameters

SetSqsQueueParameters sets the SqsQueueParameters field's value.

func (UpdatePipeSourceParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceParameters) Validate

func (s *UpdatePipeSourceParameters) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeSourceRabbitMQBrokerParameters

type UpdatePipeSourceRabbitMQBrokerParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The credentials needed to access the resource.
	//
	// Credentials is a required field
	Credentials *MQBrokerAccessCredentials `type:"structure" required:"true"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`
	// contains filtered or unexported fields
}

The parameters for using a Rabbit MQ broker as a source.

func (UpdatePipeSourceRabbitMQBrokerParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceRabbitMQBrokerParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*UpdatePipeSourceRabbitMQBrokerParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*UpdatePipeSourceRabbitMQBrokerParameters) SetMaximumBatchingWindowInSeconds

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (UpdatePipeSourceRabbitMQBrokerParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceRabbitMQBrokerParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeSourceSelfManagedKafkaParameters

type UpdatePipeSourceSelfManagedKafkaParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The credentials needed to access the resource.
	Credentials *SelfManagedKafkaAccessConfigurationCredentials `type:"structure"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`

	// The ARN of the Secrets Manager secret used for certification.
	ServerRootCaCertificate *string `min:"1" type:"string"`

	// This structure specifies the VPC subnets and security groups for the stream,
	// and whether a public IP address is to be used.
	Vpc *SelfManagedKafkaAccessConfigurationVpc `type:"structure"`
	// contains filtered or unexported fields
}

The parameters for using a self-managed Apache Kafka stream as a source.

func (UpdatePipeSourceSelfManagedKafkaParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceSelfManagedKafkaParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*UpdatePipeSourceSelfManagedKafkaParameters) SetCredentials

SetCredentials sets the Credentials field's value.

func (*UpdatePipeSourceSelfManagedKafkaParameters) SetMaximumBatchingWindowInSeconds

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (*UpdatePipeSourceSelfManagedKafkaParameters) SetServerRootCaCertificate

SetServerRootCaCertificate sets the ServerRootCaCertificate field's value.

func (*UpdatePipeSourceSelfManagedKafkaParameters) SetVpc

SetVpc sets the Vpc field's value.

func (UpdatePipeSourceSelfManagedKafkaParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceSelfManagedKafkaParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type UpdatePipeSourceSqsQueueParameters

type UpdatePipeSourceSqsQueueParameters struct {

	// The maximum number of records to include in each batch.
	BatchSize *int64 `min:"1" type:"integer"`

	// The maximum length of a time to wait for events.
	MaximumBatchingWindowInSeconds *int64 `type:"integer"`
	// contains filtered or unexported fields
}

The parameters for using a Amazon SQS stream as a source.

func (UpdatePipeSourceSqsQueueParameters) GoString

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceSqsQueueParameters) SetBatchSize

SetBatchSize sets the BatchSize field's value.

func (*UpdatePipeSourceSqsQueueParameters) SetMaximumBatchingWindowInSeconds

func (s *UpdatePipeSourceSqsQueueParameters) SetMaximumBatchingWindowInSeconds(v int64) *UpdatePipeSourceSqsQueueParameters

SetMaximumBatchingWindowInSeconds sets the MaximumBatchingWindowInSeconds field's value.

func (UpdatePipeSourceSqsQueueParameters) String

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdatePipeSourceSqsQueueParameters) Validate

Validate inspects the fields of the type to determine if they are valid.

type ValidationException

type ValidationException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	// The list of fields for which validation failed and the corresponding failure
	// messages.
	FieldList []*ValidationExceptionField `locationName:"fieldList" type:"list"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

Indicates that an error has occurred while performing a validate operation.

func (*ValidationException) Code

func (s *ValidationException) Code() string

Code returns the exception type name.

func (*ValidationException) Error

func (s *ValidationException) Error() string

func (ValidationException) GoString

func (s ValidationException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ValidationException) Message

func (s *ValidationException) Message() string

Message returns the exception's message.

func (*ValidationException) OrigErr

func (s *ValidationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ValidationException) RequestID

func (s *ValidationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ValidationException) StatusCode

func (s *ValidationException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ValidationException) String

func (s ValidationException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ValidationExceptionField

type ValidationExceptionField struct {

	// The message of the exception.
	//
	// Message is a required field
	Message *string `locationName:"message" type:"string" required:"true"`

	// The name of the exception.
	//
	// Name is a required field
	Name *string `locationName:"name" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Indicates that an error has occurred while performing a validate operation.

func (ValidationExceptionField) GoString

func (s ValidationExceptionField) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ValidationExceptionField) SetMessage

SetMessage sets the Message field's value.

func (*ValidationExceptionField) SetName

SetName sets the Name field's value.

func (ValidationExceptionField) String

func (s ValidationExceptionField) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

Directories

Path Synopsis
Package pipesiface provides an interface to enable mocking the Amazon EventBridge Pipes service client for testing your code.
Package pipesiface provides an interface to enable mocking the Amazon EventBridge Pipes service client for testing your code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL