Documentation ¶
Overview ¶
The CDK Construct Library for Amazon EventBridge Pipes Targets
Index ¶
- func NewSfnStateMachine_Override(s SfnStateMachine, stateMachine awsstepfunctions.IStateMachine, ...)
- func NewSqsTarget_Override(s SqsTarget, queue awssqs.IQueue, parameters *SqsTargetParameters)
- type SfnStateMachine
- type SfnStateMachineParameters
- type SqsTarget
- type SqsTargetParameters
- type StateMachineInvocationType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSfnStateMachine_Override ¶
func NewSfnStateMachine_Override(s SfnStateMachine, stateMachine awsstepfunctions.IStateMachine, parameters *SfnStateMachineParameters)
Experimental.
func NewSqsTarget_Override ¶
func NewSqsTarget_Override(s SqsTarget, queue awssqs.IQueue, parameters *SqsTargetParameters)
Experimental.
Types ¶
type SfnStateMachine ¶
type SfnStateMachine interface { awscdkpipesalpha.ITarget // The ARN of the target resource. // Experimental. TargetArn() *string // Bind this target to a pipe. // Experimental. Bind(pipe awscdkpipesalpha.IPipe) *awscdkpipesalpha.TargetConfig // Grant the pipe role to push to the target. // Experimental. GrantPush(grantee awsiam.IRole) }
An EventBridge Pipes target that sends messages to an AWS Step Functions State Machine.
Example:
var sourceQueue queue var targetStateMachine iStateMachine pipeTarget := targets.NewSfnStateMachine(targetStateMachine, &SfnStateMachineParameters{ InvocationType: targets.StateMachineInvocationType_FIRE_AND_FORGET, }) pipe := pipes.NewPipe(this, jsii.String("Pipe"), &PipeProps{ Source: NewSomeSource(sourceQueue), Target: pipeTarget, })
Experimental.
func NewSfnStateMachine ¶
func NewSfnStateMachine(stateMachine awsstepfunctions.IStateMachine, parameters *SfnStateMachineParameters) SfnStateMachine
Experimental.
type SfnStateMachineParameters ¶
type SfnStateMachineParameters struct { // The input transformation to apply to the message before sending it to the target. // See: https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-inputtemplate // // Default: none. // // Experimental. InputTransformation awscdkpipesalpha.IInputTransformation `field:"optional" json:"inputTransformation" yaml:"inputTransformation"` // Specify whether to invoke the State Machine synchronously (`REQUEST_RESPONSE`) or asynchronously (`FIRE_AND_FORGET`). // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html#cfn-pipes-pipe-pipetargetsqsqueueparameters-messagededuplicationid // // Default: StateMachineInvocationType.FIRE_AND_FORGET // // Experimental. InvocationType StateMachineInvocationType `field:"optional" json:"invocationType" yaml:"invocationType"` }
Parameters for the SfnStateMachine target.
Example:
var sourceQueue queue var targetStateMachine iStateMachine pipeTarget := targets.NewSfnStateMachine(targetStateMachine, &SfnStateMachineParameters{ InvocationType: targets.StateMachineInvocationType_FIRE_AND_FORGET, }) pipe := pipes.NewPipe(this, jsii.String("Pipe"), &PipeProps{ Source: NewSomeSource(sourceQueue), Target: pipeTarget, })
Experimental.
type SqsTarget ¶
type SqsTarget interface { awscdkpipesalpha.ITarget // The ARN of the target resource. // Experimental. TargetArn() *string // Bind this target to a pipe. // Experimental. Bind(pipe awscdkpipesalpha.IPipe) *awscdkpipesalpha.TargetConfig // Grant the pipe role to push to the target. // Experimental. GrantPush(grantee awsiam.IRole) }
A EventBridge Pipes target that sends messages to an SQS queue.
Example:
var sourceQueue queue var targetQueue queue pipeTarget := targets.NewSqsTarget(targetQueue) pipe := pipes.NewPipe(this, jsii.String("Pipe"), &PipeProps{ Source: NewSomeSource(sourceQueue), Target: pipeTarget, })
Experimental.
func NewSqsTarget ¶
func NewSqsTarget(queue awssqs.IQueue, parameters *SqsTargetParameters) SqsTarget
Experimental.
type SqsTargetParameters ¶
type SqsTargetParameters struct { // The input transformation to apply to the message before sending it to the target. // See: https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-inputtemplate // // Default: none. // // Experimental. InputTransformation awscdkpipesalpha.IInputTransformation `field:"optional" json:"inputTransformation" yaml:"inputTransformation"` // This parameter applies only to FIFO (first-in-first-out) queues. // // The token used for deduplication of sent messages. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html#cfn-pipes-pipe-pipetargetsqsqueueparameters-messagededuplicationid // // Default: none. // // Experimental. MessageDeduplicationId *string `field:"optional" json:"messageDeduplicationId" yaml:"messageDeduplicationId"` // The FIFO message group ID to use as the target. // See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html#cfn-pipes-pipe-pipetargetsqsqueueparameters-messagegroupid // // Default: none. // // Experimental. MessageGroupId *string `field:"optional" json:"messageGroupId" yaml:"messageGroupId"` }
SQS target properties.
Example:
var sourceQueue queue var targetQueue queue pipeTarget := targets.NewSqsTarget(targetQueue, &SqsTargetParameters{ InputTransformation: pipes.InputTransformation_FromObject(map[string]interface{}{ "SomeKey": pipes.DynamicInput_fromEventPath(jsii.String("$.body")), }), }) pipe := pipes.NewPipe(this, jsii.String("Pipe"), &PipeProps{ Source: NewSomeSource(sourceQueue), Target: pipeTarget, })
Experimental.
type StateMachineInvocationType ¶
type StateMachineInvocationType string
InvocationType for invoking the State Machine.
Example:
var sourceQueue queue var targetStateMachine iStateMachine pipeTarget := targets.NewSfnStateMachine(targetStateMachine, &SfnStateMachineParameters{ InvocationType: targets.StateMachineInvocationType_FIRE_AND_FORGET, }) pipe := pipes.NewPipe(this, jsii.String("Pipe"), &PipeProps{ Source: NewSomeSource(sourceQueue), Target: pipeTarget, })
Experimental.
const ( // Invoke StepFunction asynchronously (`StartExecution`). // // See https://docs.aws.amazon.com/step-functions/latest/apireference/API_StartExecution.html for more details. // Experimental. StateMachineInvocationType_FIRE_AND_FORGET StateMachineInvocationType = "FIRE_AND_FORGET" // Invoke StepFunction synchronously (`StartSyncExecution`) and wait for the execution to complete. // // See https://docs.aws.amazon.com/step-functions/latest/apireference/API_StartSyncExecution.html for more details. // Experimental. StateMachineInvocationType_REQUEST_RESPONSE StateMachineInvocationType = "REQUEST_RESPONSE" )
Source Files ¶
Click to show internal directories.
Click to hide internal directories.