awsstepfunctions

package
v2.0.0-rc.26 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2021 License: Apache-2.0 Imports: 9 Imported by: 33

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Activity_IsConstruct 

func Activity_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 Activity_IsResource 

func Activity_IsResource(construct constructs.IConstruct) *bool

Check whether the given construct is a Resource. Experimental.

func CfnActivity_CFN_RESOURCE_TYPE_NAME 

func CfnActivity_CFN_RESOURCE_TYPE_NAME() *string

func CfnActivity_IsCfnElement 

func CfnActivity_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnActivity_IsCfnResource 

func CfnActivity_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnActivity_IsConstruct 

func CfnActivity_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 CfnStateMachine_CFN_RESOURCE_TYPE_NAME 

func CfnStateMachine_CFN_RESOURCE_TYPE_NAME() *string

func CfnStateMachine_IsCfnElement 

func CfnStateMachine_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnStateMachine_IsCfnResource 

func CfnStateMachine_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnStateMachine_IsConstruct 

func CfnStateMachine_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 Choice_FilterNextables 

func Choice_FilterNextables(states *[]State) *[]INextable

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

func Choice_FindReachableEndStates 

func Choice_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func Choice_FindReachableStates 

func Choice_FindReachableStates(start State, options *FindStateOptions) *[]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 Choice_IsConstruct 

func Choice_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 Choice_PrefixStates 

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

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

func CustomState_FilterNextables 

func CustomState_FilterNextables(states *[]State) *[]INextable

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

func CustomState_FindReachableEndStates 

func CustomState_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func CustomState_FindReachableStates 

func CustomState_FindReachableStates(start State, options *FindStateOptions) *[]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 CustomState_IsConstruct 

func CustomState_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 CustomState_PrefixStates 

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

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

func Errors_ALL 

func Errors_ALL() *string

func Errors_BRANCH_FAILED 

func Errors_BRANCH_FAILED() *string

func Errors_HEARTBEAT_TIMEOUT 

func Errors_HEARTBEAT_TIMEOUT() *string

func Errors_NO_CHOICE_MATCHED 

func Errors_NO_CHOICE_MATCHED() *string

func Errors_PARAMETER_PATH_FAILURE 

func Errors_PARAMETER_PATH_FAILURE() *string

func Errors_PERMISSIONS 

func Errors_PERMISSIONS() *string

func Errors_RESULT_PATH_MATCH_FAILURE 

func Errors_RESULT_PATH_MATCH_FAILURE() *string

func Errors_TASKS_FAILED 

func Errors_TASKS_FAILED() *string

func Errors_TIMEOUT 

func Errors_TIMEOUT() *string

func Fail_FilterNextables 

func Fail_FilterNextables(states *[]State) *[]INextable

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

func Fail_FindReachableEndStates 

func Fail_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func Fail_FindReachableStates 

func Fail_FindReachableStates(start State, options *FindStateOptions) *[]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 Fail_IsConstruct 

func Fail_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 Fail_PrefixStates 

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

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

func FieldUtils_ContainsTaskToken 

func FieldUtils_ContainsTaskToken(obj *map[string]interface{}) *bool

Returns whether the given task structure contains the TaskToken field anywhere.

The field is considered included if the field itself or one of its containing fields occurs anywhere in the payload. Experimental.

func FieldUtils_FindReferencedPaths 

func FieldUtils_FindReferencedPaths(obj *map[string]interface{}) *[]*string

Return all JSON paths used in the given structure. Experimental.

func FieldUtils_RenderObject 

func FieldUtils_RenderObject(obj *map[string]interface{}) *map[string]interface{}

Render a JSON structure containing fields to the right StepFunctions structure. Experimental.

func JsonPath_DISCARD 

func JsonPath_DISCARD() *string

func JsonPath_EntireContext 

func JsonPath_EntireContext() *string

func JsonPath_EntirePayload 

func JsonPath_EntirePayload() *string

func JsonPath_IsEncodedJsonPath 

func JsonPath_IsEncodedJsonPath(value *string) *bool

Determines if the indicated string is an encoded JSON path. Experimental.

func JsonPath_ListAt 

func JsonPath_ListAt(path *string) *[]*string

Instead of using a literal string list, get the value from a JSON path. Experimental.

func JsonPath_NumberAt 

func JsonPath_NumberAt(path *string) *float64

Instead of using a literal number, get the value from a JSON path. Experimental.

func JsonPath_StringAt 

func JsonPath_StringAt(path *string) *string

Instead of using a literal string, get the value from a JSON path. Experimental.

func JsonPath_TaskToken 

func JsonPath_TaskToken() *string

func Map_FilterNextables 

func Map_FilterNextables(states *[]State) *[]INextable

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

func Map_FindReachableEndStates 

func Map_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func Map_FindReachableStates 

func Map_FindReachableStates(start State, options *FindStateOptions) *[]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 Map_IsConstruct 

func Map_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 Map_PrefixStates 

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

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

func NewActivity_Override 

func NewActivity_Override(a Activity, scope constructs.Construct, id *string, props *ActivityProps)

Experimental.

func NewCfnActivity_Override 

func NewCfnActivity_Override(c CfnActivity, scope constructs.Construct, id *string, props *CfnActivityProps)

Create a new `AWS::StepFunctions::Activity`.

func NewCfnStateMachine_Override 

func NewCfnStateMachine_Override(c CfnStateMachine, scope constructs.Construct, id *string, props *CfnStateMachineProps)

Create a new `AWS::StepFunctions::StateMachine`.

func NewChoice_Override 

func NewChoice_Override(c Choice, scope constructs.Construct, id *string, props *ChoiceProps)

Experimental.

func NewCondition_Override 

func NewCondition_Override(c Condition)

Experimental.

func NewCustomState_Override 

func NewCustomState_Override(c CustomState, scope constructs.Construct, id *string, props *CustomStateProps)

Experimental.

func NewErrors_Override 

func NewErrors_Override(e Errors)

Experimental.

func NewFail_Override 

func NewFail_Override(f Fail, scope constructs.Construct, id *string, props *FailProps)

Experimental.

func NewMap_Override 

func NewMap_Override(m Map, scope constructs.Construct, id *string, props *MapProps)

Experimental.

func NewParallel_Override 

func NewParallel_Override(p Parallel, scope constructs.Construct, id *string, props *ParallelProps)

Experimental.

func NewPass_Override 

func NewPass_Override(p Pass, scope constructs.Construct, id *string, props *PassProps)

Experimental.

func NewResult_Override 

func NewResult_Override(r Result, value interface{})

Experimental.

func NewStateGraph_Override 

func NewStateGraph_Override(s StateGraph, startState State, graphDescription *string)

Experimental.

func NewStateMachineFragment_Override 

func NewStateMachineFragment_Override(s StateMachineFragment, scope constructs.Construct, id *string)

Creates a new construct node. Experimental.

func NewStateMachine_Override 

func NewStateMachine_Override(s StateMachine, scope constructs.Construct, id *string, props *StateMachineProps)

Experimental.

func NewStateTransitionMetric_Override 

func NewStateTransitionMetric_Override(s StateTransitionMetric)

Experimental.

func NewState_Override 

func NewState_Override(s State, scope constructs.Construct, id *string, props *StateProps)

Experimental.

func NewSucceed_Override 

func NewSucceed_Override(s Succeed, scope constructs.Construct, id *string, props *SucceedProps)

Experimental.

func NewTaskStateBase_Override 

func NewTaskStateBase_Override(t TaskStateBase, scope constructs.Construct, id *string, props *TaskStateBaseProps)

Experimental.

func NewWait_Override 

func NewWait_Override(w Wait, scope constructs.Construct, id *string, props *WaitProps)

Experimental.

func Parallel_FilterNextables 

func Parallel_FilterNextables(states *[]State) *[]INextable

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

func Parallel_FindReachableEndStates 

func Parallel_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func Parallel_FindReachableStates 

func Parallel_FindReachableStates(start State, options *FindStateOptions) *[]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 Parallel_IsConstruct 

func Parallel_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 Parallel_PrefixStates 

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

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

func Pass_FilterNextables 

func Pass_FilterNextables(states *[]State) *[]INextable

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

func Pass_FindReachableEndStates 

func Pass_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func Pass_FindReachableStates 

func Pass_FindReachableStates(start State, options *FindStateOptions) *[]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 Pass_IsConstruct 

func Pass_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 Pass_PrefixStates 

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

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

func StateMachineFragment_IsConstruct 

func StateMachineFragment_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 StateMachine_IsConstruct 

func StateMachine_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 StateMachine_IsResource 

func StateMachine_IsResource(construct constructs.IConstruct) *bool

Check whether the given construct is a Resource. Experimental.

func StateTransitionMetric_Metric 

func StateTransitionMetric_Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric

Return the given named metric for the service's state transition metrics. Experimental.

func StateTransitionMetric_MetricConsumedCapacity 

func StateTransitionMetric_MetricConsumedCapacity(props *awscloudwatch.MetricOptions) awscloudwatch.Metric

Metric for the number of available state transitions per second. Experimental.

func StateTransitionMetric_MetricProvisionedBucketSize 

func StateTransitionMetric_MetricProvisionedBucketSize(props *awscloudwatch.MetricOptions) awscloudwatch.Metric

Metric for the number of available state transitions. Experimental.

func StateTransitionMetric_MetricProvisionedRefillRate 

func StateTransitionMetric_MetricProvisionedRefillRate(props *awscloudwatch.MetricOptions) awscloudwatch.Metric

Metric for the provisioned steady-state execution rate. Experimental.

func StateTransitionMetric_MetricThrottledEvents 

func StateTransitionMetric_MetricThrottledEvents(props *awscloudwatch.MetricOptions) awscloudwatch.Metric

Metric for the number of throttled state transitions. Experimental.

func State_FilterNextables 

func State_FilterNextables(states *[]State) *[]INextable

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

func State_FindReachableEndStates 

func State_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func State_FindReachableStates 

func State_FindReachableStates(start State, options *FindStateOptions) *[]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 State_IsConstruct 

func State_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 State_PrefixStates 

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

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

func Succeed_FilterNextables 

func Succeed_FilterNextables(states *[]State) *[]INextable

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

func Succeed_FindReachableEndStates 

func Succeed_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func Succeed_FindReachableStates 

func Succeed_FindReachableStates(start State, options *FindStateOptions) *[]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 Succeed_IsConstruct 

func Succeed_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 Succeed_PrefixStates 

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

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

func TaskStateBase_FilterNextables 

func TaskStateBase_FilterNextables(states *[]State) *[]INextable

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

func TaskStateBase_FindReachableEndStates 

func TaskStateBase_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func TaskStateBase_FindReachableStates 

func TaskStateBase_FindReachableStates(start State, options *FindStateOptions) *[]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 TaskStateBase_IsConstruct 

func TaskStateBase_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 TaskStateBase_PrefixStates 

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

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

func Wait_FilterNextables 

func Wait_FilterNextables(states *[]State) *[]INextable

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

func Wait_FindReachableEndStates 

func Wait_FindReachableEndStates(start State, options *FindStateOptions) *[]State

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

func Wait_FindReachableStates 

func Wait_FindReachableStates(start State, options *FindStateOptions) *[]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 Wait_IsConstruct 

func Wait_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 Wait_PrefixStates 

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

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

Types

type Activity 

type Activity interface {
	awscdk.Resource
	IActivity
	ActivityArn() *string
	ActivityName() *string
	Env() *awscdk.ResourceEnvironment
	Node() constructs.Node
	PhysicalName() *string
	Stack() awscdk.Stack
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy)
	GeneratePhysicalName() *string
	GetResourceArnAttribute(arnAttr *string, arnComponents *awscdk.ArnComponents) *string
	GetResourceNameAttribute(nameAttr *string) *string
	Grant(identity awsiam.IGrantable, actions ...*string) awsiam.Grant
	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
	ToString() *string
}

Define a new Step Functions Activity. Experimental.

func NewActivity 

func NewActivity(scope constructs.Construct, id *string, props *ActivityProps) Activity

Experimental.

type ActivityProps 

type ActivityProps struct {
	// The name for this activity.
	// Experimental.
	ActivityName *string `json:"activityName"`
}

Properties for defining a new Step Functions Activity. Experimental.

type AfterwardsOptions 

type AfterwardsOptions struct {
	// Whether to include error handling states.
	//
	// If this is true, all states which are error handlers (added through 'onError')
	// and states reachable via error handlers will be included as well.
	// Experimental.
	IncludeErrorHandlers *bool `json:"includeErrorHandlers"`
	// Whether to include the default/otherwise transition for the current Choice state.
	//
	// If this is true and the current Choice does not have a default outgoing
	// transition, one will be added included when .next() is called on the chain.
	// Experimental.
	IncludeOtherwise *bool `json:"includeOtherwise"`
}

Options for selecting the choice paths. Experimental.

type CatchProps 

type CatchProps struct {
	// Errors to recover from by going to the given state.
	//
	// A list of error strings to retry, which can be either predefined errors
	// (for example Errors.NoChoiceMatched) or a self-defined error.
	// Experimental.
	Errors *[]*string `json:"errors"`
	// JSONPath expression to indicate where to inject the error data.
	//
	// May also be the special value DISCARD, which will cause the error
	// data to be discarded.
	// Experimental.
	ResultPath *string `json:"resultPath"`
}

Error handler details. Experimental.

type CfnActivity 

type CfnActivity interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrName() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Name() *string
	SetName(val *string)
	Node() constructs.Node
	Ref() *string
	Stack() awscdk.Stack
	Tags() awscdk.TagManager
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::StepFunctions::Activity`.

func NewCfnActivity 

func NewCfnActivity(scope constructs.Construct, id *string, props *CfnActivityProps) CfnActivity

Create a new `AWS::StepFunctions::Activity`.

type CfnActivityProps 

type CfnActivityProps struct {
	// `AWS::StepFunctions::Activity.Name`.
	Name *string `json:"name"`
	// `AWS::StepFunctions::Activity.Tags`.
	Tags *[]*CfnActivity_TagsEntryProperty `json:"tags"`
}

Properties for defining a `AWS::StepFunctions::Activity`.

type CfnActivity_TagsEntryProperty 

type CfnActivity_TagsEntryProperty struct {
	// `CfnActivity.TagsEntryProperty.Key`.
	Key *string `json:"key"`
	// `CfnActivity.TagsEntryProperty.Value`.
	Value *string `json:"value"`
}

type CfnStateMachine 

type CfnStateMachine interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrArn() *string
	AttrName() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	Definition() interface{}
	SetDefinition(val interface{})
	DefinitionS3Location() interface{}
	SetDefinitionS3Location(val interface{})
	DefinitionString() *string
	SetDefinitionString(val *string)
	DefinitionSubstitutions() interface{}
	SetDefinitionSubstitutions(val interface{})
	LoggingConfiguration() interface{}
	SetLoggingConfiguration(val interface{})
	LogicalId() *string
	Node() constructs.Node
	Ref() *string
	RoleArn() *string
	SetRoleArn(val *string)
	Stack() awscdk.Stack
	StateMachineName() *string
	SetStateMachineName(val *string)
	StateMachineType() *string
	SetStateMachineType(val *string)
	Tags() awscdk.TagManager
	TracingConfiguration() interface{}
	SetTracingConfiguration(val interface{})
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::StepFunctions::StateMachine`.

func NewCfnStateMachine 

func NewCfnStateMachine(scope constructs.Construct, id *string, props *CfnStateMachineProps) CfnStateMachine

Create a new `AWS::StepFunctions::StateMachine`.

type CfnStateMachineProps 

type CfnStateMachineProps struct {
	// `AWS::StepFunctions::StateMachine.RoleArn`.
	RoleArn *string `json:"roleArn"`
	// `AWS::StepFunctions::StateMachine.Definition`.
	Definition interface{} `json:"definition"`
	// `AWS::StepFunctions::StateMachine.DefinitionS3Location`.
	DefinitionS3Location interface{} `json:"definitionS3Location"`
	// `AWS::StepFunctions::StateMachine.DefinitionString`.
	DefinitionString *string `json:"definitionString"`
	// `AWS::StepFunctions::StateMachine.DefinitionSubstitutions`.
	DefinitionSubstitutions interface{} `json:"definitionSubstitutions"`
	// `AWS::StepFunctions::StateMachine.LoggingConfiguration`.
	LoggingConfiguration interface{} `json:"loggingConfiguration"`
	// `AWS::StepFunctions::StateMachine.StateMachineName`.
	StateMachineName *string `json:"stateMachineName"`
	// `AWS::StepFunctions::StateMachine.StateMachineType`.
	StateMachineType *string `json:"stateMachineType"`
	// `AWS::StepFunctions::StateMachine.Tags`.
	Tags *[]*CfnStateMachine_TagsEntryProperty `json:"tags"`
	// `AWS::StepFunctions::StateMachine.TracingConfiguration`.
	TracingConfiguration interface{} `json:"tracingConfiguration"`
}

Properties for defining a `AWS::StepFunctions::StateMachine`.

type CfnStateMachine_CloudWatchLogsLogGroupProperty 

type CfnStateMachine_CloudWatchLogsLogGroupProperty struct {
	// `CfnStateMachine.CloudWatchLogsLogGroupProperty.LogGroupArn`.
	LogGroupArn *string `json:"logGroupArn"`
}

type CfnStateMachine_DefinitionProperty 

type CfnStateMachine_DefinitionProperty struct {
}

type CfnStateMachine_LogDestinationProperty 

type CfnStateMachine_LogDestinationProperty struct {
	// `CfnStateMachine.LogDestinationProperty.CloudWatchLogsLogGroup`.
	CloudWatchLogsLogGroup interface{} `json:"cloudWatchLogsLogGroup"`
}

type CfnStateMachine_LoggingConfigurationProperty 

type CfnStateMachine_LoggingConfigurationProperty struct {
	// `CfnStateMachine.LoggingConfigurationProperty.Destinations`.
	Destinations interface{} `json:"destinations"`
	// `CfnStateMachine.LoggingConfigurationProperty.IncludeExecutionData`.
	IncludeExecutionData interface{} `json:"includeExecutionData"`
	// `CfnStateMachine.LoggingConfigurationProperty.Level`.
	Level *string `json:"level"`
}

type CfnStateMachine_S3LocationProperty 

type CfnStateMachine_S3LocationProperty struct {
	// `CfnStateMachine.S3LocationProperty.Bucket`.
	Bucket *string `json:"bucket"`
	// `CfnStateMachine.S3LocationProperty.Key`.
	Key *string `json:"key"`
	// `CfnStateMachine.S3LocationProperty.Version`.
	Version *string `json:"version"`
}

type CfnStateMachine_TagsEntryProperty 

type CfnStateMachine_TagsEntryProperty struct {
	// `CfnStateMachine.TagsEntryProperty.Key`.
	Key *string `json:"key"`
	// `CfnStateMachine.TagsEntryProperty.Value`.
	Value *string `json:"value"`
}

type CfnStateMachine_TracingConfigurationProperty 

type CfnStateMachine_TracingConfigurationProperty struct {
	// `CfnStateMachine.TracingConfigurationProperty.Enabled`.
	Enabled interface{} `json:"enabled"`
}

type Chain 

type Chain interface {
	IChainable
	EndStates() *[]INextable
	Id() *string
	StartState() State
	Next(next IChainable) Chain
	ToSingleState(id *string, props *ParallelProps) Parallel
}

A collection of states to chain onto.

A Chain has a start and zero or more chainable ends. If there are zero ends, calling next() on the Chain will fail. Experimental.

func Chain_Custom 

func Chain_Custom(startState State, endStates *[]INextable, lastAdded IChainable) Chain

Make a Chain with specific start and end states, and a last-added Chainable. Experimental.

func Chain_Sequence 

func Chain_Sequence(start IChainable, next IChainable) Chain

Make a Chain with the start from one chain and the ends from another. Experimental.

func Chain_Start 

func Chain_Start(state IChainable) Chain

Begin a new Chain from one chainable. Experimental.

type Choice 

type Choice interface {
	State
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	Afterwards(options *AfterwardsOptions) Chain
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next State)
	Otherwise(def IChainable) Choice
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	When(condition Condition, next IChainable) Choice
	WhenBoundToGraph(graph StateGraph)
}

Define a Choice in the state machine.

A choice state can be used to make decisions based on the execution state. Experimental.

func NewChoice 

func NewChoice(scope constructs.Construct, id *string, props *ChoiceProps) Choice

Experimental.

type ChoiceProps 

type ChoiceProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// JSONPath expression to select part of the state to be the input to this state.
	//
	// May also be the special value DISCARD, which will cause the effective
	// input to be the empty object {}.
	// Experimental.
	InputPath *string `json:"inputPath"`
	// JSONPath expression to select part of the state to be the output to this state.
	//
	// May also be the special value DISCARD, which will cause the effective
	// output to be the empty object {}.
	// Experimental.
	OutputPath *string `json:"outputPath"`
}

Properties for defining a Choice state. Experimental.

type Condition 

type Condition interface {
	RenderCondition() interface{}
}

A Condition for use in a Choice state branch. Experimental.

func Condition_And 

func Condition_And(conditions ...Condition) Condition

Combine two or more conditions with a logical AND. Experimental.

func Condition_BooleanEquals 

func Condition_BooleanEquals(variable *string, value *bool) Condition

Matches if a boolean field has the given value. Experimental.

func Condition_BooleanEqualsJsonPath 

func Condition_BooleanEqualsJsonPath(variable *string, value *string) Condition

Matches if a boolean field equals to a value at a given mapping path. Experimental.

func Condition_IsBoolean 

func Condition_IsBoolean(variable *string) Condition

Matches if variable is boolean. Experimental.

func Condition_IsNotBoolean 

func Condition_IsNotBoolean(variable *string) Condition

Matches if variable is not boolean. Experimental.

func Condition_IsNotNull 

func Condition_IsNotNull(variable *string) Condition

Matches if variable is not null. Experimental.

func Condition_IsNotNumeric 

func Condition_IsNotNumeric(variable *string) Condition

Matches if variable is not numeric. Experimental.

func Condition_IsNotPresent 

func Condition_IsNotPresent(variable *string) Condition

Matches if variable is not present. Experimental.

func Condition_IsNotString 

func Condition_IsNotString(variable *string) Condition

Matches if variable is not a string. Experimental.

func Condition_IsNotTimestamp 

func Condition_IsNotTimestamp(variable *string) Condition

Matches if variable is not a timestamp. Experimental.

func Condition_IsNull 

func Condition_IsNull(variable *string) Condition

Matches if variable is Null. Experimental.

func Condition_IsNumeric 

func Condition_IsNumeric(variable *string) Condition

Matches if variable is numeric. Experimental.

func Condition_IsPresent 

func Condition_IsPresent(variable *string) Condition

Matches if variable is present. Experimental.

func Condition_IsString 

func Condition_IsString(variable *string) Condition

Matches if variable is a string. Experimental.

func Condition_IsTimestamp 

func Condition_IsTimestamp(variable *string) Condition

Matches if variable is a timestamp. Experimental.

func Condition_Not 

func Condition_Not(condition Condition) Condition

Negate a condition. Experimental.

func Condition_NumberEquals 

func Condition_NumberEquals(variable *string, value *float64) Condition

Matches if a numeric field has the given value. Experimental.

func Condition_NumberEqualsJsonPath 

func Condition_NumberEqualsJsonPath(variable *string, value *string) Condition

Matches if a numeric field has the value in a given mapping path. Experimental.

func Condition_NumberGreaterThan 

func Condition_NumberGreaterThan(variable *string, value *float64) Condition

Matches if a numeric field is greater than the given value. Experimental.

func Condition_NumberGreaterThanEquals 

func Condition_NumberGreaterThanEquals(variable *string, value *float64) Condition

Matches if a numeric field is greater than or equal to the given value. Experimental.

func Condition_NumberGreaterThanEqualsJsonPath 

func Condition_NumberGreaterThanEqualsJsonPath(variable *string, value *string) Condition

Matches if a numeric field is greater than or equal to the value at a given mapping path. Experimental.

func Condition_NumberGreaterThanJsonPath 

func Condition_NumberGreaterThanJsonPath(variable *string, value *string) Condition

Matches if a numeric field is greater than the value at a given mapping path. Experimental.

func Condition_NumberLessThan 

func Condition_NumberLessThan(variable *string, value *float64) Condition

Matches if a numeric field is less than the given value. Experimental.

func Condition_NumberLessThanEquals 

func Condition_NumberLessThanEquals(variable *string, value *float64) Condition

Matches if a numeric field is less than or equal to the given value. Experimental.

func Condition_NumberLessThanEqualsJsonPath 

func Condition_NumberLessThanEqualsJsonPath(variable *string, value *string) Condition

Matches if a numeric field is less than or equal to the numeric value at given mapping path. Experimental.

func Condition_NumberLessThanJsonPath 

func Condition_NumberLessThanJsonPath(variable *string, value *string) Condition

Matches if a numeric field is less than the value at the given mapping path. Experimental.

func Condition_Or 

func Condition_Or(conditions ...Condition) Condition

Combine two or more conditions with a logical OR. Experimental.

func Condition_StringEquals 

func Condition_StringEquals(variable *string, value *string) Condition

Matches if a string field has the given value. Experimental.

func Condition_StringEqualsJsonPath 

func Condition_StringEqualsJsonPath(variable *string, value *string) Condition

Matches if a string field equals to a value at a given mapping path. Experimental.

func Condition_StringGreaterThan 

func Condition_StringGreaterThan(variable *string, value *string) Condition

Matches if a string field sorts after a given value. Experimental.

func Condition_StringGreaterThanEquals 

func Condition_StringGreaterThanEquals(variable *string, value *string) Condition

Matches if a string field sorts after or equal to a given value. Experimental.

func Condition_StringGreaterThanEqualsJsonPath 

func Condition_StringGreaterThanEqualsJsonPath(variable *string, value *string) Condition

Matches if a string field sorts after or equal to value at a given mapping path. Experimental.

func Condition_StringGreaterThanJsonPath 

func Condition_StringGreaterThanJsonPath(variable *string, value *string) Condition

Matches if a string field sorts after a value at a given mapping path. Experimental.

func Condition_StringLessThan 

func Condition_StringLessThan(variable *string, value *string) Condition

Matches if a string field sorts before a given value. Experimental.

func Condition_StringLessThanEquals 

func Condition_StringLessThanEquals(variable *string, value *string) Condition

Matches if a string field sorts equal to or before a given value. Experimental.

func Condition_StringLessThanEqualsJsonPath 

func Condition_StringLessThanEqualsJsonPath(variable *string, value *string) Condition

Matches if a string field sorts equal to or before a given mapping. Experimental.

func Condition_StringLessThanJsonPath 

func Condition_StringLessThanJsonPath(variable *string, value *string) Condition

Matches if a string field sorts before a given value at a particular mapping. Experimental.

func Condition_StringMatches 

func Condition_StringMatches(variable *string, value *string) Condition

Matches if a field matches a string pattern that can contain a wild card (*) e.g: log-*.txt or *LATEST*. No other characters other than "*" have any special meaning - * can be escaped: \\*. Experimental.

func Condition_TimestampEquals 

func Condition_TimestampEquals(variable *string, value *string) Condition

Matches if a timestamp field is the same time as the given timestamp. Experimental.

func Condition_TimestampEqualsJsonPath 

func Condition_TimestampEqualsJsonPath(variable *string, value *string) Condition

Matches if a timestamp field is the same time as the timestamp at a given mapping path. Experimental.

func Condition_TimestampGreaterThan 

func Condition_TimestampGreaterThan(variable *string, value *string) Condition

Matches if a timestamp field is after the given timestamp. Experimental.

func Condition_TimestampGreaterThanEquals 

func Condition_TimestampGreaterThanEquals(variable *string, value *string) Condition

Matches if a timestamp field is after or equal to the given timestamp. Experimental.

func Condition_TimestampGreaterThanEqualsJsonPath 

func Condition_TimestampGreaterThanEqualsJsonPath(variable *string, value *string) Condition

Matches if a timestamp field is after or equal to the timestamp at a given mapping path. Experimental.

func Condition_TimestampGreaterThanJsonPath 

func Condition_TimestampGreaterThanJsonPath(variable *string, value *string) Condition

Matches if a timestamp field is after the timestamp at a given mapping path. Experimental.

func Condition_TimestampLessThan 

func Condition_TimestampLessThan(variable *string, value *string) Condition

Matches if a timestamp field is before the given timestamp. Experimental.

func Condition_TimestampLessThanEquals 

func Condition_TimestampLessThanEquals(variable *string, value *string) Condition

Matches if a timestamp field is before or equal to the given timestamp. Experimental.

func Condition_TimestampLessThanEqualsJsonPath 

func Condition_TimestampLessThanEqualsJsonPath(variable *string, value *string) Condition

Matches if a timestamp field is before or equal to the timestamp at a given mapping path. Experimental.

func Condition_TimestampLessThanJsonPath 

func Condition_TimestampLessThanJsonPath(variable *string, value *string) Condition

Matches if a timestamp field is before the timestamp at a given mapping path. Experimental.

type CustomState 

type CustomState interface {
	State
	IChainable
	INextable
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next State)
	Next(next IChainable) Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

State defined by supplying Amazon States Language (ASL) in the state machine. Experimental.

func NewCustomState 

func NewCustomState(scope constructs.Construct, id *string, props *CustomStateProps) CustomState

Experimental.

type CustomStateProps 

type CustomStateProps struct {
	// Amazon States Language (JSON-based) definition of the state.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/concepts-amazon-states-language.html
	//
	// Experimental.
	StateJson *map[string]interface{} `json:"stateJson"`
}

Properties for defining a custom state definition. Experimental.

type Errors 

type Errors interface {
}

Predefined error strings Error names in Amazon States Language - https://states-language.net/spec.html#appendix-a Error handling in Step Functions - https://docs.aws.amazon.com/step-functions/latest/dg/concepts-error-handling.html. Experimental.

func NewErrors 

func NewErrors() Errors

Experimental.

type Fail 

type Fail interface {
	State
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next State)
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Define a Fail state in the state machine.

Reaching a Fail state terminates the state execution in failure. Experimental.

func NewFail 

func NewFail(scope constructs.Construct, id *string, props *FailProps) Fail

Experimental.

type FailProps 

type FailProps struct {
	// A description for the cause of the failure.
	// Experimental.
	Cause *string `json:"cause"`
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// Error code used to represent this failure.
	// Experimental.
	Error *string `json:"error"`
}

Properties for defining a Fail state. Experimental.

type FieldUtils 

type FieldUtils interface {
}

Helper functions to work with structures containing fields. Experimental.

type FindStateOptions 

type FindStateOptions struct {
	// Whether or not to follow error-handling transitions.
	// Experimental.
	IncludeErrorHandlers *bool `json:"includeErrorHandlers"`
}

Options for finding reachable states. Experimental.

type IActivity 

type IActivity interface {
	awscdk.IResource
	// The ARN of the activity.
	// Experimental.
	ActivityArn() *string
	// The name of the activity.
	// Experimental.
	ActivityName() *string
}

Represents a Step Functions Activity https://docs.aws.amazon.com/step-functions/latest/dg/concepts-activities.html. Experimental.

func Activity_FromActivityArn 

func Activity_FromActivityArn(scope constructs.Construct, id *string, activityArn *string) IActivity

Construct an Activity from an existing Activity ARN. Experimental.

func Activity_FromActivityName 

func Activity_FromActivityName(scope constructs.Construct, id *string, activityName *string) IActivity

Construct an Activity from an existing Activity Name. Experimental.

type IChainable 

type IChainable interface {
	// The chainable end state(s) of this chainable.
	// Experimental.
	EndStates() *[]INextable
	// Descriptive identifier for this chainable.
	// Experimental.
	Id() *string
	// The start state of this chainable.
	// Experimental.
	StartState() State
}

Interface for objects that can be used in a Chain. Experimental.

type INextable 

type INextable interface {
	// Go to the indicated state after this state.
	//
	// Returns: The chain of states built up
	// Experimental.
	Next(state IChainable) Chain
}

Interface for states that can have 'next' states. Experimental.

type IStateMachine 

type IStateMachine interface {
	awsiam.IGrantable
	awscdk.IResource
	// Grant the given identity custom permissions.
	// Experimental.
	Grant(identity awsiam.IGrantable, actions ...*string) awsiam.Grant
	// Grant the given identity permissions for all executions of a state machine.
	// Experimental.
	GrantExecution(identity awsiam.IGrantable, actions ...*string) awsiam.Grant
	// Grant the given identity read permissions for this state machine.
	// Experimental.
	GrantRead(identity awsiam.IGrantable) awsiam.Grant
	// Grant the given identity permissions to start an execution of this state machine.
	// Experimental.
	GrantStartExecution(identity awsiam.IGrantable) awsiam.Grant
	// Grant the given identity read permissions for this state machine.
	// Experimental.
	GrantTaskResponse(identity awsiam.IGrantable) awsiam.Grant
	// Return the given named metric for this State Machine's executions.
	// Experimental.
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of executions that were aborted.
	// Experimental.
	MetricAborted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of executions that failed.
	// Experimental.
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of executions that were started.
	// Experimental.
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of executions that succeeded.
	// Experimental.
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of executions that were throttled.
	// Experimental.
	MetricThrottled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the interval, in milliseconds, between the time the execution starts and the time it closes.
	// Experimental.
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of executions that timed out.
	// Experimental.
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// The ARN of the state machine.
	// Experimental.
	StateMachineArn() *string
}

A State Machine. Experimental.

func StateMachine_FromStateMachineArn 

func StateMachine_FromStateMachineArn(scope constructs.Construct, id *string, stateMachineArn *string) IStateMachine

Import a state machine. Experimental.

type InputType 

type InputType string

The type of task input. Experimental. 

const (
	InputType_TEXT   InputType = "TEXT"
	InputType_OBJECT InputType = "OBJECT"
)

type IntegrationPattern 

type IntegrationPattern string

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

Experimental. 

const (
	IntegrationPattern_REQUEST_RESPONSE    IntegrationPattern = "REQUEST_RESPONSE"
	IntegrationPattern_RUN_JOB             IntegrationPattern = "RUN_JOB"
	IntegrationPattern_WAIT_FOR_TASK_TOKEN IntegrationPattern = "WAIT_FOR_TASK_TOKEN"
)

type JsonPath 

type JsonPath interface {
}

Extract a field from the State Machine data or context that gets passed around between states. See: https://docs.aws.amazon.com/step-functions/latest/dg/amazon-states-language-paths.html

Experimental.

type LogLevel 

type LogLevel string

Defines which category of execution history events are logged. See: https://docs.aws.amazon.com/step-functions/latest/dg/cloudwatch-log-level.html

Experimental. 

const (
	LogLevel_OFF   LogLevel = "OFF"
	LogLevel_ALL   LogLevel = "ALL"
	LogLevel_ERROR LogLevel = "ERROR"
	LogLevel_FATAL LogLevel = "FATAL"
)

type LogOptions 

type LogOptions struct {
	// The log group where the execution history events will be logged.
	// Experimental.
	Destination awslogs.ILogGroup `json:"destination"`
	// Determines whether execution data is included in your log.
	// Experimental.
	IncludeExecutionData *bool `json:"includeExecutionData"`
	// Defines which category of execution history events are logged.
	// Experimental.
	Level LogLevel `json:"level"`
}

Defines what execution history events are logged and where they are logged. Experimental.

type Map 

type Map interface {
	State
	INextable
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddCatch(handler IChainable, props *CatchProps) Map
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	AddRetry(props *RetryProps) Map
	BindToGraph(graph StateGraph)
	Iterator(iterator IChainable) Map
	MakeDefault(def State)
	MakeNext(next State)
	Next(next IChainable) Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Define a Map state in the state machine.

A `Map` state can be used to run a set of steps for each element of an input array. A Map state will execute the same steps for multiple entries of an array in the state input.

While the Parallel state executes multiple branches of steps using the same input, a Map state will execute the same steps for multiple entries of an array in the state input. See: https://docs.aws.amazon.com/step-functions/latest/dg/amazon-states-language-map-state.html

Experimental.

func NewMap 

func NewMap(scope constructs.Construct, id *string, props *MapProps) Map

Experimental.

type MapProps 

type MapProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// 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"`
	// JSONPath expression to select the array to iterate over.
	// Experimental.
	ItemsPath *string `json:"itemsPath"`
	// MaxConcurrency.
	//
	// An upper bound on the number of iterations you want running at once.
	// Experimental.
	MaxConcurrency *float64 `json:"maxConcurrency"`
	// JSONPath expression to select part of the state to be the output to this 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"`
	// The JSON that you want to override your default iteration input.
	// Experimental.
	Parameters *map[string]interface{} `json:"parameters"`
	// 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"`
	// The JSON that will replace the state's raw result and become the effective result before ResultPath is applied.
	//
	// You can use ResultSelector to create a payload with values that are static
	// or selected from the state's raw result.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html#input-output-resultselector
	//
	// Experimental.
	ResultSelector *map[string]interface{} `json:"resultSelector"`
}

Properties for defining a Map state. Experimental.

type Parallel 

type Parallel interface {
	State
	INextable
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddCatch(handler IChainable, props *CatchProps) Parallel
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	AddRetry(props *RetryProps) Parallel
	BindToGraph(graph StateGraph)
	Branch(branches ...IChainable) Parallel
	MakeDefault(def State)
	MakeNext(next State)
	Next(next IChainable) Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Define a Parallel state in the state machine.

A Parallel state can be used to run one or more state machines at the same time.

The Result of a Parallel state is an array of the results of its substatemachines. Experimental.

func NewParallel 

func NewParallel(scope constructs.Construct, id *string, props *ParallelProps) Parallel

Experimental.

type ParallelProps 

type ParallelProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// 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"`
	// JSONPath expression to select part of the state to be the output to this 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"`
	// The JSON that will replace the state's raw result and become the effective result before ResultPath is applied.
	//
	// You can use ResultSelector to create a payload with values that are static
	// or selected from the state's raw result.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html#input-output-resultselector
	//
	// Experimental.
	ResultSelector *map[string]interface{} `json:"resultSelector"`
}

Properties for defining a Parallel state. Experimental.

type Pass 

type Pass interface {
	State
	INextable
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next State)
	Next(next IChainable) Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Define a Pass in the state machine.

A Pass state can be used to transform the current exeuction's state. Experimental.

func NewPass 

func NewPass(scope constructs.Construct, id *string, props *PassProps) Pass

Experimental.

type PassProps 

type PassProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// 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"`
	// JSONPath expression to select part of the state to be the output to this 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"`
	// Parameters pass a collection of key-value pairs, either static values or JSONPath expressions that select from the input.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html#input-output-parameters
	//
	// Experimental.
	Parameters *map[string]interface{} `json:"parameters"`
	// If given, treat as the result of this operation.
	//
	// Can be used to inject or replace the current execution state.
	// Experimental.
	Result Result `json:"result"`
	// 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"`
}

Properties for defining a Pass state. Experimental.

type Result 

type Result interface {
	Value() interface{}
}

The result of a Pass operation. Experimental.

func NewResult 

func NewResult(value interface{}) Result

Experimental.

func Result_FromArray 

func Result_FromArray(value *[]interface{}) Result

The result of the operation is an array. Experimental.

func Result_FromBoolean 

func Result_FromBoolean(value *bool) Result

The result of the operation is a boolean. Experimental.

func Result_FromNumber 

func Result_FromNumber(value *float64) Result

The result of the operation is a number. Experimental.

func Result_FromObject 

func Result_FromObject(value *map[string]interface{}) Result

The result of the operation is an object. Experimental.

func Result_FromString 

func Result_FromString(value *string) Result

The result of the operation is a string. Experimental.

type RetryProps 

type RetryProps struct {
	// Multiplication for how much longer the wait interval gets on every retry.
	// Experimental.
	BackoffRate *float64 `json:"backoffRate"`
	// Errors to retry.
	//
	// A list of error strings to retry, which can be either predefined errors
	// (for example Errors.NoChoiceMatched) or a self-defined error.
	// Experimental.
	Errors *[]*string `json:"errors"`
	// How many seconds to wait initially before retrying.
	// Experimental.
	Interval awscdk.Duration `json:"interval"`
	// How many times to retry this particular error.
	//
	// May be 0 to disable retry for specific errors (in case you have
	// a catch-all retry policy).
	// Experimental.
	MaxAttempts *float64 `json:"maxAttempts"`
}

Retry details. Experimental.

type ServiceIntegrationPattern 

type ServiceIntegrationPattern string

Three ways to call an integrated service: Request Response, Run a Job and Wait for a Callback with Task Token. See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html

Here, they are named as FIRE_AND_FORGET, SYNC and WAIT_FOR_TASK_TOKEN respectfully.

Experimental. 

const (
	ServiceIntegrationPattern_FIRE_AND_FORGET     ServiceIntegrationPattern = "FIRE_AND_FORGET"
	ServiceIntegrationPattern_SYNC                ServiceIntegrationPattern = "SYNC"
	ServiceIntegrationPattern_WAIT_FOR_TASK_TOKEN ServiceIntegrationPattern = "WAIT_FOR_TASK_TOKEN"
)

type SingleStateOptions 

type SingleStateOptions struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// 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"`
	// JSONPath expression to select part of the state to be the output to this 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"`
	// The JSON that will replace the state's raw result and become the effective result before ResultPath is applied.
	//
	// You can use ResultSelector to create a payload with values that are static
	// or selected from the state's raw result.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html#input-output-resultselector
	//
	// Experimental.
	ResultSelector *map[string]interface{} `json:"resultSelector"`
	// String to prefix all stateIds in the state machine with.
	// Experimental.
	PrefixStates *string `json:"prefixStates"`
	// ID of newly created containing state.
	// Experimental.
	StateId *string `json:"stateId"`
}

Options for creating a single state. Experimental.

type State 

type State interface {
	constructs.Construct
	IChainable
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next State)
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Base class for all other state classes. Experimental.

type StateGraph 

type StateGraph interface {
	PolicyStatements() *[]awsiam.PolicyStatement
	StartState() State
	Timeout() awscdk.Duration
	SetTimeout(val awscdk.Duration)
	RegisterPolicyStatement(statement awsiam.PolicyStatement)
	RegisterState(state State)
	RegisterSuperGraph(graph StateGraph)
	ToGraphJson() *map[string]interface{}
	ToString() *string
}

A collection of connected states.

A StateGraph is used to keep track of all states that are connected (have transitions between them). It does not include the substatemachines in a Parallel's branches: those are their own StateGraphs, but the graphs themselves have a hierarchical relationship as well.

By assigning states to a definitive StateGraph, we verify that no state machines are constructed. In particular:

  • Every state object can only ever be in 1 StateGraph, and not inadvertently be used in two graphs.
  • Every stateId must be unique across all states in the entire state machine.

All policy statements in all states in all substatemachines are bubbled so that the top-level StateMachine instantiation can read them all and add them to the IAM Role.

You do not need to instantiate this class; it is used internally. Experimental.

func NewStateGraph 

func NewStateGraph(startState State, graphDescription *string) StateGraph

Experimental.

type StateMachine 

type StateMachine interface {
	awscdk.Resource
	IStateMachine
	Env() *awscdk.ResourceEnvironment
	GrantPrincipal() awsiam.IPrincipal
	Node() constructs.Node
	PhysicalName() *string
	Role() awsiam.IRole
	Stack() awscdk.Stack
	StateMachineArn() *string
	StateMachineName() *string
	StateMachineType() StateMachineType
	AddToRolePolicy(statement awsiam.PolicyStatement)
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy)
	GeneratePhysicalName() *string
	GetResourceArnAttribute(arnAttr *string, arnComponents *awscdk.ArnComponents) *string
	GetResourceNameAttribute(nameAttr *string) *string
	Grant(identity awsiam.IGrantable, actions ...*string) awsiam.Grant
	GrantExecution(identity awsiam.IGrantable, actions ...*string) awsiam.Grant
	GrantRead(identity awsiam.IGrantable) awsiam.Grant
	GrantStartExecution(identity awsiam.IGrantable) awsiam.Grant
	GrantTaskResponse(identity awsiam.IGrantable) awsiam.Grant
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricAborted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricFailed(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricStarted(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricSucceeded(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricThrottled(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTime(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricTimedOut(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	ToString() *string
}

Define a StepFunctions State Machine. Experimental.

func NewStateMachine 

func NewStateMachine(scope constructs.Construct, id *string, props *StateMachineProps) StateMachine

Experimental.

type StateMachineFragment 

type StateMachineFragment interface {
	constructs.Construct
	IChainable
	EndStates() *[]INextable
	Id() *string
	Node() constructs.Node
	StartState() State
	Next(next IChainable) Chain
	PrefixStates(prefix *string) StateMachineFragment
	ToSingleState(options *SingleStateOptions) Parallel
	ToString() *string
}

Base class for reusable state machine fragments. Experimental.

type StateMachineProps 

type StateMachineProps struct {
	// Definition for this state machine.
	// Experimental.
	Definition IChainable `json:"definition"`
	// Defines what execution history events are logged and where they are logged.
	// Experimental.
	Logs *LogOptions `json:"logs"`
	// The execution role for the state machine service.
	// Experimental.
	Role awsiam.IRole `json:"role"`
	// A name for the state machine.
	// Experimental.
	StateMachineName *string `json:"stateMachineName"`
	// Type of the state machine.
	// Experimental.
	StateMachineType StateMachineType `json:"stateMachineType"`
	// Maximum run time for this state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
	// Specifies whether Amazon X-Ray tracing is enabled for this state machine.
	// Experimental.
	TracingEnabled *bool `json:"tracingEnabled"`
}

Properties for defining a State Machine. Experimental.

type StateMachineType 

type StateMachineType string

Two types of state machines are available in AWS Step Functions: EXPRESS AND STANDARD. See: https://docs.aws.amazon.com/step-functions/latest/dg/concepts-standard-vs-express.html

Experimental. 

const (
	StateMachineType_EXPRESS  StateMachineType = "EXPRESS"
	StateMachineType_STANDARD StateMachineType = "STANDARD"
)

type StateProps 

type StateProps struct {
	// A comment describing this state.
	// Experimental.
	Comment *string `json:"comment"`
	// 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"`
	// JSONPath expression to select part of the state to be the output to this 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"`
	// Parameters pass a collection of key-value pairs, either static values or JSONPath expressions that select from the input.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html#input-output-parameters
	//
	// Experimental.
	Parameters *map[string]interface{} `json:"parameters"`
	// 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"`
	// The JSON that will replace the state's raw result and become the effective result before ResultPath is applied.
	//
	// You can use ResultSelector to create a payload with values that are static
	// or selected from the state's raw result.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html#input-output-resultselector
	//
	// Experimental.
	ResultSelector *map[string]interface{} `json:"resultSelector"`
}

Properties shared by all states. Experimental.

type StateTransitionMetric 

type StateTransitionMetric interface {
}

Metrics on the rate limiting performed on state machine execution.

These rate limits are shared across all state machines. Experimental.

func NewStateTransitionMetric 

func NewStateTransitionMetric() StateTransitionMetric

Experimental.

type Succeed 

type Succeed interface {
	State
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next State)
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Define a Succeed state in the state machine.

Reaching a Succeed state terminates the state execution in success. Experimental.

func NewSucceed 

func NewSucceed(scope constructs.Construct, id *string, props *SucceedProps) Succeed

Experimental.

type SucceedProps 

type SucceedProps struct {
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
	// 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"`
	// JSONPath expression to select part of the state to be the output to this 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"`
}

Properties for defining a Succeed state. Experimental.

type TaskInput 

type TaskInput interface {
	Type() InputType
	Value() interface{}
}

Type union for task classes that accept multiple types of payload. Experimental.

func TaskInput_FromJsonPathAt 

func TaskInput_FromJsonPathAt(path *string) TaskInput

Use a part of the execution data or task context as task input.

Use this when you want to use a subobject or string from the current state machine execution or the current task context as complete payload to a task. Experimental.

func TaskInput_FromObject 

func TaskInput_FromObject(obj *map[string]interface{}) TaskInput

Use an object as task input.

This object may contain JSON path fields as object values, if desired. Experimental.

func TaskInput_FromText 

func TaskInput_FromText(text *string) TaskInput

Use a literal string as task input.

This might be a JSON-encoded object, or just a text. Experimental.

type TaskMetricsConfig 

type TaskMetricsConfig struct {
	// The dimensions to attach to metrics.
	// Experimental.
	MetricDimensions *map[string]interface{} `json:"metricDimensions"`
	// Prefix for plural metric names of activity actions.
	// Experimental.
	MetricPrefixPlural *string `json:"metricPrefixPlural"`
	// Prefix for singular metric names of activity actions.
	// Experimental.
	MetricPrefixSingular *string `json:"metricPrefixSingular"`
}

Task Metrics. Experimental.

type TaskStateBase 

type TaskStateBase interface {
	State
	INextable
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	TaskMetrics() *TaskMetricsConfig
	TaskPolicies() *[]awsiam.PolicyStatement
	AddBranch(branch StateGraph)
	AddCatch(handler IChainable, props *CatchProps) TaskStateBase
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	AddRetry(props *RetryProps) TaskStateBase
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next 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 IChainable) Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Define a Task state in the state machine.

Reaching a Task state causes some work to be executed, represented by the Task's resource property. Task constructs represent a generic Amazon States Language Task.

For some resource types, more specific subclasses of Task may be available which are more convenient to use. Experimental.

type TaskStateBaseProps 

type TaskStateBaseProps 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 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"`
	// The JSON that will replace the state's raw result and become the effective result before ResultPath is applied.
	//
	// You can use ResultSelector to create a payload with values that are static
	// or selected from the state's raw result.
	// See: https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html#input-output-resultselector
	//
	// Experimental.
	ResultSelector *map[string]interface{} `json:"resultSelector"`
	// Timeout for the state machine.
	// Experimental.
	Timeout awscdk.Duration `json:"timeout"`
}

Props that are common to all tasks. Experimental.

type Wait 

type Wait interface {
	State
	INextable
	Branches() *[]StateGraph
	Comment() *string
	DefaultChoice() State
	SetDefaultChoice(val State)
	EndStates() *[]INextable
	Id() *string
	InputPath() *string
	Iteration() StateGraph
	SetIteration(val StateGraph)
	Node() constructs.Node
	OutputPath() *string
	Parameters() *map[string]interface{}
	ResultPath() *string
	ResultSelector() *map[string]interface{}
	StartState() State
	StateId() *string
	AddBranch(branch StateGraph)
	AddChoice(condition Condition, next State)
	AddIterator(iteration StateGraph)
	AddPrefix(x *string)
	BindToGraph(graph StateGraph)
	MakeDefault(def State)
	MakeNext(next State)
	Next(next IChainable) Chain
	RenderBranches() interface{}
	RenderChoices() interface{}
	RenderInputOutput() interface{}
	RenderIterator() interface{}
	RenderNextEnd() interface{}
	RenderResultSelector() interface{}
	RenderRetryCatch() interface{}
	ToStateJson() *map[string]interface{}
	ToString() *string
	ValidateState() *[]*string
	WhenBoundToGraph(graph StateGraph)
}

Define a Wait state in the state machine.

A Wait state can be used to delay execution of the state machine for a while. Experimental.

func NewWait 

func NewWait(scope constructs.Construct, id *string, props *WaitProps) Wait

Experimental.

type WaitProps 

type WaitProps struct {
	// Wait duration.
	// Experimental.
	Time WaitTime `json:"time"`
	// An optional description for this state.
	// Experimental.
	Comment *string `json:"comment"`
}

Properties for defining a Wait state. Experimental.

type WaitTime 

type WaitTime interface {
}

Represents the Wait state which delays a state machine from continuing for a specified time. See: https://docs.aws.amazon.com/step-functions/latest/dg/amazon-states-language-wait-state.html

Experimental.

func WaitTime_Duration 

func WaitTime_Duration(duration awscdk.Duration) WaitTime

Wait a fixed amount of time. Experimental.

func WaitTime_SecondsPath 

func WaitTime_SecondsPath(path *string) WaitTime

Wait for a number of seconds stored in the state object.

TODO: EXAMPLE

Experimental.

func WaitTime_Timestamp 

func WaitTime_Timestamp(timestamp *string) WaitTime

Wait until the given ISO8601 timestamp.

TODO: EXAMPLE

Experimental.

func WaitTime_TimestampPath 

func WaitTime_TimestampPath(path *string) WaitTime

Wait until a timestamp found in the state object.

TODO: EXAMPLE

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.