awsstepfunctionstasks

package
v2.0.0-rc.3 Latest Latest
Warning

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

 Go to latest Published: May 12, 2021 License: Apache-2.0 Imports: 22 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AthenaGetQueryExecution_FilterNextables 

func AthenaGetQueryExecution_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func AthenaGetQueryExecution_FindReachableEndStates 

func AthenaGetQueryExecution_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func AthenaGetQueryExecution_FindReachableStates 

func AthenaGetQueryExecution_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func AthenaGetQueryExecution_IsConstruct 

func AthenaGetQueryExecution_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func AthenaGetQueryExecution_PrefixStates 

func AthenaGetQueryExecution_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func AthenaGetQueryResults_FilterNextables 

func AthenaGetQueryResults_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func AthenaGetQueryResults_FindReachableEndStates 

func AthenaGetQueryResults_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func AthenaGetQueryResults_FindReachableStates 

func AthenaGetQueryResults_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func AthenaGetQueryResults_IsConstruct 

func AthenaGetQueryResults_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func AthenaGetQueryResults_PrefixStates 

func AthenaGetQueryResults_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func AthenaStartQueryExecution_FilterNextables 

func AthenaStartQueryExecution_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func AthenaStartQueryExecution_FindReachableEndStates 

func AthenaStartQueryExecution_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func AthenaStartQueryExecution_FindReachableStates 

func AthenaStartQueryExecution_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func AthenaStartQueryExecution_IsConstruct 

func AthenaStartQueryExecution_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func AthenaStartQueryExecution_PrefixStates 

func AthenaStartQueryExecution_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func AthenaStopQueryExecution_FilterNextables 

func AthenaStopQueryExecution_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func AthenaStopQueryExecution_FindReachableEndStates 

func AthenaStopQueryExecution_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func AthenaStopQueryExecution_FindReachableStates 

func AthenaStopQueryExecution_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func AthenaStopQueryExecution_IsConstruct 

func AthenaStopQueryExecution_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func AthenaStopQueryExecution_PrefixStates 

func AthenaStopQueryExecution_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func BatchSubmitJob_FilterNextables 

func BatchSubmitJob_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func BatchSubmitJob_FindReachableEndStates 

func BatchSubmitJob_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func BatchSubmitJob_FindReachableStates 

func BatchSubmitJob_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func BatchSubmitJob_IsConstruct 

func BatchSubmitJob_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func BatchSubmitJob_PrefixStates 

func BatchSubmitJob_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func CallApiGatewayHttpApiEndpoint_FilterNextables 

func CallApiGatewayHttpApiEndpoint_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func CallApiGatewayHttpApiEndpoint_FindReachableEndStates 

func CallApiGatewayHttpApiEndpoint_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func CallApiGatewayHttpApiEndpoint_FindReachableStates 

func CallApiGatewayHttpApiEndpoint_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func CallApiGatewayHttpApiEndpoint_IsConstruct 

func CallApiGatewayHttpApiEndpoint_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CallApiGatewayHttpApiEndpoint_PrefixStates 

func CallApiGatewayHttpApiEndpoint_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func CallApiGatewayRestApiEndpoint_FilterNextables 

func CallApiGatewayRestApiEndpoint_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func CallApiGatewayRestApiEndpoint_FindReachableEndStates 

func CallApiGatewayRestApiEndpoint_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func CallApiGatewayRestApiEndpoint_FindReachableStates 

func CallApiGatewayRestApiEndpoint_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func CallApiGatewayRestApiEndpoint_IsConstruct 

func CallApiGatewayRestApiEndpoint_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CallApiGatewayRestApiEndpoint_PrefixStates 

func CallApiGatewayRestApiEndpoint_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func CodeBuildStartBuild_FilterNextables 

func CodeBuildStartBuild_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func CodeBuildStartBuild_FindReachableEndStates 

func CodeBuildStartBuild_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func CodeBuildStartBuild_FindReachableStates 

func CodeBuildStartBuild_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func CodeBuildStartBuild_IsConstruct 

func CodeBuildStartBuild_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func CodeBuildStartBuild_PrefixStates 

func CodeBuildStartBuild_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func DynamoDeleteItem_FilterNextables 

func DynamoDeleteItem_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func DynamoDeleteItem_FindReachableEndStates 

func DynamoDeleteItem_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func DynamoDeleteItem_FindReachableStates 

func DynamoDeleteItem_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func DynamoDeleteItem_IsConstruct 

func DynamoDeleteItem_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func DynamoDeleteItem_PrefixStates 

func DynamoDeleteItem_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func DynamoGetItem_FilterNextables 

func DynamoGetItem_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func DynamoGetItem_FindReachableEndStates 

func DynamoGetItem_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func DynamoGetItem_FindReachableStates 

func DynamoGetItem_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func DynamoGetItem_IsConstruct 

func DynamoGetItem_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func DynamoGetItem_PrefixStates 

func DynamoGetItem_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func DynamoPutItem_FilterNextables 

func DynamoPutItem_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func DynamoPutItem_FindReachableEndStates 

func DynamoPutItem_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func DynamoPutItem_FindReachableStates 

func DynamoPutItem_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func DynamoPutItem_IsConstruct 

func DynamoPutItem_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func DynamoPutItem_PrefixStates 

func DynamoPutItem_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func DynamoUpdateItem_FilterNextables 

func DynamoUpdateItem_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func DynamoUpdateItem_FindReachableEndStates 

func DynamoUpdateItem_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func DynamoUpdateItem_FindReachableStates 

func DynamoUpdateItem_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func DynamoUpdateItem_IsConstruct 

func DynamoUpdateItem_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func DynamoUpdateItem_PrefixStates 

func DynamoUpdateItem_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EcsRunTask_FilterNextables 

func EcsRunTask_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EcsRunTask_FindReachableEndStates 

func EcsRunTask_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EcsRunTask_FindReachableStates 

func EcsRunTask_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EcsRunTask_IsConstruct 

func EcsRunTask_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EcsRunTask_PrefixStates 

func EcsRunTask_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EksCall_FilterNextables 

func EksCall_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EksCall_FindReachableEndStates 

func EksCall_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EksCall_FindReachableStates 

func EksCall_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EksCall_IsConstruct 

func EksCall_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EksCall_PrefixStates 

func EksCall_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EmrAddStep_FilterNextables 

func EmrAddStep_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EmrAddStep_FindReachableEndStates 

func EmrAddStep_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EmrAddStep_FindReachableStates 

func EmrAddStep_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EmrAddStep_IsConstruct 

func EmrAddStep_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EmrAddStep_PrefixStates 

func EmrAddStep_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EmrCancelStep_FilterNextables 

func EmrCancelStep_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EmrCancelStep_FindReachableEndStates 

func EmrCancelStep_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EmrCancelStep_FindReachableStates 

func EmrCancelStep_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EmrCancelStep_IsConstruct 

func EmrCancelStep_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EmrCancelStep_PrefixStates 

func EmrCancelStep_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EmrCreateCluster_FilterNextables 

func EmrCreateCluster_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EmrCreateCluster_FindReachableEndStates 

func EmrCreateCluster_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EmrCreateCluster_FindReachableStates 

func EmrCreateCluster_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EmrCreateCluster_IsConstruct 

func EmrCreateCluster_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EmrCreateCluster_PrefixStates 

func EmrCreateCluster_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EmrModifyInstanceFleetByName_FilterNextables 

func EmrModifyInstanceFleetByName_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EmrModifyInstanceFleetByName_FindReachableEndStates 

func EmrModifyInstanceFleetByName_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EmrModifyInstanceFleetByName_FindReachableStates 

func EmrModifyInstanceFleetByName_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EmrModifyInstanceFleetByName_IsConstruct 

func EmrModifyInstanceFleetByName_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EmrModifyInstanceFleetByName_PrefixStates 

func EmrModifyInstanceFleetByName_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EmrModifyInstanceGroupByName_FilterNextables 

func EmrModifyInstanceGroupByName_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EmrModifyInstanceGroupByName_FindReachableEndStates 

func EmrModifyInstanceGroupByName_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EmrModifyInstanceGroupByName_FindReachableStates 

func EmrModifyInstanceGroupByName_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EmrModifyInstanceGroupByName_IsConstruct 

func EmrModifyInstanceGroupByName_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EmrModifyInstanceGroupByName_PrefixStates 

func EmrModifyInstanceGroupByName_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EmrSetClusterTerminationProtection_FilterNextables 

func EmrSetClusterTerminationProtection_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EmrSetClusterTerminationProtection_FindReachableEndStates 

func EmrSetClusterTerminationProtection_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EmrSetClusterTerminationProtection_FindReachableStates 

func EmrSetClusterTerminationProtection_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EmrSetClusterTerminationProtection_IsConstruct 

func EmrSetClusterTerminationProtection_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EmrSetClusterTerminationProtection_PrefixStates 

func EmrSetClusterTerminationProtection_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EmrTerminateCluster_FilterNextables 

func EmrTerminateCluster_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EmrTerminateCluster_FindReachableEndStates 

func EmrTerminateCluster_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EmrTerminateCluster_FindReachableStates 

func EmrTerminateCluster_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EmrTerminateCluster_IsConstruct 

func EmrTerminateCluster_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EmrTerminateCluster_PrefixStates 

func EmrTerminateCluster_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func EvaluateExpression_FilterNextables 

func EvaluateExpression_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func EvaluateExpression_FindReachableEndStates 

func EvaluateExpression_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func EvaluateExpression_FindReachableStates 

func EvaluateExpression_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func EvaluateExpression_IsConstruct 

func EvaluateExpression_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func EvaluateExpression_PrefixStates 

func EvaluateExpression_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func GlueDataBrewStartJobRun_FilterNextables 

func GlueDataBrewStartJobRun_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func GlueDataBrewStartJobRun_FindReachableEndStates 

func GlueDataBrewStartJobRun_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func GlueDataBrewStartJobRun_FindReachableStates 

func GlueDataBrewStartJobRun_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func GlueDataBrewStartJobRun_IsConstruct 

func GlueDataBrewStartJobRun_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func GlueDataBrewStartJobRun_PrefixStates 

func GlueDataBrewStartJobRun_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func GlueStartJobRun_FilterNextables 

func GlueStartJobRun_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func GlueStartJobRun_FindReachableEndStates 

func GlueStartJobRun_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func GlueStartJobRun_FindReachableStates 

func GlueStartJobRun_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func GlueStartJobRun_IsConstruct 

func GlueStartJobRun_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func GlueStartJobRun_PrefixStates 

func GlueStartJobRun_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func LambdaInvoke_FilterNextables 

func LambdaInvoke_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func LambdaInvoke_FindReachableEndStates 

func LambdaInvoke_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func LambdaInvoke_FindReachableStates 

func LambdaInvoke_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func LambdaInvoke_IsConstruct 

func LambdaInvoke_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func LambdaInvoke_PrefixStates 

func LambdaInvoke_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func NewAcceleratorType_Override 

func NewAcceleratorType_Override(a AcceleratorType, instanceTypeIdentifier *string)

Experimental.

func NewAthenaGetQueryExecution_Override 

func NewAthenaGetQueryExecution_Override(a AthenaGetQueryExecution, scope constructs.Construct, id *string, props *AthenaGetQueryExecutionProps)

Experimental.

func NewAthenaGetQueryResults_Override 

func NewAthenaGetQueryResults_Override(a AthenaGetQueryResults, scope constructs.Construct, id *string, props *AthenaGetQueryResultsProps)

Experimental.

func NewAthenaStartQueryExecution_Override 

func NewAthenaStartQueryExecution_Override(a AthenaStartQueryExecution, scope constructs.Construct, id *string, props *AthenaStartQueryExecutionProps)

Experimental.

func NewAthenaStopQueryExecution_Override 

func NewAthenaStopQueryExecution_Override(a AthenaStopQueryExecution, scope constructs.Construct, id *string, props *AthenaStopQueryExecutionProps)

Experimental.

func NewBatchSubmitJob_Override 

func NewBatchSubmitJob_Override(b BatchSubmitJob, scope constructs.Construct, id *string, props *BatchSubmitJobProps)

Experimental.

func NewCallApiGatewayHttpApiEndpoint_Override 

func NewCallApiGatewayHttpApiEndpoint_Override(c CallApiGatewayHttpApiEndpoint, scope constructs.Construct, id *string, props *CallApiGatewayHttpApiEndpointProps)

Experimental.

func NewCallApiGatewayRestApiEndpoint_Override 

func NewCallApiGatewayRestApiEndpoint_Override(c CallApiGatewayRestApiEndpoint, scope constructs.Construct, id *string, props *CallApiGatewayRestApiEndpointProps)

Experimental.

func NewCodeBuildStartBuild_Override 

func NewCodeBuildStartBuild_Override(c CodeBuildStartBuild, scope constructs.Construct, id *string, props *CodeBuildStartBuildProps)

Experimental.

func NewContainerDefinition_Override 

func NewContainerDefinition_Override(c ContainerDefinition, options *ContainerDefinitionOptions)

Experimental.

func NewDockerImage_Override 

func NewDockerImage_Override(d DockerImage)

Experimental.

func NewDynamoDeleteItem_Override 

func NewDynamoDeleteItem_Override(d DynamoDeleteItem, scope constructs.Construct, id *string, props *DynamoDeleteItemProps)

Experimental.

func NewDynamoGetItem_Override 

func NewDynamoGetItem_Override(d DynamoGetItem, scope constructs.Construct, id *string, props *DynamoGetItemProps)

Experimental.

func NewDynamoProjectionExpression_Override 

func NewDynamoProjectionExpression_Override(d DynamoProjectionExpression)

Experimental.

func NewDynamoPutItem_Override 

func NewDynamoPutItem_Override(d DynamoPutItem, scope constructs.Construct, id *string, props *DynamoPutItemProps)

Experimental.

func NewDynamoUpdateItem_Override 

func NewDynamoUpdateItem_Override(d DynamoUpdateItem, scope constructs.Construct, id *string, props *DynamoUpdateItemProps)

Experimental.

func NewEcsEc2LaunchTarget_Override 

func NewEcsEc2LaunchTarget_Override(e EcsEc2LaunchTarget, options *EcsEc2LaunchTargetOptions)

Experimental.

func NewEcsFargateLaunchTarget_Override 

func NewEcsFargateLaunchTarget_Override(e EcsFargateLaunchTarget, options *EcsFargateLaunchTargetOptions)

Experimental.

func NewEcsRunTask_Override 

func NewEcsRunTask_Override(e EcsRunTask, scope constructs.Construct, id *string, props *EcsRunTaskProps)

Experimental.

func NewEksCall_Override 

func NewEksCall_Override(e EksCall, scope constructs.Construct, id *string, props *EksCallProps)

Experimental.

func NewEmrAddStep_Override 

func NewEmrAddStep_Override(e EmrAddStep, scope constructs.Construct, id *string, props *EmrAddStepProps)

Experimental.

func NewEmrCancelStep_Override 

func NewEmrCancelStep_Override(e EmrCancelStep, scope constructs.Construct, id *string, props *EmrCancelStepProps)

Experimental.

func NewEmrCreateCluster_Override 

func NewEmrCreateCluster_Override(e EmrCreateCluster, scope constructs.Construct, id *string, props *EmrCreateClusterProps)

Experimental.

func NewEmrModifyInstanceFleetByName_Override 

func NewEmrModifyInstanceFleetByName_Override(e EmrModifyInstanceFleetByName, scope constructs.Construct, id *string, props *EmrModifyInstanceFleetByNameProps)

Experimental.

func NewEmrModifyInstanceGroupByName_Override 

func NewEmrModifyInstanceGroupByName_Override(e EmrModifyInstanceGroupByName, scope constructs.Construct, id *string, props *EmrModifyInstanceGroupByNameProps)

Experimental.

func NewEmrSetClusterTerminationProtection_Override 

func NewEmrSetClusterTerminationProtection_Override(e EmrSetClusterTerminationProtection, scope constructs.Construct, id *string, props *EmrSetClusterTerminationProtectionProps)

Experimental.

func NewEmrTerminateCluster_Override 

func NewEmrTerminateCluster_Override(e EmrTerminateCluster, scope constructs.Construct, id *string, props *EmrTerminateClusterProps)

Experimental.

func NewEvaluateExpression_Override 

func NewEvaluateExpression_Override(e EvaluateExpression, scope constructs.Construct, id *string, props *EvaluateExpressionProps)

Experimental.

func NewGlueDataBrewStartJobRun_Override 

func NewGlueDataBrewStartJobRun_Override(g GlueDataBrewStartJobRun, scope constructs.Construct, id *string, props *GlueDataBrewStartJobRunProps)

Experimental.

func NewGlueStartJobRun_Override 

func NewGlueStartJobRun_Override(g GlueStartJobRun, scope constructs.Construct, id *string, props *GlueStartJobRunProps)

Experimental.

func NewLambdaInvoke_Override 

func NewLambdaInvoke_Override(l LambdaInvoke, scope constructs.Construct, id *string, props *LambdaInvokeProps)

Experimental.

func NewS3Location_Override 

func NewS3Location_Override(s S3Location)

Experimental.

func NewSageMakerCreateEndpointConfig_Override 

func NewSageMakerCreateEndpointConfig_Override(s SageMakerCreateEndpointConfig, scope constructs.Construct, id *string, props *SageMakerCreateEndpointConfigProps)

Experimental.

func NewSageMakerCreateEndpoint_Override 

func NewSageMakerCreateEndpoint_Override(s SageMakerCreateEndpoint, scope constructs.Construct, id *string, props *SageMakerCreateEndpointProps)

Experimental.

func NewSageMakerCreateModel_Override 

func NewSageMakerCreateModel_Override(s SageMakerCreateModel, scope constructs.Construct, id *string, props *SageMakerCreateModelProps)

Experimental.

func NewSageMakerCreateTrainingJob_Override 

func NewSageMakerCreateTrainingJob_Override(s SageMakerCreateTrainingJob, scope constructs.Construct, id *string, props *SageMakerCreateTrainingJobProps)

Experimental.

func NewSageMakerCreateTransformJob_Override 

func NewSageMakerCreateTransformJob_Override(s SageMakerCreateTransformJob, scope constructs.Construct, id *string, props *SageMakerCreateTransformJobProps)

Experimental.

func NewSageMakerUpdateEndpoint_Override 

func NewSageMakerUpdateEndpoint_Override(s SageMakerUpdateEndpoint, scope constructs.Construct, id *string, props *SageMakerUpdateEndpointProps)

Experimental.

func NewSnsPublish_Override 

func NewSnsPublish_Override(s SnsPublish, scope constructs.Construct, id *string, props *SnsPublishProps)

Experimental.

func NewSqsSendMessage_Override 

func NewSqsSendMessage_Override(s SqsSendMessage, scope constructs.Construct, id *string, props *SqsSendMessageProps)

Experimental.

func NewStepFunctionsInvokeActivity_Override 

func NewStepFunctionsInvokeActivity_Override(s StepFunctionsInvokeActivity, scope constructs.Construct, id *string, props *StepFunctionsInvokeActivityProps)

Experimental.

func NewStepFunctionsStartExecution_Override 

func NewStepFunctionsStartExecution_Override(s StepFunctionsStartExecution, scope constructs.Construct, id *string, props *StepFunctionsStartExecutionProps)

Experimental.

func SageMakerCreateEndpointConfig_FilterNextables 

func SageMakerCreateEndpointConfig_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SageMakerCreateEndpointConfig_FindReachableEndStates 

func SageMakerCreateEndpointConfig_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SageMakerCreateEndpointConfig_FindReachableStates 

func SageMakerCreateEndpointConfig_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SageMakerCreateEndpointConfig_IsConstruct 

func SageMakerCreateEndpointConfig_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SageMakerCreateEndpointConfig_PrefixStates 

func SageMakerCreateEndpointConfig_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func SageMakerCreateEndpoint_FilterNextables 

func SageMakerCreateEndpoint_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SageMakerCreateEndpoint_FindReachableEndStates 

func SageMakerCreateEndpoint_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SageMakerCreateEndpoint_FindReachableStates 

func SageMakerCreateEndpoint_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SageMakerCreateEndpoint_IsConstruct 

func SageMakerCreateEndpoint_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SageMakerCreateEndpoint_PrefixStates 

func SageMakerCreateEndpoint_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func SageMakerCreateModel_FilterNextables 

func SageMakerCreateModel_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SageMakerCreateModel_FindReachableEndStates 

func SageMakerCreateModel_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SageMakerCreateModel_FindReachableStates 

func SageMakerCreateModel_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SageMakerCreateModel_IsConstruct 

func SageMakerCreateModel_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SageMakerCreateModel_PrefixStates 

func SageMakerCreateModel_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func SageMakerCreateTrainingJob_FilterNextables 

func SageMakerCreateTrainingJob_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SageMakerCreateTrainingJob_FindReachableEndStates 

func SageMakerCreateTrainingJob_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SageMakerCreateTrainingJob_FindReachableStates 

func SageMakerCreateTrainingJob_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SageMakerCreateTrainingJob_IsConstruct 

func SageMakerCreateTrainingJob_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SageMakerCreateTrainingJob_PrefixStates 

func SageMakerCreateTrainingJob_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func SageMakerCreateTransformJob_FilterNextables 

func SageMakerCreateTransformJob_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SageMakerCreateTransformJob_FindReachableEndStates 

func SageMakerCreateTransformJob_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SageMakerCreateTransformJob_FindReachableStates 

func SageMakerCreateTransformJob_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SageMakerCreateTransformJob_IsConstruct 

func SageMakerCreateTransformJob_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SageMakerCreateTransformJob_PrefixStates 

func SageMakerCreateTransformJob_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func SageMakerUpdateEndpoint_FilterNextables 

func SageMakerUpdateEndpoint_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SageMakerUpdateEndpoint_FindReachableEndStates 

func SageMakerUpdateEndpoint_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SageMakerUpdateEndpoint_FindReachableStates 

func SageMakerUpdateEndpoint_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SageMakerUpdateEndpoint_IsConstruct 

func SageMakerUpdateEndpoint_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SageMakerUpdateEndpoint_PrefixStates 

func SageMakerUpdateEndpoint_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func SnsPublish_FilterNextables 

func SnsPublish_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SnsPublish_FindReachableEndStates 

func SnsPublish_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SnsPublish_FindReachableStates 

func SnsPublish_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SnsPublish_IsConstruct 

func SnsPublish_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SnsPublish_PrefixStates 

func SnsPublish_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func SqsSendMessage_FilterNextables 

func SqsSendMessage_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func SqsSendMessage_FindReachableEndStates 

func SqsSendMessage_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func SqsSendMessage_FindReachableStates 

func SqsSendMessage_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func SqsSendMessage_IsConstruct 

func SqsSendMessage_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func SqsSendMessage_PrefixStates 

func SqsSendMessage_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func StepFunctionsInvokeActivity_FilterNextables 

func StepFunctionsInvokeActivity_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func StepFunctionsInvokeActivity_FindReachableEndStates 

func StepFunctionsInvokeActivity_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func StepFunctionsInvokeActivity_FindReachableStates 

func StepFunctionsInvokeActivity_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func StepFunctionsInvokeActivity_IsConstruct 

func StepFunctionsInvokeActivity_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func StepFunctionsInvokeActivity_PrefixStates 

func StepFunctionsInvokeActivity_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

func StepFunctionsStartExecution_FilterNextables 

func StepFunctionsStartExecution_FilterNextables(states *[]awsstepfunctions.State) *[]awsstepfunctions.INextable

Return only the states that allow chaining from an array of states. Experimental.

func StepFunctionsStartExecution_FindReachableEndStates 

func StepFunctionsStartExecution_FindReachableEndStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of end states states reachable through transitions from the given start state. Experimental.

func StepFunctionsStartExecution_FindReachableStates 

func StepFunctionsStartExecution_FindReachableStates(start awsstepfunctions.State, options *awsstepfunctions.FindStateOptions) *[]awsstepfunctions.State

Find the set of states reachable through transitions from the given start state.

This does not retrieve states from within sub-graphs, such as states within a Parallel state's branch. Experimental.

func StepFunctionsStartExecution_IsConstruct 

func StepFunctionsStartExecution_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead

func StepFunctionsStartExecution_PrefixStates 

func StepFunctionsStartExecution_PrefixStates(root constructs.IConstruct, prefix *string)

Add a prefix to the stateId of all States found in a construct tree. Experimental.

Types

type AcceleratorClass 

type AcceleratorClass interface {
	Version() *string
}

The generation of Elastic Inference (EI) instance. See: https://docs.aws.amazon.com/sagemaker/latest/dg/ei.html

Experimental.

func AcceleratorClass_EIA1 

func AcceleratorClass_EIA1() AcceleratorClass

func AcceleratorClass_EIA2 

func AcceleratorClass_EIA2() AcceleratorClass

func AcceleratorClass_Of 

func AcceleratorClass_Of(version *string) AcceleratorClass

Custom AcceleratorType. Experimental.

type AcceleratorType 

type AcceleratorType interface {
	ToString() *string
}

The size of the Elastic Inference (EI) instance to use for the production variant.

EI instances provide on-demand GPU computing for inference See: https://docs.aws.amazon.com/sagemaker/latest/dg/ei.html

Experimental.

func AcceleratorType_Of 

func AcceleratorType_Of(acceleratorClass AcceleratorClass, instanceSize awsec2.InstanceSize) AcceleratorType

AcceleratorType.

This class takes a combination of a class and size. Experimental.

func NewAcceleratorType 

func NewAcceleratorType(instanceTypeIdentifier *string) AcceleratorType

Experimental.

type ActionOnFailure 

type ActionOnFailure string

The action to take when the cluster step fails. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_StepConfig.html

Here, they are named as TERMINATE_JOB_FLOW, TERMINATE_CLUSTER, CANCEL_AND_WAIT, and CONTINUE respectively.

Experimental. 

const (
	ActionOnFailure_TERMINATE_CLUSTER ActionOnFailure = "TERMINATE_CLUSTER"
	ActionOnFailure_CANCEL_AND_WAIT   ActionOnFailure = "CANCEL_AND_WAIT"
	ActionOnFailure_CONTINUE          ActionOnFailure = "CONTINUE"
)

type AlgorithmSpecification 

type AlgorithmSpecification struct {
	// Name of the algorithm resource to use for the training job.
	//
	// This must be an algorithm resource that you created or subscribe to on AWS Marketplace.
	// If you specify a value for this parameter, you can't specify a value for TrainingImage.
	// Experimental.
	AlgorithmName *string `json:"algorithmName"`
	// List of metric definition objects.
	//
	// Each object specifies the metric name and regular expressions used to parse algorithm logs.
	// Experimental.
	MetricDefinitions *[]*MetricDefinition `json:"metricDefinitions"`
	// Registry path of the Docker image that contains the training algorithm.
	// Experimental.
	TrainingImage DockerImage `json:"trainingImage"`
	// Input mode that the algorithm supports.
	// Experimental.
	TrainingInputMode InputMode `json:"trainingInputMode"`
}

Specify the training algorithm and algorithm-specific metadata. Experimental.

type AssembleWith 

type AssembleWith string

How to assemble the results of the transform job as a single S3 object. Experimental. 

const (
	AssembleWith_NONE AssembleWith = "NONE"
	AssembleWith_LINE AssembleWith = "LINE"
)

type AthenaGetQueryExecution 

type AthenaGetQueryExecution interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Get an Athena Query Execution as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-athena.html

Experimental.

func NewAthenaGetQueryExecution 

func NewAthenaGetQueryExecution(scope constructs.Construct, id *string, props *AthenaGetQueryExecutionProps) AthenaGetQueryExecution

Experimental.

type AthenaGetQueryExecutionProps 

type AthenaGetQueryExecutionProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Query that will be retrieved.
	//
	// TODO: EXAMPLE
	//
	// Experimental.
	QueryExecutionId *string `json:"queryExecutionId"`
}

Properties for getting a Query Execution. Experimental.

type AthenaGetQueryResults 

type AthenaGetQueryResults interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Get an Athena Query Results as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-athena.html

Experimental.

func NewAthenaGetQueryResults 

func NewAthenaGetQueryResults(scope constructs.Construct, id *string, props *AthenaGetQueryResultsProps) AthenaGetQueryResults

Experimental.

type AthenaGetQueryResultsProps 

type AthenaGetQueryResultsProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Query that will be retrieved.
	//
	// TODO: EXAMPLE
	//
	// Experimental.
	QueryExecutionId *string `json:"queryExecutionId"`
	// Max number of results.
	// Experimental.
	MaxResults *float64 `json:"maxResults"`
	// Pagination token.
	// Experimental.
	NextToken *string `json:"nextToken"`
}

Properties for getting a Query Results. Experimental.

type AthenaStartQueryExecution 

type AthenaStartQueryExecution interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Start an Athena Query as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-athena.html

Experimental.

func NewAthenaStartQueryExecution 

func NewAthenaStartQueryExecution(scope constructs.Construct, id *string, props *AthenaStartQueryExecutionProps) AthenaStartQueryExecution

Experimental.

type AthenaStartQueryExecutionProps 

type AthenaStartQueryExecutionProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Query that will be started.
	// Experimental.
	QueryString *string `json:"queryString"`
	// Unique string string to ensure idempotence.
	// Experimental.
	ClientRequestToken *string `json:"clientRequestToken"`
	// Database within which query executes.
	// Experimental.
	QueryExecutionContext *QueryExecutionContext `json:"queryExecutionContext"`
	// Configuration on how and where to save query.
	// Experimental.
	ResultConfiguration *ResultConfiguration `json:"resultConfiguration"`
	// Configuration on how and where to save query.
	// Experimental.
	WorkGroup *string `json:"workGroup"`
}

Properties for starting a Query Execution. Experimental.

type AthenaStopQueryExecution 

type AthenaStopQueryExecution interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Stop an Athena Query Execution as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-athena.html

Experimental.

func NewAthenaStopQueryExecution 

func NewAthenaStopQueryExecution(scope constructs.Construct, id *string, props *AthenaStopQueryExecutionProps) AthenaStopQueryExecution

Experimental.

type AthenaStopQueryExecutionProps 

type AthenaStopQueryExecutionProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Query that will be stopped.
	// Experimental.
	QueryExecutionId *string `json:"queryExecutionId"`
}

Properties for stoping a Query Execution. Experimental.

type AuthType 

type AuthType string

The authentication method used to call the endpoint. Experimental. 

const (
	AuthType_NO_AUTH         AuthType = "NO_AUTH"
	AuthType_IAM_ROLE        AuthType = "IAM_ROLE"
	AuthType_RESOURCE_POLICY AuthType = "RESOURCE_POLICY"
)

type BatchContainerOverrides 

type BatchContainerOverrides struct {
	// The command to send to the container that overrides the default command from the Docker image or the job definition.
	// Experimental.
	Command *[]*string `json:"command"`
	// 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 job definition.
	// Experimental.
	Environment *map[string]*string `json:"environment"`
	// The number of physical GPUs to reserve for the container.
	//
	// The number of GPUs reserved for all containers in a job
	// should not exceed the number of available GPUs on the compute
	// resource that the job is launched on.
	// Experimental.
	GpuCount *float64 `json:"gpuCount"`
	// The instance type to use for a multi-node parallel job.
	//
	// This parameter is not valid for single-node container jobs.
	// Experimental.
	InstanceType awsec2.InstanceType `json:"instanceType"`
	// Memory reserved for the job.
	// Experimental.
	Memory awscdk.Size `json:"memory"`
	// The number of vCPUs to reserve for the container.
	//
	// This value overrides the value set in the job definition.
	// Experimental.
	Vcpus *float64 `json:"vcpus"`
}

The overrides that should be sent to a container. Experimental.

type BatchJobDependency 

type BatchJobDependency struct {
	// The job ID of the AWS Batch job associated with this dependency.
	// Experimental.
	JobId *string `json:"jobId"`
	// The type of the job dependency.
	// Experimental.
	Type *string `json:"type"`
}

An object representing an AWS Batch job dependency. Experimental.

type BatchStrategy 

type BatchStrategy string

Specifies the number of records to include in a mini-batch for an HTTP inference request. Experimental. 

const (
	BatchStrategy_MULTI_RECORD  BatchStrategy = "MULTI_RECORD"
	BatchStrategy_SINGLE_RECORD BatchStrategy = "SINGLE_RECORD"
)

type BatchSubmitJob 

type BatchSubmitJob interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Task to submits an AWS Batch job from a job definition. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-batch.html

Experimental.

func NewBatchSubmitJob 

func NewBatchSubmitJob(scope constructs.Construct, id *string, props *BatchSubmitJobProps) BatchSubmitJob

Experimental.

type BatchSubmitJobProps 

type BatchSubmitJobProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The arn of the job definition used by this job.
	// Experimental.
	JobDefinitionArn *string `json:"jobDefinitionArn"`
	// The name of the job.
	//
	// The first character must be alphanumeric, and up to 128 letters (uppercase and lowercase),
	// numbers, hyphens, and underscores are allowed.
	// Experimental.
	JobName *string `json:"jobName"`
	// The arn of the job queue into which the job is submitted.
	// Experimental.
	JobQueueArn *string `json:"jobQueueArn"`
	// The array size can be between 2 and 10,000.
	//
	// If you specify array properties for a job, it becomes an array job.
	// For more information, see Array Jobs in the AWS Batch User Guide.
	// Experimental.
	ArraySize *float64 `json:"arraySize"`
	// The number of times to move a job to the RUNNABLE status.
	//
	// You may specify between 1 and 10 attempts.
	// If the value of attempts is greater than one,
	// the job is retried on failure the same number of attempts as the value.
	// Experimental.
	Attempts *float64 `json:"attempts"`
	// A list of container overrides in JSON format that specify the name of a container in the specified job definition and the overrides it should receive.
	// See: https://docs.aws.amazon.com/batch/latest/APIReference/API_SubmitJob.html#Batch-SubmitJob-request-containerOverrides
	//
	// Experimental.
	ContainerOverrides *BatchContainerOverrides `json:"containerOverrides"`
	// A list of dependencies for the job.
	//
	// A job can depend upon a maximum of 20 jobs.
	// See: https://docs.aws.amazon.com/batch/latest/APIReference/API_SubmitJob.html#Batch-SubmitJob-request-dependsOn
	//
	// Experimental.
	DependsOn *[]*BatchJobDependency `json:"dependsOn"`
	// The payload to be passed as parameters to the batch job.
	// Experimental.
	Payload awsstepfunctions.TaskInput `json:"payload"`
}

Properties for RunBatchJob. Experimental.

type CallApiGatewayEndpointBaseProps 

type CallApiGatewayEndpointBaseProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Http method for the API.
	// Experimental.
	Method HttpMethod `json:"method"`
	// Path parameters appended after API endpoint.
	// Experimental.
	ApiPath *string `json:"apiPath"`
	// Authentication methods.
	// Experimental.
	AuthType AuthType `json:"authType"`
	// HTTP request information that does not relate to contents of the request.
	// Experimental.
	Headers awsstepfunctions.TaskInput `json:"headers"`
	// Query strings attatched to end of request.
	// Experimental.
	QueryParameters awsstepfunctions.TaskInput `json:"queryParameters"`
	// HTTP Request body.
	// Experimental.
	RequestBody awsstepfunctions.TaskInput `json:"requestBody"`
}

Base CallApiGatewayEdnpoint Task Props. Experimental.

type CallApiGatewayHttpApiEndpoint 

type CallApiGatewayHttpApiEndpoint interface {
	awsstepfunctions.TaskStateBase
	ApiEndpoint() *string
	ArnForExecuteApi() *string
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StageName() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	CreatePolicyStatements() *[]awsiam.PolicyStatement
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Call HTTP API endpoint as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-api-gateway.html

Experimental.

func NewCallApiGatewayHttpApiEndpoint 

func NewCallApiGatewayHttpApiEndpoint(scope constructs.Construct, id *string, props *CallApiGatewayHttpApiEndpointProps) CallApiGatewayHttpApiEndpoint

Experimental.

type CallApiGatewayHttpApiEndpointProps 

type CallApiGatewayHttpApiEndpointProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Http method for the API.
	// Experimental.
	Method HttpMethod `json:"method"`
	// Path parameters appended after API endpoint.
	// Experimental.
	ApiPath *string `json:"apiPath"`
	// Authentication methods.
	// Experimental.
	AuthType AuthType `json:"authType"`
	// HTTP request information that does not relate to contents of the request.
	// Experimental.
	Headers awsstepfunctions.TaskInput `json:"headers"`
	// Query strings attatched to end of request.
	// Experimental.
	QueryParameters awsstepfunctions.TaskInput `json:"queryParameters"`
	// HTTP Request body.
	// Experimental.
	RequestBody awsstepfunctions.TaskInput `json:"requestBody"`
	// The Id of the API to call.
	// Experimental.
	ApiId *string `json:"apiId"`
	// The Stack in which the API is defined.
	// Experimental.
	ApiStack awscdk.Stack `json:"apiStack"`
	// Name of the stage where the API is deployed to in API Gateway.
	// Experimental.
	StageName *string `json:"stageName"`
}

Properties for calling an HTTP API Endpoint. Experimental.

type CallApiGatewayRestApiEndpoint 

type CallApiGatewayRestApiEndpoint interface {
	awsstepfunctions.TaskStateBase
	ApiEndpoint() *string
	ArnForExecuteApi() *string
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StageName() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	CreatePolicyStatements() *[]awsiam.PolicyStatement
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Call REST API endpoint as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-api-gateway.html

Experimental.

func NewCallApiGatewayRestApiEndpoint 

func NewCallApiGatewayRestApiEndpoint(scope constructs.Construct, id *string, props *CallApiGatewayRestApiEndpointProps) CallApiGatewayRestApiEndpoint

Experimental.

type CallApiGatewayRestApiEndpointProps 

type CallApiGatewayRestApiEndpointProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Http method for the API.
	// Experimental.
	Method HttpMethod `json:"method"`
	// Path parameters appended after API endpoint.
	// Experimental.
	ApiPath *string `json:"apiPath"`
	// Authentication methods.
	// Experimental.
	AuthType AuthType `json:"authType"`
	// HTTP request information that does not relate to contents of the request.
	// Experimental.
	Headers awsstepfunctions.TaskInput `json:"headers"`
	// Query strings attatched to end of request.
	// Experimental.
	QueryParameters awsstepfunctions.TaskInput `json:"queryParameters"`
	// HTTP Request body.
	// Experimental.
	RequestBody awsstepfunctions.TaskInput `json:"requestBody"`
	// API to call.
	// Experimental.
	Api awsapigateway.IRestApi `json:"api"`
	// Name of the stage where the API is deployed to in API Gateway.
	// Experimental.
	StageName *string `json:"stageName"`
}

Properties for calling an REST API Endpoint. Experimental.

type Channel 

type Channel struct {
	// Name of the channel.
	// Experimental.
	ChannelName *string `json:"channelName"`
	// Location of the channel data.
	// Experimental.
	DataSource *DataSource `json:"dataSource"`
	// Compression type if training data is compressed.
	// Experimental.
	CompressionType CompressionType `json:"compressionType"`
	// The MIME type of the data.
	// Experimental.
	ContentType *string `json:"contentType"`
	// Input mode to use for the data channel in a training job.
	// Experimental.
	InputMode InputMode `json:"inputMode"`
	// Specify RecordIO as the value when input data is in raw format but the training algorithm requires the RecordIO format.
	//
	// In this case, Amazon SageMaker wraps each individual S3 object in a RecordIO record.
	// If the input data is already in RecordIO format, you don't need to set this attribute.
	// Experimental.
	RecordWrapperType RecordWrapperType `json:"recordWrapperType"`
	// Shuffle config option for input data in a channel.
	// Experimental.
	ShuffleConfig *ShuffleConfig `json:"shuffleConfig"`
}

Describes the training, validation or test dataset and the Amazon S3 location where it is stored. Experimental.

type CodeBuildStartBuild 

type CodeBuildStartBuild interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Start a CodeBuild Build as a task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-codebuild.html

Experimental.

func NewCodeBuildStartBuild 

func NewCodeBuildStartBuild(scope constructs.Construct, id *string, props *CodeBuildStartBuildProps) CodeBuildStartBuild

Experimental.

type CodeBuildStartBuildProps 

type CodeBuildStartBuildProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// CodeBuild project to start.
	// Experimental.
	Project awscodebuild.IProject `json:"project"`
	// A set of environment variables to be used for this build only.
	// Experimental.
	EnvironmentVariablesOverride *map[string]*awscodebuild.BuildEnvironmentVariable `json:"environmentVariablesOverride"`
}

Properties for CodeBuildStartBuild. Experimental.

type CommonEcsRunTaskProps 

type CommonEcsRunTaskProps struct {
	// The topic to run the task on.
	// Experimental.
	Cluster awsecs.ICluster `json:"cluster"`
	// Task Definition used for running tasks in the service.
	//
	// Note: this must be TaskDefinition, and not ITaskDefinition,
	// as it requires properties that are not known for imported task definitions
	// Experimental.
	TaskDefinition awsecs.TaskDefinition `json:"taskDefinition"`
	// Container setting overrides.
	//
	// Key is the name of the container to override, value is the
	// values you want to override.
	// Experimental.
	ContainerOverrides *[]*ContainerOverride `json:"containerOverrides"`
	// The service integration pattern indicates different ways to call RunTask in ECS.
	//
	// The valid value for Lambda is FIRE_AND_FORGET, SYNC and WAIT_FOR_TASK_TOKEN.
	// Experimental.
	IntegrationPattern awsstepfunctions.ServiceIntegrationPattern `json:"integrationPattern"`
}

Basic properties for ECS Tasks. Experimental.

type CompressionType 

type CompressionType string

Compression type of the data. Experimental. 

const (
	CompressionType_NONE CompressionType = "NONE"
	CompressionType_GZIP CompressionType = "GZIP"
)

type ContainerDefinition 

type ContainerDefinition interface {
	IContainerDefinition
	Bind(task ISageMakerTask) *ContainerDefinitionConfig
}

Describes the container, as part of model definition. See: https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_ContainerDefinition.html

Experimental.

func NewContainerDefinition 

func NewContainerDefinition(options *ContainerDefinitionOptions) ContainerDefinition

Experimental.

type ContainerDefinitionConfig 

type ContainerDefinitionConfig struct {
	// Additional parameters to pass to the base task.
	// Experimental.
	Parameters *map[string]interface{} `json:"parameters"`
}

Configuration options for the ContainerDefinition. Experimental.

type ContainerDefinitionOptions 

type ContainerDefinitionOptions struct {
	// This parameter is ignored for models that contain only a PrimaryContainer.
	//
	// When a ContainerDefinition is part of an inference pipeline,
	// the value of the parameter uniquely identifies the container for the purposes of logging and metrics.
	// Experimental.
	ContainerHostName *string `json:"containerHostName"`
	// The environment variables to set in the Docker container.
	// Experimental.
	EnvironmentVariables awsstepfunctions.TaskInput `json:"environmentVariables"`
	// The Amazon EC2 Container Registry (Amazon ECR) path where inference code is stored.
	// Experimental.
	Image DockerImage `json:"image"`
	// Defines how many models the container hosts.
	// Experimental.
	Mode Mode `json:"mode"`
	// The name or Amazon Resource Name (ARN) of the model package to use to create the model.
	// Experimental.
	ModelPackageName *string `json:"modelPackageName"`
	// The S3 path where the model artifacts, which result from model training, are stored.
	//
	// This path must point to a single gzip compressed tar archive (.tar.gz suffix).
	// The S3 path is required for Amazon SageMaker built-in algorithms, but not if you use your own algorithms.
	// Experimental.
	ModelS3Location S3Location `json:"modelS3Location"`
}

Properties to define a ContainerDefinition. See: https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_ContainerDefinition.html

Experimental.

type ContainerOverride 

type ContainerOverride struct {
	// Name of the container inside the task definition.
	// Experimental.
	ContainerDefinition awsecs.ContainerDefinition `json:"containerDefinition"`
	// Command to run inside the container.
	// Experimental.
	Command *[]*string `json:"command"`
	// The number of cpu units reserved for the container.
	// Experimental.
	Cpu *float64 `json:"cpu"`
	// 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.
	// Experimental.
	Environment *[]*TaskEnvironmentVariable `json:"environment"`
	// The hard limit (in MiB) of memory to present to the container.
	// Experimental.
	MemoryLimit *float64 `json:"memoryLimit"`
	// The soft limit (in MiB) of memory to reserve for the container.
	// Experimental.
	MemoryReservation *float64 `json:"memoryReservation"`
}

A list of container overrides that specify the name of a container and the overrides it should receive. Experimental.

type ContainerOverrides 

type ContainerOverrides struct {
	// The command to send to the container that overrides the default command from the Docker image or the job definition.
	// Experimental.
	Command *[]*string `json:"command"`
	// 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 job definition.
	// Experimental.
	Environment *map[string]*string `json:"environment"`
	// The number of physical GPUs to reserve for the container.
	//
	// The number of GPUs reserved for all containers in a job
	// should not exceed the number of available GPUs on the compute
	// resource that the job is launched on.
	// Experimental.
	GpuCount *float64 `json:"gpuCount"`
	// The instance type to use for a multi-node parallel job.
	//
	// This parameter is not valid for single-node container jobs.
	// Experimental.
	InstanceType awsec2.InstanceType `json:"instanceType"`
	// The number of MiB of memory reserved for the job.
	//
	// This value overrides the value set in the job definition.
	// Experimental.
	Memory *float64 `json:"memory"`
	// The number of vCPUs to reserve for the container.
	//
	// This value overrides the value set in the job definition.
	// Experimental.
	Vcpus *float64 `json:"vcpus"`
}

The overrides that should be sent to a container. Experimental.

type DataSource 

type DataSource struct {
	// S3 location of the data source that is associated with a channel.
	// Experimental.
	S3DataSource *S3DataSource `json:"s3DataSource"`
}

Location of the channel data. Experimental.

type DockerImage 

type DockerImage interface {
	Bind(task ISageMakerTask) *DockerImageConfig
}

Creates `IDockerImage` instances. Experimental.

func DockerImage_FromAsset 

func DockerImage_FromAsset(scope constructs.Construct, id *string, props *awsecrassets.DockerImageAssetProps) DockerImage

Reference a Docker image that is provided as an Asset in the current app. Experimental.

func DockerImage_FromEcrRepository 

func DockerImage_FromEcrRepository(repository awsecr.IRepository, tag *string) DockerImage

Reference a Docker image stored in an ECR repository. Experimental.

func DockerImage_FromJsonExpression 

func DockerImage_FromJsonExpression(expression *string, allowAnyEcrImagePull *bool) DockerImage

Reference a Docker image which URI is obtained from the task's input. Experimental.

func DockerImage_FromRegistry 

func DockerImage_FromRegistry(imageUri *string) DockerImage

Reference a Docker image by it's URI.

When referencing ECR images, prefer using `inEcr`. Experimental.

type DockerImageConfig 

type DockerImageConfig struct {
	// The fully qualified URI of the Docker image.
	// Experimental.
	ImageUri *string `json:"imageUri"`
}

Configuration for a using Docker image. Experimental.

type DynamoAttributeValue 

type DynamoAttributeValue interface {
	AttributeValue() interface{}
	ToObject() interface{}
}

Represents the data for an attribute.

Each attribute value is described as a name-value pair. The name is the data type, and the value is the data itself. See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_AttributeValue.html

Experimental.

func DynamoAttributeValue_BooleanFromJsonPath 

func DynamoAttributeValue_BooleanFromJsonPath(value *string) DynamoAttributeValue

Sets an attribute of type Boolean from state input through Json path.

For example: "BOOL": true Experimental.

func DynamoAttributeValue_FromBinary 

func DynamoAttributeValue_FromBinary(value *string) DynamoAttributeValue

Sets an attribute of type Binary.

For example: "B": "dGhpcyB0ZXh0IGlzIGJhc2U2NC1lbmNvZGVk" Experimental.

func DynamoAttributeValue_FromBinarySet 

func DynamoAttributeValue_FromBinarySet(value *[]*string) DynamoAttributeValue

Sets an attribute of type Binary Set.

For example: "BS": ["U3Vubnk=", "UmFpbnk=", "U25vd3k="] Experimental.

func DynamoAttributeValue_FromBoolean 

func DynamoAttributeValue_FromBoolean(value *bool) DynamoAttributeValue

Sets an attribute of type Boolean.

For example: "BOOL": true Experimental.

func DynamoAttributeValue_FromList 

func DynamoAttributeValue_FromList(value *[]DynamoAttributeValue) DynamoAttributeValue

Sets an attribute of type List.

For example: "L": [ {"S": "Cookies"} , {"S": "Coffee"}, {"N", "3.14159"}] Experimental.

func DynamoAttributeValue_FromMap 

func DynamoAttributeValue_FromMap(value *map[string]DynamoAttributeValue) DynamoAttributeValue

Sets an attribute of type Map.

For example: "M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}} Experimental.

func DynamoAttributeValue_FromNull 

func DynamoAttributeValue_FromNull(value *bool) DynamoAttributeValue

Sets an attribute of type Null.

For example: "NULL": true Experimental.

func DynamoAttributeValue_FromNumber 

func DynamoAttributeValue_FromNumber(value *float64) DynamoAttributeValue

Sets a literal number.

For example: 1234 Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and libraries. However, DynamoDB treats them as number type attributes for mathematical operations. Experimental.

func DynamoAttributeValue_FromNumberSet 

func DynamoAttributeValue_FromNumberSet(value *[]*float64) DynamoAttributeValue

Sets an attribute of type Number Set.

For example: "NS": ["42.2", "-19", "7.5", "3.14"] Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and libraries. However, DynamoDB treats them as number type attributes for mathematical operations. Experimental.

func DynamoAttributeValue_FromString 

func DynamoAttributeValue_FromString(value *string) DynamoAttributeValue

Sets an attribute of type String.

For example: "S": "Hello" Strings may be literal values or as JsonPath.

TODO: EXAMPLE

Experimental.

func DynamoAttributeValue_FromStringSet 

func DynamoAttributeValue_FromStringSet(value *[]*string) DynamoAttributeValue

Sets an attribute of type String Set.

For example: "SS": ["Giraffe", "Hippo" ,"Zebra"] Experimental.

func DynamoAttributeValue_MapFromJsonPath 

func DynamoAttributeValue_MapFromJsonPath(value *string) DynamoAttributeValue

Sets an attribute of type Map.

For example: "M": {"Name": {"S": "Joe"}, "Age": {"N": "35"}} Experimental.

func DynamoAttributeValue_NumberFromString 

func DynamoAttributeValue_NumberFromString(value *string) DynamoAttributeValue

Sets an attribute of type Number.

For example: "N": "123.45" Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and libraries. However, DynamoDB treats them as number type attributes for mathematical operations.

Numbers may be expressed as literal strings or as JsonPath Experimental.

func DynamoAttributeValue_NumberSetFromStrings 

func DynamoAttributeValue_NumberSetFromStrings(value *[]*string) DynamoAttributeValue

Sets an attribute of type Number Set.

For example: "NS": ["42.2", "-19", "7.5", "3.14"] Numbers are sent across the network to DynamoDB as strings, to maximize compatibility across languages and libraries. However, DynamoDB treats them as number type attributes for mathematical operations.

Numbers may be expressed as literal strings or as JsonPath Experimental.

type DynamoConsumedCapacity 

type DynamoConsumedCapacity string

Determines the level of detail about provisioned throughput consumption that is returned. Experimental. 

const (
	DynamoConsumedCapacity_INDEXES DynamoConsumedCapacity = "INDEXES"
	DynamoConsumedCapacity_TOTAL   DynamoConsumedCapacity = "TOTAL"
	DynamoConsumedCapacity_NONE    DynamoConsumedCapacity = "NONE"
)

type DynamoDeleteItem 

type DynamoDeleteItem interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A StepFunctions task to call DynamoDeleteItem. Experimental.

func NewDynamoDeleteItem 

func NewDynamoDeleteItem(scope constructs.Construct, id *string, props *DynamoDeleteItemProps) DynamoDeleteItem

Experimental.

type DynamoDeleteItemProps 

type DynamoDeleteItemProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Primary key of the item to retrieve.
	//
	// For the primary key, you must provide all of the attributes.
	// For example, with a simple primary key, you only need to provide a value for the partition key.
	// For a composite primary key, you must provide values for both the partition key and the sort key.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html#DDB-GetItem-request-Key
	//
	// Experimental.
	Key *map[string]DynamoAttributeValue `json:"key"`
	// The name of the table containing the requested item.
	// Experimental.
	Table awsdynamodb.ITable `json:"table"`
	// A condition that must be satisfied in order for a conditional DeleteItem to succeed.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html#DDB-DeleteItem-request-ConditionExpression
	//
	// Experimental.
	ConditionExpression *string `json:"conditionExpression"`
	// One or more substitution tokens for attribute names in an expression.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html#DDB-DeleteItem-request-ExpressionAttributeNames
	//
	// Experimental.
	ExpressionAttributeNames *map[string]*string `json:"expressionAttributeNames"`
	// One or more values that can be substituted in an expression.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html#DDB-DeleteItem-request-ExpressionAttributeValues
	//
	// Experimental.
	ExpressionAttributeValues *map[string]DynamoAttributeValue `json:"expressionAttributeValues"`
	// Determines the level of detail about provisioned throughput consumption that is returned in the response.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html#DDB-DeleteItem-request-ReturnConsumedCapacity
	//
	// Experimental.
	ReturnConsumedCapacity DynamoConsumedCapacity `json:"returnConsumedCapacity"`
	// Determines whether item collection metrics are returned.
	//
	// If set to SIZE, the response includes statistics about item collections, if any,
	// that were modified during the operation are returned in the response.
	// If set to NONE (the default), no statistics are returned.
	// Experimental.
	ReturnItemCollectionMetrics DynamoItemCollectionMetrics `json:"returnItemCollectionMetrics"`
	// Use ReturnValues if you want to get the item attributes as they appeared before they were deleted.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html#DDB-DeleteItem-request-ReturnValues
	//
	// Experimental.
	ReturnValues DynamoReturnValues `json:"returnValues"`
}

Properties for DynamoDeleteItem Task. Experimental.

type DynamoGetItem 

type DynamoGetItem interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A StepFunctions task to call DynamoGetItem. Experimental.

func NewDynamoGetItem 

func NewDynamoGetItem(scope constructs.Construct, id *string, props *DynamoGetItemProps) DynamoGetItem

Experimental.

type DynamoGetItemProps 

type DynamoGetItemProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Primary key of the item to retrieve.
	//
	// For the primary key, you must provide all of the attributes.
	// For example, with a simple primary key, you only need to provide a value for the partition key.
	// For a composite primary key, you must provide values for both the partition key and the sort key.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html#DDB-GetItem-request-Key
	//
	// Experimental.
	Key *map[string]DynamoAttributeValue `json:"key"`
	// The name of the table containing the requested item.
	// Experimental.
	Table awsdynamodb.ITable `json:"table"`
	// Determines the read consistency model: If set to true, then the operation uses strongly consistent reads;
	//
	// otherwise, the operation uses eventually consistent reads.
	// Experimental.
	ConsistentRead *bool `json:"consistentRead"`
	// One or more substitution tokens for attribute names in an expression.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html#DDB-GetItem-request-ExpressionAttributeNames
	//
	// Experimental.
	ExpressionAttributeNames *map[string]*string `json:"expressionAttributeNames"`
	// An array of DynamoProjectionExpression that identifies one or more attributes to retrieve from the table.
	//
	// These attributes can include scalars, sets, or elements of a JSON document.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html#DDB-GetItem-request-ProjectionExpression
	//
	// Experimental.
	ProjectionExpression *[]DynamoProjectionExpression `json:"projectionExpression"`
	// Determines the level of detail about provisioned throughput consumption that is returned in the response.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html#DDB-GetItem-request-ReturnConsumedCapacity
	//
	// Experimental.
	ReturnConsumedCapacity DynamoConsumedCapacity `json:"returnConsumedCapacity"`
}

Properties for DynamoGetItem Task. Experimental.

type DynamoItemCollectionMetrics 

type DynamoItemCollectionMetrics string

Determines whether item collection metrics are returned. Experimental. 

const (
	DynamoItemCollectionMetrics_SIZE DynamoItemCollectionMetrics = "SIZE"
	DynamoItemCollectionMetrics_NONE DynamoItemCollectionMetrics = "NONE"
)

type DynamoProjectionExpression 

type DynamoProjectionExpression interface {
	AtIndex(index *float64) DynamoProjectionExpression
	ToString() *string
	WithAttribute(attr *string) DynamoProjectionExpression
}

Class to generate projection expression. Experimental.

func NewDynamoProjectionExpression 

func NewDynamoProjectionExpression() DynamoProjectionExpression

Experimental.

type DynamoPutItem 

type DynamoPutItem interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A StepFunctions task to call DynamoPutItem. Experimental.

func NewDynamoPutItem 

func NewDynamoPutItem(scope constructs.Construct, id *string, props *DynamoPutItemProps) DynamoPutItem

Experimental.

type DynamoPutItemProps 

type DynamoPutItemProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// A map of attribute name/value pairs, one for each attribute.
	//
	// Only the primary key attributes are required;
	// you can optionally provide other attribute name-value pairs for the item.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html#DDB-PutItem-request-Item
	//
	// Experimental.
	Item *map[string]DynamoAttributeValue `json:"item"`
	// The name of the table where the item should be written .
	// Experimental.
	Table awsdynamodb.ITable `json:"table"`
	// A condition that must be satisfied in order for a conditional PutItem operation to succeed.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html#DDB-PutItem-request-ConditionExpression
	//
	// Experimental.
	ConditionExpression *string `json:"conditionExpression"`
	// One or more substitution tokens for attribute names in an expression.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html#DDB-PutItem-request-ExpressionAttributeNames
	//
	// Experimental.
	ExpressionAttributeNames *map[string]*string `json:"expressionAttributeNames"`
	// One or more values that can be substituted in an expression.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html#DDB-PutItem-request-ExpressionAttributeValues
	//
	// Experimental.
	ExpressionAttributeValues *map[string]DynamoAttributeValue `json:"expressionAttributeValues"`
	// Determines the level of detail about provisioned throughput consumption that is returned in the response.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html#DDB-PutItem-request-ReturnConsumedCapacity
	//
	// Experimental.
	ReturnConsumedCapacity DynamoConsumedCapacity `json:"returnConsumedCapacity"`
	// The item collection metrics to returned in the response.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/LSI.html#LSI.ItemCollections
	//
	// Experimental.
	ReturnItemCollectionMetrics DynamoItemCollectionMetrics `json:"returnItemCollectionMetrics"`
	// Use ReturnValues if you want to get the item attributes as they appeared before they were updated with the PutItem request.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html#DDB-PutItem-request-ReturnValues
	//
	// Experimental.
	ReturnValues DynamoReturnValues `json:"returnValues"`
}

Properties for DynamoPutItem Task. Experimental.

type DynamoReturnValues 

type DynamoReturnValues string

Use ReturnValues if you want to get the item attributes as they appear before or after they are changed. Experimental. 

const (
	DynamoReturnValues_NONE        DynamoReturnValues = "NONE"
	DynamoReturnValues_ALL_OLD     DynamoReturnValues = "ALL_OLD"
	DynamoReturnValues_UPDATED_OLD DynamoReturnValues = "UPDATED_OLD"
	DynamoReturnValues_ALL_NEW     DynamoReturnValues = "ALL_NEW"
	DynamoReturnValues_UPDATED_NEW DynamoReturnValues = "UPDATED_NEW"
)

type DynamoUpdateItem 

type DynamoUpdateItem interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A StepFunctions task to call DynamoUpdateItem. Experimental.

func NewDynamoUpdateItem 

func NewDynamoUpdateItem(scope constructs.Construct, id *string, props *DynamoUpdateItemProps) DynamoUpdateItem

Experimental.

type DynamoUpdateItemProps 

type DynamoUpdateItemProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Primary key of the item to retrieve.
	//
	// For the primary key, you must provide all of the attributes.
	// For example, with a simple primary key, you only need to provide a value for the partition key.
	// For a composite primary key, you must provide values for both the partition key and the sort key.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html#DDB-GetItem-request-Key
	//
	// Experimental.
	Key *map[string]DynamoAttributeValue `json:"key"`
	// The name of the table containing the requested item.
	// Experimental.
	Table awsdynamodb.ITable `json:"table"`
	// A condition that must be satisfied in order for a conditional DeleteItem to succeed.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html#DDB-UpdateItem-request-ConditionExpression
	//
	// Experimental.
	ConditionExpression *string `json:"conditionExpression"`
	// One or more substitution tokens for attribute names in an expression.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html#DDB-UpdateItem-request-ExpressionAttributeNames
	//
	// Experimental.
	ExpressionAttributeNames *map[string]*string `json:"expressionAttributeNames"`
	// One or more values that can be substituted in an expression.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html#DDB-UpdateItem-request-ExpressionAttributeValues
	//
	// Experimental.
	ExpressionAttributeValues *map[string]DynamoAttributeValue `json:"expressionAttributeValues"`
	// Determines the level of detail about provisioned throughput consumption that is returned in the response.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html#DDB-UpdateItem-request-ReturnConsumedCapacity
	//
	// Experimental.
	ReturnConsumedCapacity DynamoConsumedCapacity `json:"returnConsumedCapacity"`
	// Determines whether item collection metrics are returned.
	//
	// If set to SIZE, the response includes statistics about item collections, if any,
	// that were modified during the operation are returned in the response.
	// If set to NONE (the default), no statistics are returned.
	// Experimental.
	ReturnItemCollectionMetrics DynamoItemCollectionMetrics `json:"returnItemCollectionMetrics"`
	// Use ReturnValues if you want to get the item attributes as they appeared before they were deleted.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html#DDB-UpdateItem-request-ReturnValues
	//
	// Experimental.
	ReturnValues DynamoReturnValues `json:"returnValues"`
	// An expression that defines one or more attributes to be updated, the action to be performed on them, and new values for them.
	// See: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html#DDB-UpdateItem-request-UpdateExpression
	//
	// Experimental.
	UpdateExpression *string `json:"updateExpression"`
}

Properties for DynamoUpdateItem Task. Experimental.

type EcsEc2LaunchTarget 

type EcsEc2LaunchTarget interface {
	IEcsLaunchTarget
	Bind(_task EcsRunTask, launchTargetOptions *LaunchTargetBindOptions) *EcsLaunchTargetConfig
}

Configuration for running an ECS task on EC2. See: https://docs.aws.amazon.com/AmazonECS/latest/userguide/launch_types.html#launch-type-ec2

Experimental.

func NewEcsEc2LaunchTarget 

func NewEcsEc2LaunchTarget(options *EcsEc2LaunchTargetOptions) EcsEc2LaunchTarget

Experimental.

type EcsEc2LaunchTargetOptions 

type EcsEc2LaunchTargetOptions struct {
	// Placement constraints.
	// Experimental.
	PlacementConstraints *[]awsecs.PlacementConstraint `json:"placementConstraints"`
	// Placement strategies.
	// Experimental.
	PlacementStrategies *[]awsecs.PlacementStrategy `json:"placementStrategies"`
}

Options to run an ECS task on EC2 in StepFunctions and ECS. Experimental.

type EcsFargateLaunchTarget 

type EcsFargateLaunchTarget interface {
	IEcsLaunchTarget
	Bind(_task EcsRunTask, launchTargetOptions *LaunchTargetBindOptions) *EcsLaunchTargetConfig
}

Configuration for running an ECS task on Fargate. See: https://docs.aws.amazon.com/AmazonECS/latest/userguide/launch_types.html#launch-type-fargate

Experimental.

func NewEcsFargateLaunchTarget 

func NewEcsFargateLaunchTarget(options *EcsFargateLaunchTargetOptions) EcsFargateLaunchTarget

Experimental.

type EcsFargateLaunchTargetOptions 

type EcsFargateLaunchTargetOptions struct {
	// Refers to a specific runtime environment for Fargate task infrastructure.
	//
	// Fargate platform version is a combination of the kernel and container runtime versions.
	// See: https://docs.aws.amazon.com/AmazonECS/latest/developerguide/platform_versions.html
	//
	// Experimental.
	PlatformVersion awsecs.FargatePlatformVersion `json:"platformVersion"`
}

Properties to define an ECS service. Experimental.

type EcsLaunchTargetConfig 

type EcsLaunchTargetConfig struct {
	// Additional parameters to pass to the base task.
	// Experimental.
	Parameters *map[string]interface{} `json:"parameters"`
}

Configuration options for the ECS launch type. Experimental.

type EcsRunTask 

type EcsRunTask interface {
	awsstepfunctions.TaskStateBase
	awsec2.IConnectable
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	Connections() awsec2.Connections
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Run a Task on ECS or Fargate. Experimental.

func NewEcsRunTask 

func NewEcsRunTask(scope constructs.Construct, id *string, props *EcsRunTaskProps) EcsRunTask

Experimental.

type EcsRunTaskProps 

type EcsRunTaskProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The ECS cluster to run the task on.
	// Experimental.
	Cluster awsecs.ICluster `json:"cluster"`
	// An Amazon ECS launch type determines the type of infrastructure on which your tasks and services are hosted.
	// See: https://docs.aws.amazon.com/AmazonECS/latest/developerguide/launch_types.html
	//
	// Experimental.
	LaunchTarget IEcsLaunchTarget `json:"launchTarget"`
	// [disable-awslint:ref-via-interface] Task Definition used for running tasks in the service.
	//
	// Note: this must be TaskDefinition, and not ITaskDefinition,
	// as it requires properties that are not known for imported task definitions
	// Experimental.
	TaskDefinition awsecs.TaskDefinition `json:"taskDefinition"`
	// Assign public IP addresses to each task.
	// Experimental.
	AssignPublicIp *bool `json:"assignPublicIp"`
	// Container setting overrides.
	//
	// Specify the container to use and the overrides to apply.
	// Experimental.
	ContainerOverrides *[]*ContainerOverride `json:"containerOverrides"`
	// Existing security groups to use for the tasks.
	// Experimental.
	SecurityGroups *[]awsec2.ISecurityGroup `json:"securityGroups"`
	// Subnets to place the task's ENIs.
	// Experimental.
	Subnets *awsec2.SubnetSelection `json:"subnets"`
}

Properties for ECS Tasks. Experimental.

type EksCall 

type EksCall interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Call a EKS endpoint as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-eks.html

Experimental.

func NewEksCall 

func NewEksCall(scope constructs.Construct, id *string, props *EksCallProps) EksCall

Experimental.

type EksCallProps 

type EksCallProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The EKS cluster.
	// Experimental.
	Cluster awseks.ICluster `json:"cluster"`
	// HTTP method ("GET", "POST", "PUT", ...) part of HTTP request.
	// Experimental.
	HttpMethod HttpMethods `json:"httpMethod"`
	// HTTP path of the Kubernetes REST API operation For example: /api/v1/namespaces/default/pods.
	// Experimental.
	HttpPath *string `json:"httpPath"`
	// Query Parameters part of HTTP request.
	// Experimental.
	QueryParameters *map[string]*[]*string `json:"queryParameters"`
	// Request body part of HTTP request.
	// Experimental.
	RequestBody awsstepfunctions.TaskInput `json:"requestBody"`
}

Properties for calling a EKS endpoint with EksCall. Experimental.

type EmrAddStep 

type EmrAddStep interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to add a Step to an EMR Cluster.

The StepConfiguration is defined as Parameters in the state machine definition.

OUTPUT: the StepId Experimental.

func NewEmrAddStep 

func NewEmrAddStep(scope constructs.Construct, id *string, props *EmrAddStepProps) EmrAddStep

Experimental.

type EmrAddStepProps 

type EmrAddStepProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The ClusterId to add the Step to.
	// Experimental.
	ClusterId *string `json:"clusterId"`
	// A path to a JAR file run during the step.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_HadoopJarStepConfig.html
	//
	// Experimental.
	Jar *string `json:"jar"`
	// The name of the Step.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_StepConfig.html
	//
	// Experimental.
	Name *string `json:"name"`
	// The action to take when the cluster step fails.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_StepConfig.html
	//
	// Experimental.
	ActionOnFailure ActionOnFailure `json:"actionOnFailure"`
	// A list of command line arguments passed to the JAR file's main function when executed.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_HadoopJarStepConfig.html
	//
	// Experimental.
	Args *[]*string `json:"args"`
	// The name of the main class in the specified Java file.
	//
	// If not specified, the JAR file should specify a Main-Class in its manifest file.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_HadoopJarStepConfig.html
	//
	// Experimental.
	MainClass *string `json:"mainClass"`
	// A list of Java properties that are set when the step runs.
	//
	// You can use these properties to pass key value pairs to your main function.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_HadoopJarStepConfig.html
	//
	// Experimental.
	Properties *map[string]*string `json:"properties"`
}

Properties for EmrAddStep. Experimental.

type EmrCancelStep 

type EmrCancelStep interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to to cancel a Step on an EMR Cluster. Experimental.

func NewEmrCancelStep 

func NewEmrCancelStep(scope constructs.Construct, id *string, props *EmrCancelStepProps) EmrCancelStep

Experimental.

type EmrCancelStepProps 

type EmrCancelStepProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The ClusterId to update.
	// Experimental.
	ClusterId *string `json:"clusterId"`
	// The StepId to cancel.
	// Experimental.
	StepId *string `json:"stepId"`
}

Properties for EmrCancelStep. Experimental.

type EmrCreateCluster 

type EmrCreateCluster interface {
	awsstepfunctions.TaskStateBase
	AutoScalingRole() awsiam.IRole
	Branches() *[]awsstepfunctions.StateGraph
	ClusterRole() awsiam.IRole
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ServiceRole() awsiam.IRole
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to create an EMR Cluster.

The ClusterConfiguration is defined as Parameters in the state machine definition.

OUTPUT: the ClusterId. Experimental.

func NewEmrCreateCluster 

func NewEmrCreateCluster(scope constructs.Construct, id *string, props *EmrCreateClusterProps) EmrCreateCluster

Experimental.

type EmrCreateClusterProps 

type EmrCreateClusterProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// A specification of the number and type of Amazon EC2 instances.
	// Experimental.
	Instances *EmrCreateCluster_InstancesConfigProperty `json:"instances"`
	// The Name of the Cluster.
	// Experimental.
	Name *string `json:"name"`
	// A JSON string for selecting additional features.
	// Experimental.
	AdditionalInfo *string `json:"additionalInfo"`
	// A case-insensitive list of applications for Amazon EMR to install and configure when launching the cluster.
	// Experimental.
	Applications *[]*EmrCreateCluster_ApplicationConfigProperty `json:"applications"`
	// An IAM role for automatic scaling policies.
	// Experimental.
	AutoScalingRole awsiam.IRole `json:"autoScalingRole"`
	// A list of bootstrap actions to run before Hadoop starts on the cluster nodes.
	// Experimental.
	BootstrapActions *[]*EmrCreateCluster_BootstrapActionConfigProperty `json:"bootstrapActions"`
	// Also called instance profile and EC2 role.
	//
	// An IAM role for an EMR cluster. The EC2 instances of the cluster assume this role.
	//
	// This attribute has been renamed from jobFlowRole to clusterRole to align with other ERM/StepFunction integration parameters.
	// Experimental.
	ClusterRole awsiam.IRole `json:"clusterRole"`
	// The list of configurations supplied for the EMR cluster you are creating.
	// Experimental.
	Configurations *[]*EmrCreateCluster_ConfigurationProperty `json:"configurations"`
	// The ID of a custom Amazon EBS-backed Linux AMI.
	// Experimental.
	CustomAmiId *string `json:"customAmiId"`
	// The size of the EBS root device volume of the Linux AMI that is used for each EC2 instance.
	// Experimental.
	EbsRootVolumeSize awscdk.Size `json:"ebsRootVolumeSize"`
	// Attributes for Kerberos configuration when Kerberos authentication is enabled using a security configuration.
	// Experimental.
	KerberosAttributes *EmrCreateCluster_KerberosAttributesProperty `json:"kerberosAttributes"`
	// The location in Amazon S3 to write the log files of the job flow.
	// Experimental.
	LogUri *string `json:"logUri"`
	// The Amazon EMR release label, which determines the version of open-source application packages installed on the cluster.
	// Experimental.
	ReleaseLabel *string `json:"releaseLabel"`
	// Specifies the way that individual Amazon EC2 instances terminate when an automatic scale-in activity occurs or an instance group is resized.
	// Experimental.
	ScaleDownBehavior EmrCreateCluster_EmrClusterScaleDownBehavior `json:"scaleDownBehavior"`
	// The name of a security configuration to apply to the cluster.
	// Experimental.
	SecurityConfiguration *string `json:"securityConfiguration"`
	// The IAM role that will be assumed by the Amazon EMR service to access AWS resources on your behalf.
	// Experimental.
	ServiceRole awsiam.IRole `json:"serviceRole"`
	// A list of tags to associate with a cluster and propagate to Amazon EC2 instances.
	// Experimental.
	Tags *map[string]*string `json:"tags"`
	// A value of true indicates that all IAM users in the AWS account can perform cluster actions if they have the proper IAM policy permissions.
	// Experimental.
	VisibleToAllUsers *bool `json:"visibleToAllUsers"`
}

Properties for EmrCreateCluster.

See the RunJobFlow API for complete documentation on input parameters See: https://docs.aws.amazon.com/emr/latest/APIReference/API_RunJobFlow.html

Experimental.

type EmrCreateCluster_ApplicationConfigProperty 

type EmrCreateCluster_ApplicationConfigProperty struct {
	// The name of the application.
	// Experimental.
	Name *string `json:"name"`
	// This option is for advanced users only.
	//
	// This is meta information about third-party applications that third-party vendors use
	// for testing purposes.
	// Experimental.
	AdditionalInfo *map[string]*string `json:"additionalInfo"`
	// Arguments for Amazon EMR to pass to the application.
	// Experimental.
	Args *[]*string `json:"args"`
	// The version of the application.
	// Experimental.
	Version *string `json:"version"`
}

Properties for the EMR Cluster Applications.

Applies to Amazon EMR releases 4.0 and later. A case-insensitive list of applications for Amazon EMR to install and configure when launching the cluster.

See the RunJobFlow API for complete documentation on input parameters See: https://docs.aws.amazon.com/emr/latest/APIReference/API_Application.html

Experimental.

type EmrCreateCluster_AutoScalingPolicyProperty 

type EmrCreateCluster_AutoScalingPolicyProperty struct {
	// The upper and lower EC2 instance limits for an automatic scaling policy.
	//
	// Automatic scaling activity will not cause an instance
	// group to grow above or below these limits.
	// Experimental.
	Constraints *EmrCreateCluster_ScalingConstraintsProperty `json:"constraints"`
	// The scale-in and scale-out rules that comprise the automatic scaling policy.
	// Experimental.
	Rules *[]*EmrCreateCluster_ScalingRuleProperty `json:"rules"`
}

An automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_AutoScalingPolicy.html

Experimental.

type EmrCreateCluster_BootstrapActionConfigProperty 

type EmrCreateCluster_BootstrapActionConfigProperty struct {
	// The name of the bootstrap action.
	// Experimental.
	Name *string `json:"name"`
	// The script run by the bootstrap action.
	// Experimental.
	ScriptBootstrapAction *EmrCreateCluster_ScriptBootstrapActionConfigProperty `json:"scriptBootstrapAction"`
}

Configuration of a bootstrap action.

See the RunJobFlow API for complete documentation on input parameters See: https://docs.aws.amazon.com/emr/latest/APIReference/API_BootstrapActionConfig.html

Experimental.

type EmrCreateCluster_CloudWatchAlarmComparisonOperator 

type EmrCreateCluster_CloudWatchAlarmComparisonOperator string

CloudWatch Alarm Comparison Operators. Experimental. 

const (
	EmrCreateCluster_CloudWatchAlarmComparisonOperator_GREATER_THAN_OR_EQUAL EmrCreateCluster_CloudWatchAlarmComparisonOperator = "GREATER_THAN_OR_EQUAL"
	EmrCreateCluster_CloudWatchAlarmComparisonOperator_GREATER_THAN          EmrCreateCluster_CloudWatchAlarmComparisonOperator = "GREATER_THAN"
	EmrCreateCluster_CloudWatchAlarmComparisonOperator_LESS_THAN             EmrCreateCluster_CloudWatchAlarmComparisonOperator = "LESS_THAN"
	EmrCreateCluster_CloudWatchAlarmComparisonOperator_LESS_THAN_OR_EQUAL    EmrCreateCluster_CloudWatchAlarmComparisonOperator = "LESS_THAN_OR_EQUAL"
)

type EmrCreateCluster_CloudWatchAlarmDefinitionProperty 

type EmrCreateCluster_CloudWatchAlarmDefinitionProperty struct {
	// Determines how the metric specified by MetricName is compared to the value specified by Threshold.
	// Experimental.
	ComparisonOperator EmrCreateCluster_CloudWatchAlarmComparisonOperator `json:"comparisonOperator"`
	// The name of the CloudWatch metric that is watched to determine an alarm condition.
	// Experimental.
	MetricName *string `json:"metricName"`
	// The period, in seconds, over which the statistic is applied.
	//
	// EMR CloudWatch metrics are emitted every five minutes (300 seconds), so if
	// an EMR CloudWatch metric is specified, specify 300.
	// Experimental.
	Period awscdk.Duration `json:"period"`
	// A CloudWatch metric dimension.
	// Experimental.
	Dimensions *[]*EmrCreateCluster_MetricDimensionProperty `json:"dimensions"`
	// The number of periods, in five-minute increments, during which the alarm condition must exist before the alarm triggers automatic scaling activity.
	// Experimental.
	EvaluationPeriods *float64 `json:"evaluationPeriods"`
	// The namespace for the CloudWatch metric.
	// Experimental.
	Namespace *string `json:"namespace"`
	// The statistic to apply to the metric associated with the alarm.
	// Experimental.
	Statistic EmrCreateCluster_CloudWatchAlarmStatistic `json:"statistic"`
	// The value against which the specified statistic is compared.
	// Experimental.
	Threshold *float64 `json:"threshold"`
	// The unit of measure associated with the CloudWatch metric being watched.
	//
	// The value specified for Unit must correspond to the units
	// specified in the CloudWatch metric.
	// Experimental.
	Unit EmrCreateCluster_CloudWatchAlarmUnit `json:"unit"`
}

The definition of a CloudWatch metric alarm, which determines when an automatic scaling activity is triggered.

When the defined alarm conditions are satisfied, scaling activity begins. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_CloudWatchAlarmDefinition.html

Experimental.

type EmrCreateCluster_CloudWatchAlarmStatistic 

type EmrCreateCluster_CloudWatchAlarmStatistic string

CloudWatch Alarm Statistics. Experimental. 

const (
	EmrCreateCluster_CloudWatchAlarmStatistic_SAMPLE_COUNT EmrCreateCluster_CloudWatchAlarmStatistic = "SAMPLE_COUNT"
	EmrCreateCluster_CloudWatchAlarmStatistic_AVERAGE      EmrCreateCluster_CloudWatchAlarmStatistic = "AVERAGE"
	EmrCreateCluster_CloudWatchAlarmStatistic_SUM          EmrCreateCluster_CloudWatchAlarmStatistic = "SUM"
	EmrCreateCluster_CloudWatchAlarmStatistic_MINIMUM      EmrCreateCluster_CloudWatchAlarmStatistic = "MINIMUM"
	EmrCreateCluster_CloudWatchAlarmStatistic_MAXIMUM      EmrCreateCluster_CloudWatchAlarmStatistic = "MAXIMUM"
)

type EmrCreateCluster_CloudWatchAlarmUnit 

type EmrCreateCluster_CloudWatchAlarmUnit string

CloudWatch Alarm Units. Experimental. 

const (
	EmrCreateCluster_CloudWatchAlarmUnit_NONE                  EmrCreateCluster_CloudWatchAlarmUnit = "NONE"
	EmrCreateCluster_CloudWatchAlarmUnit_SECONDS               EmrCreateCluster_CloudWatchAlarmUnit = "SECONDS"
	EmrCreateCluster_CloudWatchAlarmUnit_MICRO_SECONDS         EmrCreateCluster_CloudWatchAlarmUnit = "MICRO_SECONDS"
	EmrCreateCluster_CloudWatchAlarmUnit_MILLI_SECONDS         EmrCreateCluster_CloudWatchAlarmUnit = "MILLI_SECONDS"
	EmrCreateCluster_CloudWatchAlarmUnit_BYTES                 EmrCreateCluster_CloudWatchAlarmUnit = "BYTES"
	EmrCreateCluster_CloudWatchAlarmUnit_KILO_BYTES            EmrCreateCluster_CloudWatchAlarmUnit = "KILO_BYTES"
	EmrCreateCluster_CloudWatchAlarmUnit_MEGA_BYTES            EmrCreateCluster_CloudWatchAlarmUnit = "MEGA_BYTES"
	EmrCreateCluster_CloudWatchAlarmUnit_GIGA_BYTES            EmrCreateCluster_CloudWatchAlarmUnit = "GIGA_BYTES"
	EmrCreateCluster_CloudWatchAlarmUnit_TERA_BYTES            EmrCreateCluster_CloudWatchAlarmUnit = "TERA_BYTES"
	EmrCreateCluster_CloudWatchAlarmUnit_BITS                  EmrCreateCluster_CloudWatchAlarmUnit = "BITS"
	EmrCreateCluster_CloudWatchAlarmUnit_KILO_BITS             EmrCreateCluster_CloudWatchAlarmUnit = "KILO_BITS"
	EmrCreateCluster_CloudWatchAlarmUnit_MEGA_BITS             EmrCreateCluster_CloudWatchAlarmUnit = "MEGA_BITS"
	EmrCreateCluster_CloudWatchAlarmUnit_GIGA_BITS             EmrCreateCluster_CloudWatchAlarmUnit = "GIGA_BITS"
	EmrCreateCluster_CloudWatchAlarmUnit_TERA_BITS             EmrCreateCluster_CloudWatchAlarmUnit = "TERA_BITS"
	EmrCreateCluster_CloudWatchAlarmUnit_PERCENT               EmrCreateCluster_CloudWatchAlarmUnit = "PERCENT"
	EmrCreateCluster_CloudWatchAlarmUnit_COUNT                 EmrCreateCluster_CloudWatchAlarmUnit = "COUNT"
	EmrCreateCluster_CloudWatchAlarmUnit_BYTES_PER_SECOND      EmrCreateCluster_CloudWatchAlarmUnit = "BYTES_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_KILO_BYTES_PER_SECOND EmrCreateCluster_CloudWatchAlarmUnit = "KILO_BYTES_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_MEGA_BYTES_PER_SECOND EmrCreateCluster_CloudWatchAlarmUnit = "MEGA_BYTES_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_GIGA_BYTES_PER_SECOND EmrCreateCluster_CloudWatchAlarmUnit = "GIGA_BYTES_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_TERA_BYTES_PER_SECOND EmrCreateCluster_CloudWatchAlarmUnit = "TERA_BYTES_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_BITS_PER_SECOND       EmrCreateCluster_CloudWatchAlarmUnit = "BITS_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_KILO_BITS_PER_SECOND  EmrCreateCluster_CloudWatchAlarmUnit = "KILO_BITS_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_MEGA_BITS_PER_SECOND  EmrCreateCluster_CloudWatchAlarmUnit = "MEGA_BITS_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_GIGA_BITS_PER_SECOND  EmrCreateCluster_CloudWatchAlarmUnit = "GIGA_BITS_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_TERA_BITS_PER_SECOND  EmrCreateCluster_CloudWatchAlarmUnit = "TERA_BITS_PER_SECOND"
	EmrCreateCluster_CloudWatchAlarmUnit_COUNT_PER_SECOND      EmrCreateCluster_CloudWatchAlarmUnit = "COUNT_PER_SECOND"
)

type EmrCreateCluster_ConfigurationProperty 

type EmrCreateCluster_ConfigurationProperty struct {
	// The classification within a configuration.
	// Experimental.
	Classification *string `json:"classification"`
	// A list of additional configurations to apply within a configuration object.
	// Experimental.
	Configurations *[]*EmrCreateCluster_ConfigurationProperty `json:"configurations"`
	// A set of properties specified within a configuration classification.
	// Experimental.
	Properties *map[string]*string `json:"properties"`
}

An optional configuration specification to be used when provisioning cluster instances, which can include configurations for applications and software bundled with Amazon EMR.

See the RunJobFlow API for complete documentation on input parameters See: https://docs.aws.amazon.com/emr/latest/APIReference/API_Configuration.html

Experimental.

type EmrCreateCluster_EbsBlockDeviceConfigProperty 

type EmrCreateCluster_EbsBlockDeviceConfigProperty struct {
	// EBS volume specifications such as volume type, IOPS, and size (GiB) that will be requested for the EBS volume attached to an EC2 instance in the cluster.
	// Experimental.
	VolumeSpecification *EmrCreateCluster_VolumeSpecificationProperty `json:"volumeSpecification"`
	// Number of EBS volumes with a specific volume configuration that will be associated with every instance in the instance group.
	// Experimental.
	VolumesPerInstance *float64 `json:"volumesPerInstance"`
}

Configuration of requested EBS block device associated with the instance group with count of volumes that will be associated to every instance. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_EbsBlockDeviceConfig.html

Experimental.

type EmrCreateCluster_EbsBlockDeviceVolumeType 

type EmrCreateCluster_EbsBlockDeviceVolumeType string

EBS Volume Types. Experimental. 

const (
	EmrCreateCluster_EbsBlockDeviceVolumeType_GP2      EmrCreateCluster_EbsBlockDeviceVolumeType = "GP2"
	EmrCreateCluster_EbsBlockDeviceVolumeType_IO1      EmrCreateCluster_EbsBlockDeviceVolumeType = "IO1"
	EmrCreateCluster_EbsBlockDeviceVolumeType_STANDARD EmrCreateCluster_EbsBlockDeviceVolumeType = "STANDARD"
)

type EmrCreateCluster_EbsConfigurationProperty 

type EmrCreateCluster_EbsConfigurationProperty struct {
	// An array of Amazon EBS volume specifications attached to a cluster instance.
	// Experimental.
	EbsBlockDeviceConfigs *[]*EmrCreateCluster_EbsBlockDeviceConfigProperty `json:"ebsBlockDeviceConfigs"`
	// Indicates whether an Amazon EBS volume is EBS-optimized.
	// Experimental.
	EbsOptimized *bool `json:"ebsOptimized"`
}

The Amazon EBS configuration of a cluster instance. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_EbsConfiguration.html

Experimental.

type EmrCreateCluster_EmrClusterScaleDownBehavior 

type EmrCreateCluster_EmrClusterScaleDownBehavior string

Valid valus for the Cluster ScaleDownBehavior. Experimental. 

const (
	EmrCreateCluster_EmrClusterScaleDownBehavior_TERMINATE_AT_INSTANCE_HOUR   EmrCreateCluster_EmrClusterScaleDownBehavior = "TERMINATE_AT_INSTANCE_HOUR"
	EmrCreateCluster_EmrClusterScaleDownBehavior_TERMINATE_AT_TASK_COMPLETION EmrCreateCluster_EmrClusterScaleDownBehavior = "TERMINATE_AT_TASK_COMPLETION"
)

type EmrCreateCluster_InstanceFleetConfigProperty 

type EmrCreateCluster_InstanceFleetConfigProperty struct {
	// The node type that the instance fleet hosts.
	//
	// Valid values are MASTER,CORE,and TASK.
	// Experimental.
	InstanceFleetType EmrCreateCluster_InstanceRoleType `json:"instanceFleetType"`
	// The instance type configurations that define the EC2 instances in the instance fleet.
	// Experimental.
	InstanceTypeConfigs *[]*EmrCreateCluster_InstanceTypeConfigProperty `json:"instanceTypeConfigs"`
	// The launch specification for the instance fleet.
	// Experimental.
	LaunchSpecifications *EmrCreateCluster_InstanceFleetProvisioningSpecificationsProperty `json:"launchSpecifications"`
	// The friendly name of the instance fleet.
	// Experimental.
	Name *string `json:"name"`
	// The target capacity of On-Demand units for the instance fleet, which determines how many On-Demand instances to provision.
	// Experimental.
	TargetOnDemandCapacity *float64 `json:"targetOnDemandCapacity"`
	// The target capacity of Spot units for the instance fleet, which determines how many Spot instances to provision.
	// Experimental.
	TargetSpotCapacity *float64 `json:"targetSpotCapacity"`
}

The configuration that defines an instance fleet. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceFleetConfig.html

Experimental.

type EmrCreateCluster_InstanceFleetProvisioningSpecificationsProperty 

type EmrCreateCluster_InstanceFleetProvisioningSpecificationsProperty struct {
	// The launch specification for Spot instances in the fleet, which determines the defined duration and provisioning timeout behavior.
	// Experimental.
	SpotSpecification *EmrCreateCluster_SpotProvisioningSpecificationProperty `json:"spotSpecification"`
}

The launch specification for Spot instances in the fleet, which determines the defined duration and provisioning timeout behavior. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceFleetProvisioningSpecifications.html

Experimental.

type EmrCreateCluster_InstanceGroupConfigProperty 

type EmrCreateCluster_InstanceGroupConfigProperty struct {
	// Target number of instances for the instance group.
	// Experimental.
	InstanceCount *float64 `json:"instanceCount"`
	// The role of the instance group in the cluster.
	// Experimental.
	InstanceRole EmrCreateCluster_InstanceRoleType `json:"instanceRole"`
	// The EC2 instance type for all instances in the instance group.
	// Experimental.
	InstanceType *string `json:"instanceType"`
	// An automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster.
	// Experimental.
	AutoScalingPolicy *EmrCreateCluster_AutoScalingPolicyProperty `json:"autoScalingPolicy"`
	// The bid price for each EC2 Spot instance type as defined by InstanceType.
	//
	// Expressed in USD.
	// Experimental.
	BidPrice *string `json:"bidPrice"`
	// The list of configurations supplied for an EMR cluster instance group.
	// Experimental.
	Configurations *[]*EmrCreateCluster_ConfigurationProperty `json:"configurations"`
	// EBS configurations that will be attached to each EC2 instance in the instance group.
	// Experimental.
	EbsConfiguration *EmrCreateCluster_EbsConfigurationProperty `json:"ebsConfiguration"`
	// Market type of the EC2 instances used to create a cluster node.
	// Experimental.
	Market EmrCreateCluster_InstanceMarket `json:"market"`
	// Friendly name given to the instance group.
	// Experimental.
	Name *string `json:"name"`
}

Configuration defining a new instance group. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceGroupConfig.html

Experimental.

type EmrCreateCluster_InstanceMarket 

type EmrCreateCluster_InstanceMarket string

EC2 Instance Market. Experimental. 

const (
	EmrCreateCluster_InstanceMarket_ON_DEMAND EmrCreateCluster_InstanceMarket = "ON_DEMAND"
	EmrCreateCluster_InstanceMarket_SPOT      EmrCreateCluster_InstanceMarket = "SPOT"
)

type EmrCreateCluster_InstanceRoleType 

type EmrCreateCluster_InstanceRoleType string

Instance Role Types. Experimental. 

const (
	EmrCreateCluster_InstanceRoleType_MASTER EmrCreateCluster_InstanceRoleType = "MASTER"
	EmrCreateCluster_InstanceRoleType_CORE   EmrCreateCluster_InstanceRoleType = "CORE"
	EmrCreateCluster_InstanceRoleType_TASK   EmrCreateCluster_InstanceRoleType = "TASK"
)

type EmrCreateCluster_InstanceTypeConfigProperty 

type EmrCreateCluster_InstanceTypeConfigProperty struct {
	// An EC2 instance type.
	// Experimental.
	InstanceType *string `json:"instanceType"`
	// The bid price for each EC2 Spot instance type as defined by InstanceType.
	//
	// Expressed in USD.
	// Experimental.
	BidPrice *string `json:"bidPrice"`
	// The bid price, as a percentage of On-Demand price.
	// Experimental.
	BidPriceAsPercentageOfOnDemandPrice *float64 `json:"bidPriceAsPercentageOfOnDemandPrice"`
	// A configuration classification that applies when provisioning cluster instances, which can include configurations for applications and software that run on the cluster.
	// Experimental.
	Configurations *[]*EmrCreateCluster_ConfigurationProperty `json:"configurations"`
	// The configuration of Amazon Elastic Block Storage (EBS) attached to each instance as defined by InstanceType.
	// Experimental.
	EbsConfiguration *EmrCreateCluster_EbsConfigurationProperty `json:"ebsConfiguration"`
	// The number of units that a provisioned instance of this type provides toward fulfilling the target capacities defined in the InstanceFleetConfig.
	// Experimental.
	WeightedCapacity *float64 `json:"weightedCapacity"`
}

An instance type configuration for each instance type in an instance fleet, which determines the EC2 instances Amazon EMR attempts to provision to fulfill On-Demand and Spot target capacities. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceTypeConfig.html

Experimental.

type EmrCreateCluster_InstancesConfigProperty 

type EmrCreateCluster_InstancesConfigProperty struct {
	// A list of additional Amazon EC2 security group IDs for the master node.
	// Experimental.
	AdditionalMasterSecurityGroups *[]*string `json:"additionalMasterSecurityGroups"`
	// A list of additional Amazon EC2 security group IDs for the core and task nodes.
	// Experimental.
	AdditionalSlaveSecurityGroups *[]*string `json:"additionalSlaveSecurityGroups"`
	// The name of the EC2 key pair that can be used to ssh to the master node as the user called "hadoop.".
	// Experimental.
	Ec2KeyName *string `json:"ec2KeyName"`
	// Applies to clusters that use the uniform instance group configuration.
	//
	// To launch the cluster in Amazon Virtual Private Cloud (Amazon VPC),
	// set this parameter to the identifier of the Amazon VPC subnet where you want the cluster to launch.
	// Experimental.
	Ec2SubnetId *string `json:"ec2SubnetId"`
	// Applies to clusters that use the instance fleet configuration.
	//
	// When multiple EC2 subnet IDs are specified, Amazon EMR evaluates them and
	// launches instances in the optimal subnet.
	// Experimental.
	Ec2SubnetIds *[]*string `json:"ec2SubnetIds"`
	// The identifier of the Amazon EC2 security group for the master node.
	// Experimental.
	EmrManagedMasterSecurityGroup *string `json:"emrManagedMasterSecurityGroup"`
	// The identifier of the Amazon EC2 security group for the core and task nodes.
	// Experimental.
	EmrManagedSlaveSecurityGroup *string `json:"emrManagedSlaveSecurityGroup"`
	// Applies only to Amazon EMR release versions earlier than 4.0. The Hadoop version for the cluster.
	// Experimental.
	HadoopVersion *string `json:"hadoopVersion"`
	// The number of EC2 instances in the cluster.
	// Experimental.
	InstanceCount *float64 `json:"instanceCount"`
	// Describes the EC2 instances and instance configurations for clusters that use the instance fleet configuration.
	//
	// The instance fleet configuration is available only in Amazon EMR versions 4.8.0 and later, excluding 5.0.x versions.
	// Experimental.
	InstanceFleets *[]*EmrCreateCluster_InstanceFleetConfigProperty `json:"instanceFleets"`
	// Configuration for the instance groups in a cluster.
	// Experimental.
	InstanceGroups *[]*EmrCreateCluster_InstanceGroupConfigProperty `json:"instanceGroups"`
	// The EC2 instance type of the master node.
	// Experimental.
	MasterInstanceType *string `json:"masterInstanceType"`
	// The Availability Zone in which the cluster runs.
	// Experimental.
	Placement *EmrCreateCluster_PlacementTypeProperty `json:"placement"`
	// The identifier of the Amazon EC2 security group for the Amazon EMR service to access clusters in VPC private subnets.
	// Experimental.
	ServiceAccessSecurityGroup *string `json:"serviceAccessSecurityGroup"`
	// The EC2 instance type of the core and task nodes.
	// Experimental.
	SlaveInstanceType *string `json:"slaveInstanceType"`
	// Specifies whether to lock the cluster to prevent the Amazon EC2 instances from being terminated by API call, user intervention, or in the event of a job-flow error.
	// Experimental.
	TerminationProtected *bool `json:"terminationProtected"`
}

A specification of the number and type of Amazon EC2 instances.

See the RunJobFlow API for complete documentation on input parameters See: https://docs.aws.amazon.com/emr/latest/APIReference/API_JobFlowInstancesConfig.html

Experimental.

type EmrCreateCluster_KerberosAttributesProperty 

type EmrCreateCluster_KerberosAttributesProperty struct {
	// The name of the Kerberos realm to which all nodes in a cluster belong.
	//
	// For example, EC2.INTERNAL.
	// Experimental.
	Realm *string `json:"realm"`
	// The Active Directory password for ADDomainJoinUser.
	// Experimental.
	AdDomainJoinPassword *string `json:"adDomainJoinPassword"`
	// Required only when establishing a cross-realm trust with an Active Directory domain.
	//
	// A user with sufficient privileges to join
	// resources to the domain.
	// Experimental.
	AdDomainJoinUser *string `json:"adDomainJoinUser"`
	// Required only when establishing a cross-realm trust with a KDC in a different realm.
	//
	// The cross-realm principal password, which
	// must be identical across realms.
	// Experimental.
	CrossRealmTrustPrincipalPassword *string `json:"crossRealmTrustPrincipalPassword"`
	// The password used within the cluster for the kadmin service on the cluster-dedicated KDC, which maintains Kerberos principals, password policies, and keytabs for the cluster.
	// Experimental.
	KdcAdminPassword *string `json:"kdcAdminPassword"`
}

Attributes for Kerberos configuration when Kerberos authentication is enabled using a security configuration.

See the RunJobFlow API for complete documentation on input parameters See: https://docs.aws.amazon.com/emr/latest/APIReference/API_KerberosAttributes.html

Experimental.

type EmrCreateCluster_MetricDimensionProperty 

type EmrCreateCluster_MetricDimensionProperty struct {
	// The dimension name.
	// Experimental.
	Key *string `json:"key"`
	// The dimension value.
	// Experimental.
	Value *string `json:"value"`
}

A CloudWatch dimension, which is specified using a Key (known as a Name in CloudWatch), Value pair.

By default, Amazon EMR uses one dimension whose Key is JobFlowID and Value is a variable representing the cluster ID, which is ${emr.clusterId}. This enables the rule to bootstrap when the cluster ID becomes available See: https://docs.aws.amazon.com/emr/latest/APIReference/API_MetricDimension.html

Experimental.

type EmrCreateCluster_PlacementTypeProperty 

type EmrCreateCluster_PlacementTypeProperty struct {
	// The Amazon EC2 Availability Zone for the cluster.
	//
	// AvailabilityZone is used for uniform instance groups, while AvailabilityZones
	// (plural) is used for instance fleets.
	// Experimental.
	AvailabilityZone *string `json:"availabilityZone"`
	// When multiple Availability Zones are specified, Amazon EMR evaluates them and launches instances in the optimal Availability Zone.
	//
	// AvailabilityZones is used for instance fleets, while AvailabilityZone (singular) is used for uniform instance groups.
	// Experimental.
	AvailabilityZones *[]*string `json:"availabilityZones"`
}

The Amazon EC2 Availability Zone configuration of the cluster (job flow). See: https://docs.aws.amazon.com/emr/latest/APIReference/API_PlacementType.html

Experimental.

type EmrCreateCluster_ScalingActionProperty 

type EmrCreateCluster_ScalingActionProperty struct {
	// The type of adjustment the automatic scaling activity makes when triggered, and the periodicity of the adjustment.
	// Experimental.
	SimpleScalingPolicyConfiguration *EmrCreateCluster_SimpleScalingPolicyConfigurationProperty `json:"simpleScalingPolicyConfiguration"`
	// Not available for instance groups.
	//
	// Instance groups use the market type specified for the group.
	// Experimental.
	Market EmrCreateCluster_InstanceMarket `json:"market"`
}

The type of adjustment the automatic scaling activity makes when triggered, and the periodicity of the adjustment.

And an automatic scaling configuration, which describes how the policy adds or removes instances, the cooldown period, and the number of EC2 instances that will be added each time the CloudWatch metric alarm condition is satisfied. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ScalingAction.html

Experimental.

type EmrCreateCluster_ScalingAdjustmentType 

type EmrCreateCluster_ScalingAdjustmentType string

AutoScaling Adjustment Type. Experimental. 

const (
	EmrCreateCluster_ScalingAdjustmentType_CHANGE_IN_CAPACITY         EmrCreateCluster_ScalingAdjustmentType = "CHANGE_IN_CAPACITY"
	EmrCreateCluster_ScalingAdjustmentType_PERCENT_CHANGE_IN_CAPACITY EmrCreateCluster_ScalingAdjustmentType = "PERCENT_CHANGE_IN_CAPACITY"
	EmrCreateCluster_ScalingAdjustmentType_EXACT_CAPACITY             EmrCreateCluster_ScalingAdjustmentType = "EXACT_CAPACITY"
)

type EmrCreateCluster_ScalingConstraintsProperty 

type EmrCreateCluster_ScalingConstraintsProperty struct {
	// The upper boundary of EC2 instances in an instance group beyond which scaling activities are not allowed to grow.
	//
	// Scale-out
	// activities will not add instances beyond this boundary.
	// Experimental.
	MaxCapacity *float64 `json:"maxCapacity"`
	// The lower boundary of EC2 instances in an instance group below which scaling activities are not allowed to shrink.
	//
	// Scale-in
	// activities will not terminate instances below this boundary.
	// Experimental.
	MinCapacity *float64 `json:"minCapacity"`
}

The upper and lower EC2 instance limits for an automatic scaling policy.

Automatic scaling activities triggered by automatic scaling rules will not cause an instance group to grow above or below these limits. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ScalingConstraints.html

Experimental.

type EmrCreateCluster_ScalingRuleProperty 

type EmrCreateCluster_ScalingRuleProperty struct {
	// The conditions that trigger an automatic scaling activity.
	// Experimental.
	Action *EmrCreateCluster_ScalingActionProperty `json:"action"`
	// The name used to identify an automatic scaling rule.
	//
	// Rule names must be unique within a scaling policy.
	// Experimental.
	Name *string `json:"name"`
	// The CloudWatch alarm definition that determines when automatic scaling activity is triggered.
	// Experimental.
	Trigger *EmrCreateCluster_ScalingTriggerProperty `json:"trigger"`
	// A friendly, more verbose description of the automatic scaling rule.
	// Experimental.
	Description *string `json:"description"`
}

A scale-in or scale-out rule that defines scaling activity, including the CloudWatch metric alarm that triggers activity, how EC2 instances are added or removed, and the periodicity of adjustments. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ScalingRule.html

Experimental.

type EmrCreateCluster_ScalingTriggerProperty 

type EmrCreateCluster_ScalingTriggerProperty struct {
	// The definition of a CloudWatch metric alarm.
	//
	// When the defined alarm conditions are met along with other trigger parameters,
	// scaling activity begins.
	// Experimental.
	CloudWatchAlarmDefinition *EmrCreateCluster_CloudWatchAlarmDefinitionProperty `json:"cloudWatchAlarmDefinition"`
}

The conditions that trigger an automatic scaling activity and the definition of a CloudWatch metric alarm.

When the defined alarm conditions are met along with other trigger parameters, scaling activity begins. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ScalingTrigger.html

Experimental.

type EmrCreateCluster_ScriptBootstrapActionConfigProperty 

type EmrCreateCluster_ScriptBootstrapActionConfigProperty struct {
	// Location of the script to run during a bootstrap action.
	//
	// Can be either a location in Amazon S3 or on a local file system.
	// Experimental.
	Path *string `json:"path"`
	// A list of command line arguments to pass to the bootstrap action script.
	// Experimental.
	Args *[]*string `json:"args"`
}

Configuration of the script to run during a bootstrap action. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ScriptBootstrapActionConfig.html

Experimental.

type EmrCreateCluster_SimpleScalingPolicyConfigurationProperty 

type EmrCreateCluster_SimpleScalingPolicyConfigurationProperty struct {
	// The amount by which to scale in or scale out, based on the specified AdjustmentType.
	//
	// A positive value adds to the instance group's
	// EC2 instance count while a negative number removes instances. If AdjustmentType is set to EXACT_CAPACITY, the number should only be
	// a positive integer.
	// Experimental.
	ScalingAdjustment *float64 `json:"scalingAdjustment"`
	// The way in which EC2 instances are added (if ScalingAdjustment is a positive number) or terminated (if ScalingAdjustment is a negative number) each time the scaling activity is triggered.
	// Experimental.
	AdjustmentType EmrCreateCluster_ScalingAdjustmentType `json:"adjustmentType"`
	// The amount of time, in seconds, after a scaling activity completes before any further trigger-related scaling activities can start.
	// Experimental.
	CoolDown *float64 `json:"coolDown"`
}

An automatic scaling configuration, which describes how the policy adds or removes instances, the cooldown period, and the number of EC2 instances that will be added each time the CloudWatch metric alarm condition is satisfied. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_SimpleScalingPolicyConfiguration.html

Experimental.

type EmrCreateCluster_SpotProvisioningSpecificationProperty 

type EmrCreateCluster_SpotProvisioningSpecificationProperty struct {
	// The action to take when TargetSpotCapacity has not been fulfilled when the TimeoutDurationMinutes has expired.
	// Experimental.
	TimeoutAction EmrCreateCluster_SpotTimeoutAction `json:"timeoutAction"`
	// The spot provisioning timeout period in minutes.
	// Experimental.
	TimeoutDurationMinutes *float64 `json:"timeoutDurationMinutes"`
	// The defined duration for Spot instances (also known as Spot blocks) in minutes.
	// Experimental.
	BlockDurationMinutes *float64 `json:"blockDurationMinutes"`
}

The launch specification for Spot instances in the instance fleet, which determines the defined duration and provisioning timeout behavior. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_SpotProvisioningSpecification.html

Experimental.

type EmrCreateCluster_SpotTimeoutAction 

type EmrCreateCluster_SpotTimeoutAction string

Spot Timeout Actions. Experimental. 

const (
	EmrCreateCluster_SpotTimeoutAction_SWITCH_TO_ON_DEMAND EmrCreateCluster_SpotTimeoutAction = "SWITCH_TO_ON_DEMAND"
	EmrCreateCluster_SpotTimeoutAction_TERMINATE_CLUSTER   EmrCreateCluster_SpotTimeoutAction = "TERMINATE_CLUSTER"
)

type EmrCreateCluster_VolumeSpecificationProperty 

type EmrCreateCluster_VolumeSpecificationProperty struct {
	// The volume size.
	//
	// If the volume type is EBS-optimized, the minimum value is 10GiB.
	// Maximum size is 1TiB
	// Experimental.
	VolumeSize awscdk.Size `json:"volumeSize"`
	// The volume type.
	//
	// Volume types supported are gp2, io1, standard.
	// Experimental.
	VolumeType EmrCreateCluster_EbsBlockDeviceVolumeType `json:"volumeType"`
	// The number of I/O operations per second (IOPS) that the volume supports.
	// Experimental.
	Iops *float64 `json:"iops"`
}

EBS volume specifications such as volume type, IOPS, and size (GiB) that will be requested for the EBS volume attached to an EC2 instance in the cluster. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_VolumeSpecification.html

Experimental.

type EmrModifyInstanceFleetByName 

type EmrModifyInstanceFleetByName interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to to modify an InstanceFleet on an EMR Cluster. Experimental.

func NewEmrModifyInstanceFleetByName 

func NewEmrModifyInstanceFleetByName(scope constructs.Construct, id *string, props *EmrModifyInstanceFleetByNameProps) EmrModifyInstanceFleetByName

Experimental.

type EmrModifyInstanceFleetByNameProps 

type EmrModifyInstanceFleetByNameProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The ClusterId to update.
	// Experimental.
	ClusterId *string `json:"clusterId"`
	// The InstanceFleetName to update.
	// Experimental.
	InstanceFleetName *string `json:"instanceFleetName"`
	// The target capacity of On-Demand units for the instance fleet.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceFleetModifyConfig.html
	//
	// Experimental.
	TargetOnDemandCapacity *float64 `json:"targetOnDemandCapacity"`
	// The target capacity of Spot units for the instance fleet.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceFleetModifyConfig.html
	//
	// Experimental.
	TargetSpotCapacity *float64 `json:"targetSpotCapacity"`
}

Properties for EmrModifyInstanceFleetByName. Experimental.

type EmrModifyInstanceGroupByName 

type EmrModifyInstanceGroupByName interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to to modify an InstanceGroup on an EMR Cluster. Experimental.

func NewEmrModifyInstanceGroupByName 

func NewEmrModifyInstanceGroupByName(scope constructs.Construct, id *string, props *EmrModifyInstanceGroupByNameProps) EmrModifyInstanceGroupByName

Experimental.

type EmrModifyInstanceGroupByNameProps 

type EmrModifyInstanceGroupByNameProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The ClusterId to update.
	// Experimental.
	ClusterId *string `json:"clusterId"`
	// The JSON that you want to provide to your ModifyInstanceGroup call as input.
	//
	// This uses the same syntax as the ModifyInstanceGroups API.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ModifyInstanceGroups.html
	//
	// Experimental.
	InstanceGroup *EmrModifyInstanceGroupByName_InstanceGroupModifyConfigProperty `json:"instanceGroup"`
	// The InstanceGroupName to update.
	// Experimental.
	InstanceGroupName *string `json:"instanceGroupName"`
}

Properties for EmrModifyInstanceGroupByName. Experimental.

type EmrModifyInstanceGroupByName_InstanceGroupModifyConfigProperty 

type EmrModifyInstanceGroupByName_InstanceGroupModifyConfigProperty struct {
	// A list of new or modified configurations to apply for an instance group.
	// Experimental.
	Configurations *[]*EmrCreateCluster_ConfigurationProperty `json:"configurations"`
	// The EC2 InstanceIds to terminate.
	//
	// After you terminate the instances, the instance group will not return to its original requested size.
	// Experimental.
	EC2InstanceIdsToTerminate *[]*string `json:"eC2InstanceIdsToTerminate"`
	// Target size for the instance group.
	// Experimental.
	InstanceCount *float64 `json:"instanceCount"`
	// Policy for customizing shrink operations.
	// See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ShrinkPolicy.html
	//
	// Experimental.
	ShrinkPolicy *EmrModifyInstanceGroupByName_ShrinkPolicyProperty `json:"shrinkPolicy"`
}

Modify the size or configurations of an instance group. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceGroupModifyConfig.html

Experimental.

type EmrModifyInstanceGroupByName_InstanceResizePolicyProperty 

type EmrModifyInstanceGroupByName_InstanceResizePolicyProperty struct {
	// Specific list of instances to be protected when shrinking an instance group.
	// Experimental.
	InstancesToProtect *[]*string `json:"instancesToProtect"`
	// Specific list of instances to be terminated when shrinking an instance group.
	// Experimental.
	InstancesToTerminate *[]*string `json:"instancesToTerminate"`
	// Decommissioning timeout override for the specific list of instances to be terminated.
	// Experimental.
	InstanceTerminationTimeout awscdk.Duration `json:"instanceTerminationTimeout"`
}

Custom policy for requesting termination protection or termination of specific instances when shrinking an instance group. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_InstanceResizePolicy.html

Experimental.

type EmrModifyInstanceGroupByName_ShrinkPolicyProperty 

type EmrModifyInstanceGroupByName_ShrinkPolicyProperty struct {
	// The desired timeout for decommissioning an instance.
	//
	// Overrides the default YARN decommissioning timeout.
	// Experimental.
	DecommissionTimeout awscdk.Duration `json:"decommissionTimeout"`
	// Custom policy for requesting termination protection or termination of specific instances when shrinking an instance group.
	// Experimental.
	InstanceResizePolicy *EmrModifyInstanceGroupByName_InstanceResizePolicyProperty `json:"instanceResizePolicy"`
}

Policy for customizing shrink operations.

Allows configuration of decommissioning timeout and targeted instance shrinking. See: https://docs.aws.amazon.com/emr/latest/APIReference/API_ShrinkPolicy.html

Experimental.

type EmrSetClusterTerminationProtection 

type EmrSetClusterTerminationProtection interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to to set Termination Protection on an EMR Cluster. Experimental.

func NewEmrSetClusterTerminationProtection 

func NewEmrSetClusterTerminationProtection(scope constructs.Construct, id *string, props *EmrSetClusterTerminationProtectionProps) EmrSetClusterTerminationProtection

Experimental.

type EmrSetClusterTerminationProtectionProps 

type EmrSetClusterTerminationProtectionProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The ClusterId to update.
	// Experimental.
	ClusterId *string `json:"clusterId"`
	// Termination protection indicator.
	// Experimental.
	TerminationProtected *bool `json:"terminationProtected"`
}

Properties for EmrSetClusterTerminationProtection. Experimental.

type EmrTerminateCluster 

type EmrTerminateCluster interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to terminate an EMR Cluster. Experimental.

func NewEmrTerminateCluster 

func NewEmrTerminateCluster(scope constructs.Construct, id *string, props *EmrTerminateClusterProps) EmrTerminateCluster

Experimental.

type EmrTerminateClusterProps 

type EmrTerminateClusterProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The ClusterId to terminate.
	// Experimental.
	ClusterId *string `json:"clusterId"`
}

Properties for EmrTerminateCluster. Experimental.

type EncryptionConfiguration 

type EncryptionConfiguration struct {
	// Type of S3 server-side encryption enabled.
	// Experimental.
	EncryptionOption EncryptionOption `json:"encryptionOption"`
	// KMS key ARN or ID.
	// Experimental.
	EncryptionKey awskms.IKey `json:"encryptionKey"`
}

Encryption Configuration of the S3 bucket. See: https://docs.aws.amazon.com/athena/latest/APIReference/API_EncryptionConfiguration.html

Experimental.

type EncryptionOption 

type EncryptionOption string

Encryption Options of the S3 bucket. See: https://docs.aws.amazon.com/athena/latest/APIReference/API_EncryptionConfiguration.html#athena-Type-EncryptionConfiguration-EncryptionOption

Experimental. 

const (
	EncryptionOption_S3_MANAGED      EncryptionOption = "S3_MANAGED"
	EncryptionOption_KMS             EncryptionOption = "KMS"
	EncryptionOption_CLIENT_SIDE_KMS EncryptionOption = "CLIENT_SIDE_KMS"
)

type EvaluateExpression 

type EvaluateExpression interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to evaluate an expression.

OUTPUT: the output of this task is the evaluated expression. Experimental.

func NewEvaluateExpression 

func NewEvaluateExpression(scope constructs.Construct, id *string, props *EvaluateExpressionProps) EvaluateExpression

Experimental.

type EvaluateExpressionProps 

type EvaluateExpressionProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The expression to evaluate.
	//
	// The expression may contain state paths.
	//
	// TODO: EXAMPLE
	//
	// Experimental.
	Expression *string `json:"expression"`
	// The runtime language to use to evaluate the expression.
	// Experimental.
	Runtime awslambda.Runtime `json:"runtime"`
}

Properties for EvaluateExpression. Experimental.

type GlueDataBrewStartJobRun 

type GlueDataBrewStartJobRun interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Start a Job run as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-databrew.html

Experimental.

func NewGlueDataBrewStartJobRun 

func NewGlueDataBrewStartJobRun(scope constructs.Construct, id *string, props *GlueDataBrewStartJobRunProps) GlueDataBrewStartJobRun

Experimental.

type GlueDataBrewStartJobRunProps 

type GlueDataBrewStartJobRunProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Glue DataBrew Job to run.
	// Experimental.
	Name *string `json:"name"`
}

Properties for starting a job run with StartJobRun. Experimental.

type GlueStartJobRun 

type GlueStartJobRun interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Starts an AWS Glue job in a Task state.

OUTPUT: the output of this task is a JobRun structure, for details consult https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-jobs-runs.html#aws-glue-api-jobs-runs-JobRun See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-glue.html

Experimental.

func NewGlueStartJobRun 

func NewGlueStartJobRun(scope constructs.Construct, id *string, props *GlueStartJobRunProps) GlueStartJobRun

Experimental.

type GlueStartJobRunProps 

type GlueStartJobRunProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Glue job name.
	// Experimental.
	GlueJobName *string `json:"glueJobName"`
	// The job arguments specifically for this run.
	//
	// For this job run, they replace the default arguments set in the job
	// definition itself.
	// Experimental.
	Arguments awsstepfunctions.TaskInput `json:"arguments"`
	// After a job run starts, the number of minutes to wait before sending a job run delay notification.
	//
	// Must be at least 1 minute.
	// Experimental.
	NotifyDelayAfter awscdk.Duration `json:"notifyDelayAfter"`
	// The name of the SecurityConfiguration structure to be used with this job run.
	//
	// This must match the Glue API
	// See: https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-common.html#aws-glue-api-regex-oneLine
	//
	// Experimental.
	SecurityConfiguration *string `json:"securityConfiguration"`
}

Properties for starting an AWS Glue job as a task. Experimental.

type HttpMethod 

type HttpMethod string

Http Methods that API Gateway supports. Experimental. 

const (
	HttpMethod_GET     HttpMethod = "GET"
	HttpMethod_POST    HttpMethod = "POST"
	HttpMethod_PUT     HttpMethod = "PUT"
	HttpMethod_DELETE  HttpMethod = "DELETE"
	HttpMethod_PATCH   HttpMethod = "PATCH"
	HttpMethod_HEAD    HttpMethod = "HEAD"
	HttpMethod_OPTIONS HttpMethod = "OPTIONS"
)

type HttpMethods 

type HttpMethods string

Method type of a EKS call. Experimental. 

const (
	HttpMethods_GET    HttpMethods = "GET"
	HttpMethods_POST   HttpMethods = "POST"
	HttpMethods_PUT    HttpMethods = "PUT"
	HttpMethods_DELETE HttpMethods = "DELETE"
	HttpMethods_PATCH  HttpMethods = "PATCH"
	HttpMethods_HEAD   HttpMethods = "HEAD"
)

type IContainerDefinition 

type IContainerDefinition interface {
	// Called when the ContainerDefinition is used by a SageMaker task.
	// Experimental.
	Bind(task ISageMakerTask) *ContainerDefinitionConfig
}

Configuration of the container used to host the model. See: https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_ContainerDefinition.html

Experimental.

type IEcsLaunchTarget 

type IEcsLaunchTarget interface {
	// called when the ECS launch target is configured on RunTask.
	// Experimental.
	Bind(task EcsRunTask, launchTargetOptions *LaunchTargetBindOptions) *EcsLaunchTargetConfig
}

An Amazon ECS launch type determines the type of infrastructure on which your tasks and services are hosted. See: https://docs.aws.amazon.com/AmazonECS/latest/developerguide/launch_types.html

Experimental.

type ISageMakerTask 

type ISageMakerTask interface {
	awsiam.IGrantable
}

Task to train a machine learning model using Amazon SageMaker. Experimental.

type InputMode 

type InputMode string

Input mode that the algorithm supports. Experimental. 

const (
	InputMode_PIPE InputMode = "PIPE"
	InputMode_FILE InputMode = "FILE"
)

type JobDependency 

type JobDependency struct {
	// The job ID of the AWS Batch job associated with this dependency.
	// Experimental.
	JobId *string `json:"jobId"`
	// The type of the job dependency.
	// Experimental.
	Type *string `json:"type"`
}

An object representing an AWS Batch job dependency. Experimental.

type LambdaInvocationType 

type LambdaInvocationType string

Invocation type of a Lambda. Experimental. 

const (
	LambdaInvocationType_REQUEST_RESPONSE LambdaInvocationType = "REQUEST_RESPONSE"
	LambdaInvocationType_EVENT            LambdaInvocationType = "EVENT"
	LambdaInvocationType_DRY_RUN          LambdaInvocationType = "DRY_RUN"
)

type LambdaInvoke 

type LambdaInvoke interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Invoke a Lambda function as a Task. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-lambda.html

Experimental.

func NewLambdaInvoke 

func NewLambdaInvoke(scope constructs.Construct, id *string, props *LambdaInvokeProps) LambdaInvoke

Experimental.

type LambdaInvokeProps 

type LambdaInvokeProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Lambda function to invoke.
	// Experimental.
	LambdaFunction awslambda.IFunction `json:"lambdaFunction"`
	// Up to 3583 bytes of base64-encoded data about the invoking client to pass to the function.
	// Experimental.
	ClientContext *string `json:"clientContext"`
	// Invocation type of the Lambda function.
	// Experimental.
	InvocationType LambdaInvocationType `json:"invocationType"`
	// The JSON that will be supplied as input to the Lambda function.
	// Experimental.
	Payload awsstepfunctions.TaskInput `json:"payload"`
	// Invoke the Lambda in a way that only returns the payload response without additional metadata.
	//
	// The `payloadResponseOnly` property cannot be used if `integrationPattern`, `invocationType`,
	// `clientContext`, or `qualifier` are specified.
	// It always uses the REQUEST_RESPONSE behavior.
	// Experimental.
	PayloadResponseOnly *bool `json:"payloadResponseOnly"`
	// Version or alias to invoke a published version of the function.
	//
	// You only need to supply this if you want the version of the Lambda Function to depend
	// on data in the state machine state. If not, you can pass the appropriate Alias or Version object
	// directly as the `lambdaFunction` argument.
	// Experimental.
	Qualifier *string `json:"qualifier"`
	// Whether to retry on Lambda service exceptions.
	//
	// This handles `Lambda.ServiceException`, `Lambda.AWSLambdaException` and
	// `Lambda.SdkClientException` with an interval of 2 seconds, a back-off rate
	// of 2 and 6 maximum attempts.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/bp-lambda-serviceexception.html
	//
	// Experimental.
	RetryOnServiceExceptions *bool `json:"retryOnServiceExceptions"`
}

Properties for invoking a Lambda function with LambdaInvoke. Experimental.

type LaunchTargetBindOptions 

type LaunchTargetBindOptions struct {
	// Task definition to run Docker containers in Amazon ECS.
	// Experimental.
	TaskDefinition awsecs.ITaskDefinition `json:"taskDefinition"`
	// A regional grouping of one or more container instances on which you can run tasks and services.
	// Experimental.
	Cluster awsecs.ICluster `json:"cluster"`
}

Options for binding a launch target to an ECS run job task. Experimental.

type MetricDefinition 

type MetricDefinition struct {
	// Name of the metric.
	// Experimental.
	Name *string `json:"name"`
	// Regular expression that searches the output of a training job and gets the value of the metric.
	// Experimental.
	Regex *string `json:"regex"`
}

Specifies the metric name and regular expressions used to parse algorithm logs. Experimental.

type Mode 

type Mode string

Specifies how many models the container hosts. Experimental. 

const (
	Mode_SINGLE_MODEL Mode = "SINGLE_MODEL"
	Mode_MULTI_MODEL  Mode = "MULTI_MODEL"
)

type ModelClientOptions 

type ModelClientOptions struct {
	// The maximum number of retries when invocation requests are failing.
	// Experimental.
	InvocationsMaxRetries *float64 `json:"invocationsMaxRetries"`
	// The timeout duration for an invocation request.
	// Experimental.
	InvocationsTimeout awscdk.Duration `json:"invocationsTimeout"`
}

Configures the timeout and maximum number of retries for processing a transform job invocation. Experimental.

type OutputDataConfig 

type OutputDataConfig struct {
	// Identifies the S3 path where you want Amazon SageMaker to store the model artifacts.
	// Experimental.
	S3OutputLocation S3Location `json:"s3OutputLocation"`
	// Optional KMS encryption key that Amazon SageMaker uses to encrypt the model artifacts at rest using Amazon S3 server-side encryption.
	// Experimental.
	EncryptionKey awskms.IKey `json:"encryptionKey"`
}

Configures the S3 bucket where SageMaker will save the result of model training. Experimental.

type ProductionVariant 

type ProductionVariant struct {
	// The ML compute instance type.
	// Experimental.
	InstanceType awsec2.InstanceType `json:"instanceType"`
	// The name of the model that you want to host.
	//
	// This is the name that you specified when creating the model.
	// Experimental.
	ModelName *string `json:"modelName"`
	// The name of the production variant.
	// Experimental.
	VariantName *string `json:"variantName"`
	// The size of the Elastic Inference (EI) instance to use for the production variant.
	// Experimental.
	AcceleratorType AcceleratorType `json:"acceleratorType"`
	// Number of instances to launch initially.
	// Experimental.
	InitialInstanceCount *float64 `json:"initialInstanceCount"`
	// Determines initial traffic distribution among all of the models that you specify in the endpoint configuration.
	// Experimental.
	InitialVariantWeight *float64 `json:"initialVariantWeight"`
}

Identifies a model that you want to host and the resources to deploy for hosting it. See: https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_ProductionVariant.html

Experimental.

type QueryExecutionContext 

type QueryExecutionContext struct {
	// Name of catalog used in query execution.
	// Experimental.
	CatalogName *string `json:"catalogName"`
	// Name of database used in query execution.
	// Experimental.
	DatabaseName *string `json:"databaseName"`
}

Database and data catalog context in which the query execution occurs. See: https://docs.aws.amazon.com/athena/latest/APIReference/API_QueryExecutionContext.html

Experimental.

type RecordWrapperType 

type RecordWrapperType string

Define the format of the input data. Experimental. 

const (
	RecordWrapperType_NONE      RecordWrapperType = "NONE"
	RecordWrapperType_RECORD_IO RecordWrapperType = "RECORD_IO"
)

type ResourceConfig 

type ResourceConfig struct {
	// The number of ML compute instances to use.
	// Experimental.
	InstanceCount *float64 `json:"instanceCount"`
	// ML compute instance type.
	// Experimental.
	InstanceType awsec2.InstanceType `json:"instanceType"`
	// Size of the ML storage volume that you want to provision.
	// Experimental.
	VolumeSize awscdk.Size `json:"volumeSize"`
	// KMS key that Amazon SageMaker uses to encrypt data on the storage volume attached to the ML compute instance(s) that run the training job.
	// Experimental.
	VolumeEncryptionKey awskms.IKey `json:"volumeEncryptionKey"`
}

Specifies the resources, ML compute instances, and ML storage volumes to deploy for model training. Experimental.

type ResultConfiguration 

type ResultConfiguration struct {
	// Encryption option used if enabled in S3.
	// Experimental.
	EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration"`
	// S3 path of query results.
	//
	// TODO: EXAMPLE
	//
	// Experimental.
	OutputLocation *awss3.Location `json:"outputLocation"`
}

Location of query result along with S3 bucket configuration. See: https://docs.aws.amazon.com/athena/latest/APIReference/API_ResultConfiguration.html

Experimental.

type S3DataDistributionType 

type S3DataDistributionType string

S3 Data Distribution Type. Experimental. 

const (
	S3DataDistributionType_FULLY_REPLICATED  S3DataDistributionType = "FULLY_REPLICATED"
	S3DataDistributionType_SHARDED_BY_S3_KEY S3DataDistributionType = "SHARDED_BY_S3_KEY"
)

type S3DataSource 

type S3DataSource struct {
	// S3 Uri.
	// Experimental.
	S3Location S3Location `json:"s3Location"`
	// List of one or more attribute names to use that are found in a specified augmented manifest file.
	// Experimental.
	AttributeNames *[]*string `json:"attributeNames"`
	// S3 Data Distribution Type.
	// Experimental.
	S3DataDistributionType S3DataDistributionType `json:"s3DataDistributionType"`
	// S3 Data Type.
	// Experimental.
	S3DataType S3DataType `json:"s3DataType"`
}

S3 location of the channel data. See: https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_S3DataSource.html

Experimental.

type S3DataType 

type S3DataType string

S3 Data Type. Experimental. 

const (
	S3DataType_MANIFEST_FILE           S3DataType = "MANIFEST_FILE"
	S3DataType_S3_PREFIX               S3DataType = "S3_PREFIX"
	S3DataType_AUGMENTED_MANIFEST_FILE S3DataType = "AUGMENTED_MANIFEST_FILE"
)

type S3Location 

type S3Location interface {
	Bind(task ISageMakerTask, opts *S3LocationBindOptions) *S3LocationConfig
}

Constructs `IS3Location` objects. Experimental.

func S3Location_FromBucket 

func S3Location_FromBucket(bucket awss3.IBucket, keyPrefix *string) S3Location

An `IS3Location` built with a determined bucket and key prefix. Experimental.

func S3Location_FromJsonExpression 

func S3Location_FromJsonExpression(expression *string) S3Location

An `IS3Location` determined fully by a JSON Path from the task input.

Due to the dynamic nature of those locations, the IAM grants that will be set by `grantRead` and `grantWrite` apply to the `*` resource. Experimental.

type S3LocationBindOptions 

type S3LocationBindOptions struct {
	// Allow reading from the S3 Location.
	// Experimental.
	ForReading *bool `json:"forReading"`
	// Allow writing to the S3 Location.
	// Experimental.
	ForWriting *bool `json:"forWriting"`
}

Options for binding an S3 Location. Experimental.

type S3LocationConfig 

type S3LocationConfig struct {
	// Uniquely identifies the resource in Amazon S3.
	// Experimental.
	Uri *string `json:"uri"`
}

Stores information about the location of an object in Amazon S3. Experimental.

type SageMakerCreateEndpoint 

type SageMakerCreateEndpoint interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to create a SageMaker endpoint. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

func NewSageMakerCreateEndpoint 

func NewSageMakerCreateEndpoint(scope constructs.Construct, id *string, props *SageMakerCreateEndpointProps) SageMakerCreateEndpoint

Experimental.

type SageMakerCreateEndpointConfig 

type SageMakerCreateEndpointConfig interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to create a SageMaker endpoint configuration. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

func NewSageMakerCreateEndpointConfig 

func NewSageMakerCreateEndpointConfig(scope constructs.Construct, id *string, props *SageMakerCreateEndpointConfigProps) SageMakerCreateEndpointConfig

Experimental.

type SageMakerCreateEndpointConfigProps 

type SageMakerCreateEndpointConfigProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The name of the endpoint configuration.
	// Experimental.
	EndpointConfigName *string `json:"endpointConfigName"`
	// An list of ProductionVariant objects, one for each model that you want to host at this endpoint.
	//
	// Identifies a model that you want to host and the resources to deploy for hosting it.
	// If you are deploying multiple models, tell Amazon SageMaker how to distribute traffic among the models by specifying variant weights.
	// Experimental.
	ProductionVariants *[]*ProductionVariant `json:"productionVariants"`
	// AWS Key Management Service key that Amazon SageMaker uses to encrypt data on the storage volume attached to the ML compute instance that hosts the endpoint.
	// Experimental.
	KmsKey awskms.IKey `json:"kmsKey"`
	// Tags to be applied to the endpoint configuration.
	// Experimental.
	Tags awsstepfunctions.TaskInput `json:"tags"`
}

Properties for creating an Amazon SageMaker endpoint configuration. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

type SageMakerCreateEndpointProps 

type SageMakerCreateEndpointProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The name of an endpoint configuration.
	// Experimental.
	EndpointConfigName *string `json:"endpointConfigName"`
	// The name of the endpoint.
	//
	// The name must be unique within an AWS Region in your AWS account.
	// Experimental.
	EndpointName *string `json:"endpointName"`
	// Tags to be applied to the endpoint.
	// Experimental.
	Tags awsstepfunctions.TaskInput `json:"tags"`
}

Properties for creating an Amazon SageMaker endpoint. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

type SageMakerCreateModel 

type SageMakerCreateModel interface {
	awsstepfunctions.TaskStateBase
	awsec2.IConnectable
	awsiam.IGrantable
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	Connections() awsec2.Connections
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	GrantPrincipal() awsiam.IPrincipal
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	Role() awsiam.IRole
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	AddSecurityGroup(securityGroup awsec2.ISecurityGroup)
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to create a SageMaker model. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

func NewSageMakerCreateModel 

func NewSageMakerCreateModel(scope constructs.Construct, id *string, props *SageMakerCreateModelProps) SageMakerCreateModel

Experimental.

type SageMakerCreateModelProps 

type SageMakerCreateModelProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The name of the new model.
	// Experimental.
	ModelName *string `json:"modelName"`
	// The definition of the primary docker image containing inference code, associated artifacts, and custom environment map that the inference code uses when the model is deployed for predictions.
	// Experimental.
	PrimaryContainer IContainerDefinition `json:"primaryContainer"`
	// Specifies the containers in the inference pipeline.
	// Experimental.
	Containers *[]IContainerDefinition `json:"containers"`
	// Isolates the model container.
	//
	// No inbound or outbound network calls can be made to or from the model container.
	// Experimental.
	EnableNetworkIsolation *bool `json:"enableNetworkIsolation"`
	// An execution role that you can pass in a CreateModel API request.
	// Experimental.
	Role awsiam.IRole `json:"role"`
	// The subnets of the VPC to which the hosted model is connected (Note this parameter is only used when VPC is provided).
	// Experimental.
	SubnetSelection *awsec2.SubnetSelection `json:"subnetSelection"`
	// Tags to be applied to the model.
	// Experimental.
	Tags awsstepfunctions.TaskInput `json:"tags"`
	// The VPC that is accessible by the hosted model.
	// Experimental.
	Vpc awsec2.IVpc `json:"vpc"`
}

Properties for creating an Amazon SageMaker model. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

type SageMakerCreateTrainingJob 

type SageMakerCreateTrainingJob interface {
	awsstepfunctions.TaskStateBase
	awsec2.IConnectable
	awsiam.IGrantable
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	Connections() awsec2.Connections
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	GrantPrincipal() awsiam.IPrincipal
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	Role() awsiam.IRole
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	AddSecurityGroup(securityGroup awsec2.ISecurityGroup)
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Class representing the SageMaker Create Training Job task. Experimental.

func NewSageMakerCreateTrainingJob 

func NewSageMakerCreateTrainingJob(scope constructs.Construct, id *string, props *SageMakerCreateTrainingJobProps) SageMakerCreateTrainingJob

Experimental.

type SageMakerCreateTrainingJobProps 

type SageMakerCreateTrainingJobProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Identifies the training algorithm to use.
	// Experimental.
	AlgorithmSpecification *AlgorithmSpecification `json:"algorithmSpecification"`
	// Describes the various datasets (e.g. train, validation, test) and the Amazon S3 location where stored.
	// Experimental.
	InputDataConfig *[]*Channel `json:"inputDataConfig"`
	// Identifies the Amazon S3 location where you want Amazon SageMaker to save the results of model training.
	// Experimental.
	OutputDataConfig *OutputDataConfig `json:"outputDataConfig"`
	// Training Job Name.
	// Experimental.
	TrainingJobName *string `json:"trainingJobName"`
	// Algorithm-specific parameters that influence the quality of the model.
	//
	// Set hyperparameters before you start the learning process.
	// For a list of hyperparameters provided by Amazon SageMaker
	// See: https://docs.aws.amazon.com/sagemaker/latest/dg/algos.html
	//
	// Experimental.
	Hyperparameters *map[string]interface{} `json:"hyperparameters"`
	// Specifies the resources, ML compute instances, and ML storage volumes to deploy for model training.
	// Experimental.
	ResourceConfig *ResourceConfig `json:"resourceConfig"`
	// Role for the Training Job.
	//
	// The role must be granted all necessary permissions for the SageMaker training job to
	// be able to operate.
	//
	// See https://docs.aws.amazon.com/fr_fr/sagemaker/latest/dg/sagemaker-roles.html#sagemaker-roles-createtrainingjob-perms
	// Experimental.
	Role awsiam.IRole `json:"role"`
	// Sets a time limit for training.
	// Experimental.
	StoppingCondition *StoppingCondition `json:"stoppingCondition"`
	// Tags to be applied to the train job.
	// Experimental.
	Tags *map[string]*string `json:"tags"`
	// Specifies the VPC that you want your training job to connect to.
	// Experimental.
	VpcConfig *VpcConfig `json:"vpcConfig"`
}

Properties for creating an Amazon SageMaker training job. Experimental.

type SageMakerCreateTransformJob 

type SageMakerCreateTransformJob interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	Role() awsiam.IRole
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

Class representing the SageMaker Create Transform Job task. Experimental.

func NewSageMakerCreateTransformJob 

func NewSageMakerCreateTransformJob(scope constructs.Construct, id *string, props *SageMakerCreateTransformJobProps) SageMakerCreateTransformJob

Experimental.

type SageMakerCreateTransformJobProps 

type SageMakerCreateTransformJobProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Name of the model that you want to use for the transform job.
	// Experimental.
	ModelName *string `json:"modelName"`
	// Dataset to be transformed and the Amazon S3 location where it is stored.
	// Experimental.
	TransformInput *TransformInput `json:"transformInput"`
	// Transform Job Name.
	// Experimental.
	TransformJobName *string `json:"transformJobName"`
	// S3 location where you want Amazon SageMaker to save the results from the transform job.
	// Experimental.
	TransformOutput *TransformOutput `json:"transformOutput"`
	// Number of records to include in a mini-batch for an HTTP inference request.
	// Experimental.
	BatchStrategy BatchStrategy `json:"batchStrategy"`
	// Environment variables to set in the Docker container.
	// Experimental.
	Environment *map[string]*string `json:"environment"`
	// Maximum number of parallel requests that can be sent to each instance in a transform job.
	// Experimental.
	MaxConcurrentTransforms *float64 `json:"maxConcurrentTransforms"`
	// Maximum allowed size of the payload, in MB.
	// Experimental.
	MaxPayload awscdk.Size `json:"maxPayload"`
	// Configures the timeout and maximum number of retries for processing a transform job invocation.
	// Experimental.
	ModelClientOptions *ModelClientOptions `json:"modelClientOptions"`
	// Role for the Transform Job.
	// Experimental.
	Role awsiam.IRole `json:"role"`
	// Tags to be applied to the train job.
	// Experimental.
	Tags *map[string]*string `json:"tags"`
	// ML compute instances for the transform job.
	// Experimental.
	TransformResources *TransformResources `json:"transformResources"`
}

Properties for creating an Amazon SageMaker transform job task. Experimental.

type SageMakerUpdateEndpoint 

type SageMakerUpdateEndpoint interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to update a SageMaker endpoint. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

func NewSageMakerUpdateEndpoint 

func NewSageMakerUpdateEndpoint(scope constructs.Construct, id *string, props *SageMakerUpdateEndpointProps) SageMakerUpdateEndpoint

Experimental.

type SageMakerUpdateEndpointProps 

type SageMakerUpdateEndpointProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The name of the new endpoint configuration.
	// Experimental.
	EndpointConfigName *string `json:"endpointConfigName"`
	// The name of the endpoint whose configuration you want to update.
	// Experimental.
	EndpointName *string `json:"endpointName"`
}

Properties for updating Amazon SageMaker endpoint. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-sagemaker.html

Experimental.

type ShuffleConfig 

type ShuffleConfig struct {
	// Determines the shuffling order.
	// Experimental.
	Seed *float64 `json:"seed"`
}

Configuration for a shuffle option for input data in a channel. Experimental.

type SnsPublish 

type SnsPublish interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to publish messages to SNS topic. Experimental.

func NewSnsPublish 

func NewSnsPublish(scope constructs.Construct, id *string, props *SnsPublishProps) SnsPublish

Experimental.

type SnsPublishProps 

type SnsPublishProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The message you want to send.
	//
	// With the exception of SMS, messages must be UTF-8 encoded strings and
	// at most 256 KB in size.
	// For SMS, each message can contain up to 140 characters.
	// Experimental.
	Message awsstepfunctions.TaskInput `json:"message"`
	// The SNS topic that the task will publish to.
	// Experimental.
	Topic awssns.ITopic `json:"topic"`
	// Send different messages for each transport protocol.
	//
	// For example, you might want to send a shorter message to SMS subscribers
	// and a more verbose message to email and SQS subscribers.
	//
	// Your message must be a JSON object with a top-level JSON key of
	// "default" with a value that is a string
	// You can define other top-level keys that define the message you want to
	// send to a specific transport protocol (i.e. "sqs", "email", "http", etc)
	// See: https://docs.aws.amazon.com/sns/latest/api/API_Publish.html#API_Publish_RequestParameters
	//
	// Experimental.
	MessagePerSubscriptionType *bool `json:"messagePerSubscriptionType"`
	// Used as the "Subject" line when the message is delivered to email endpoints.
	//
	// This field will also be included, if present, in the standard JSON messages
	// delivered to other endpoints.
	// Experimental.
	Subject *string `json:"subject"`
}

Properties for publishing a message to an SNS topic. Experimental.

type SplitType 

type SplitType string

Method to use to split the transform job's data files into smaller batches. Experimental. 

const (
	SplitType_NONE      SplitType = "NONE"
	SplitType_LINE      SplitType = "LINE"
	SplitType_RECORD_IO SplitType = "RECORD_IO"
	SplitType_TF_RECORD SplitType = "TF_RECORD"
)

type SqsSendMessage 

type SqsSendMessage interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A StepFunctions Task to send messages to SQS queue. Experimental.

func NewSqsSendMessage 

func NewSqsSendMessage(scope constructs.Construct, id *string, props *SqsSendMessageProps) SqsSendMessage

Experimental.

type SqsSendMessageProps 

type SqsSendMessageProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The text message to send to the queue.
	// Experimental.
	MessageBody awsstepfunctions.TaskInput `json:"messageBody"`
	// The SQS queue that messages will be sent to.
	// Experimental.
	Queue awssqs.IQueue `json:"queue"`
	// The length of time, for which to delay a message.
	//
	// Messages that you send to the queue remain invisible to consumers for the duration
	// of the delay period. The maximum allowed delay is 15 minutes.
	// Experimental.
	Delay awscdk.Duration `json:"delay"`
	// The token used for deduplication of sent messages.
	//
	// Any messages sent with the same deduplication ID are accepted successfully,
	// but aren't delivered during the 5-minute deduplication interval.
	// Experimental.
	MessageDeduplicationId *string `json:"messageDeduplicationId"`
	// The tag that specifies that a message belongs to a specific message group.
	//
	// Messages that belong to the same message group are processed in a FIFO manner.
	// Messages in different message groups might be processed out of order.
	// Experimental.
	MessageGroupId *string `json:"messageGroupId"`
}

Properties for sending a message to an SQS queue. Experimental.

type StepFunctionsInvokeActivity 

type StepFunctionsInvokeActivity interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to invoke an Activity worker.

An Activity can be used directly as a Resource. Experimental.

func NewStepFunctionsInvokeActivity 

func NewStepFunctionsInvokeActivity(scope constructs.Construct, id *string, props *StepFunctionsInvokeActivityProps) StepFunctionsInvokeActivity

Experimental.

type StepFunctionsInvokeActivityProps 

type StepFunctionsInvokeActivityProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Step Functions Activity to invoke.
	// Experimental.
	Activity awsstepfunctions.IActivity `json:"activity"`
}

Properties for invoking an Activity worker. Experimental.

type StepFunctionsStartExecution 

type StepFunctionsStartExecution interface {
	awsstepfunctions.TaskStateBase
	Branches() *[]awsstepfunctions.StateGraph
	Comment() *string
	DefaultChoice() awsstepfunctions.State
	SetDefaultChoice(val awsstepfunctions.State)
	EndStates() *[]awsstepfunctions.INextable
	Id() *string
	InputPath() *string
	Iteration() awsstepfunctions.StateGraph
	SetIteration(val awsstepfunctions.StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	StartState() awsstepfunctions.State
	StateId() *string
	TaskMetrics() *awsstepfunctions.TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch awsstepfunctions.StateGraph)
	AddCatch(handler awsstepfunctions.IChainable, props *awsstepfunctions.CatchProps) awsstepfunctions.TaskStateBase
	AddChoice(condition awsstepfunctions.Condition, next awsstepfunctions.State)
	AddIterator(iteration awsstepfunctions.StateGraph)
	AddPrefix(x *string)
	AddRetry(props *awsstepfunctions.RetryProps) awsstepfunctions.TaskStateBase
	BindToGraph(graph awsstepfunctions.StateGraph)
	MakeDefault(def awsstepfunctions.State)
	MakeNext(next awsstepfunctions.State)
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricHeartbeatTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricRunTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricScheduleTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	Next(next awsstepfunctions.IChainable) awsstepfunctions.Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph awsstepfunctions.StateGraph)
}

A Step Functions Task to call StartExecution on another state machine.

It supports three service integration patterns: FIRE_AND_FORGET, SYNC and WAIT_FOR_TASK_TOKEN. Experimental.

func NewStepFunctionsStartExecution 

func NewStepFunctionsStartExecution(scope constructs.Construct, id *string, props *StepFunctionsStartExecutionProps) StepFunctionsStartExecution

Experimental.

type StepFunctionsStartExecutionProps 

type StepFunctionsStartExecutionProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Timeout for the heartbeat.
	// Experimental.
	Heartbeat awscdk.Duration `json:"heartbeat"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// AWS Step Functions integrates with services directly in the Amazon States Language.
	//
	// You can control these AWS services using service integration patterns
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token
	//
	// Experimental.
	IntegrationPattern awsstepfunctions.IntegrationPattern `json:"integrationPattern"`
	// JSONPath expression to select select a portion of the state output to pass to the next state.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
	// JSONPath expression to indicate where to inject the state's output.
	//
	// May also be the special value JsonPath.DISCARD, which will cause the state's
	// input to become its output.
	// Experimental.
	ResultPath *string `json:"resultPath"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// The Step Functions state machine to start the execution on.
	// Experimental.
	StateMachine awsstepfunctions.IStateMachine `json:"stateMachine"`
	// The JSON input for the execution, same as that of StartExecution.
	// See: https://docs.aws.amazon.com/step-functions/latest/apireference/API_StartExecution.html
	//
	// Experimental.
	Input awsstepfunctions.TaskInput `json:"input"`
	// The name of the execution, same as that of StartExecution.
	// See: https://docs.aws.amazon.com/step-functions/latest/apireference/API_StartExecution.html
	//
	// Experimental.
	Name *string `json:"name"`
}

Properties for StartExecution. Experimental.

type StoppingCondition 

type StoppingCondition struct {
	// The maximum length of time, in seconds, that the training or compilation job can run.
	// Experimental.
	MaxRuntime awscdk.Duration `json:"maxRuntime"`
}

Specifies a limit to how long a model training job can run.

When the job reaches the time limit, Amazon SageMaker ends the training job. Experimental.

type TaskEnvironmentVariable 

type TaskEnvironmentVariable struct {
	// Name for the environment variable.
	//
	// Exactly one of `name` and `namePath` must be specified.
	// Experimental.
	Name *string `json:"name"`
	// Value of the environment variable.
	//
	// Exactly one of `value` and `valuePath` must be specified.
	// Experimental.
	Value *string `json:"value"`
}

An environment variable to be set in the container run as a task. Experimental.

type TransformDataSource 

type TransformDataSource struct {
	// S3 location of the input data.
	// Experimental.
	S3DataSource *TransformS3DataSource `json:"s3DataSource"`
}

S3 location of the input data that the model can consume. Experimental.

type TransformInput 

type TransformInput struct {
	// S3 location of the channel data.
	// Experimental.
	TransformDataSource *TransformDataSource `json:"transformDataSource"`
	// The compression type of the transform data.
	// Experimental.
	CompressionType CompressionType `json:"compressionType"`
	// Multipurpose internet mail extension (MIME) type of the data.
	// Experimental.
	ContentType *string `json:"contentType"`
	// Method to use to split the transform job's data files into smaller batches.
	// Experimental.
	SplitType SplitType `json:"splitType"`
}

Dataset to be transformed and the Amazon S3 location where it is stored. Experimental.

type TransformOutput 

type TransformOutput struct {
	// S3 path where you want Amazon SageMaker to store the results of the transform job.
	// Experimental.
	S3OutputPath *string `json:"s3OutputPath"`
	// MIME type used to specify the output data.
	// Experimental.
	Accept *string `json:"accept"`
	// Defines how to assemble the results of the transform job as a single S3 object.
	// Experimental.
	AssembleWith AssembleWith `json:"assembleWith"`
	// AWS KMS key that Amazon SageMaker uses to encrypt the model artifacts at rest using Amazon S3 server-side encryption.
	// Experimental.
	EncryptionKey awskms.IKey `json:"encryptionKey"`
}

S3 location where you want Amazon SageMaker to save the results from the transform job. Experimental.

type TransformResources 

type TransformResources struct {
	// Number of ML compute instances to use in the transform job.
	// Experimental.
	InstanceCount *float64 `json:"instanceCount"`
	// ML compute instance type for the transform job.
	// Experimental.
	InstanceType awsec2.InstanceType `json:"instanceType"`
	// AWS KMS key that Amazon SageMaker uses to encrypt data on the storage volume attached to the ML compute instance(s).
	// Experimental.
	VolumeEncryptionKey awskms.IKey `json:"volumeEncryptionKey"`
}

ML compute instances for the transform job. Experimental.

type TransformS3DataSource 

type TransformS3DataSource struct {
	// Identifies either a key name prefix or a manifest.
	// Experimental.
	S3Uri *string `json:"s3Uri"`
	// S3 Data Type.
	// Experimental.
	S3DataType S3DataType `json:"s3DataType"`
}

Location of the channel data. Experimental.

type VpcConfig 

type VpcConfig struct {
	// VPC.
	// Experimental.
	Vpc awsec2.IVpc `json:"vpc"`
	// VPC subnets.
	// Experimental.
	Subnets *awsec2.SubnetSelection `json:"subnets"`
}

Specifies the VPC that you want your Amazon SageMaker training job to connect to. Experimental.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.