step

package

Go to main page

Versions in this module

v1

v1.15.0

May 3, 2020

Changes in this version

type StateMachine

+ func NewExpressStateMachine(stateMachineName string, ...) *StateMachine

type WaitDynamicUntil

+ SecondsPath string

+ func NewDynamicWaitDurationState(stateName string, secondsPath string) *WaitDynamicUntil

v1.13.0

Nov 30, 2019

v1.12.0

Oct 12, 2019

Changes in this version

+ type MapState struct

+ Catchers []*TaskCatch

+ ItemsPath string

+ MaxConcurrency int

+ Parameters map[string]interface{}

+ ResultPath string

+ Retriers []*TaskRetry

+ States *StateMachine

+ func NewMapState(parallelStateName string, states *StateMachine) *MapState

+ func (ms *MapState) AdjacentStates() []MachineState

+ func (ms *MapState) MarshalJSON() ([]byte, error)

+ func (ms *MapState) Name() string

+ func (ms *MapState) Next(nextState MachineState) MachineState

+ func (ms *MapState) WithCatchers(catch ...*TaskCatch) *MapState

+ func (ms *MapState) WithComment(comment string) TransitionState

+ func (ms *MapState) WithInputPath(inputPath string) TransitionState

+ func (ms *MapState) WithOutputPath(outputPath string) TransitionState

+ func (ms *MapState) WithResultPath(resultPath string) *MapState

+ func (ms *MapState) WithRetriers(retries ...*TaskRetry) *MapState

type ParallelState

+ Branches []*StateMachine

+ Parameters map[string]interface{}

v1.10.0

Aug 12, 2019

v1.9.4

Jul 27, 2019

v1.9.3

Jun 3, 2019

v1.9.2

Feb 17, 2019

v1.9.1

Feb 3, 2019

v1.9.0

Jan 21, 2019

v1.8.0

Dec 16, 2018

Changes in this version

+ type BaseTask struct

+ Catchers []*TaskCatch

+ HeartbeatSeconds time.Duration

+ LambdaDecorator sparta.TemplateDecorator

+ ResultPath string

+ Retriers []*TaskRetry

+ TimeoutSeconds time.Duration

+ func (bt *BaseTask) AdjacentStates() []MachineState

+ func (bt *BaseTask) MarshalJSON() ([]byte, error)

+ func (bt *BaseTask) Name() string

+ func (bt *BaseTask) Next(nextState MachineState) MachineState

+ func (bt *BaseTask) WithCatchers(catch ...*TaskCatch) *BaseTask

+ func (bt *BaseTask) WithComment(comment string) TransitionState

+ func (bt *BaseTask) WithHeartbeat(pulse time.Duration) *BaseTask

+ func (bt *BaseTask) WithInputPath(inputPath string) TransitionState

+ func (bt *BaseTask) WithOutputPath(outputPath string) TransitionState

+ func (bt *BaseTask) WithResultPath(resultPath string) *BaseTask

+ func (bt *BaseTask) WithRetriers(retries ...*TaskRetry) *BaseTask

+ func (bt *BaseTask) WithTimeout(timeout time.Duration) *BaseTask

+ type BatchTaskParameters struct

+ ArrayProperties map[string]interface{}

+ ContainerOverrides map[string]interface{}

+ DependsOn []map[string]interface{}

+ JobDefinition gocf.Stringable

+ JobName string

+ JobQueue gocf.Stringable

+ Parameters map[string]string

+ RetryStrategy map[string]interface{}

+ Timeout map[string]interface{}

+ type BatchTaskState struct

+ func NewBatchTaskState(stateName string, parameters BatchTaskParameters) *BatchTaskState

+ func (bts *BatchTaskState) MarshalJSON() ([]byte, error)

+ type DynamoDBGetItemParameters struct

+ AttributesToGet []string

+ ConsistentRead bool

+ ExpressionAttributeNames map[string]string

+ Key map[string]*dynamodb.AttributeValue

+ ProjectionExpression string

+ ReturnConsumedCapacity string

+ TableName gocf.Stringable

+ type DynamoDBGetItemState struct

+ func NewDynamoDBGetItemState(stateName string, parameters DynamoDBGetItemParameters) *DynamoDBGetItemState

+ func (dgis *DynamoDBGetItemState) MarshalJSON() ([]byte, error)

+ type DynamoDBPutItemParameters struct

+ ConditionExpression string

+ ConsistentRead bool

+ ExpressionAttributeNames map[string]string

+ ExpressionAttributeValues map[string]*dynamodb.AttributeValue

+ Item map[string]*dynamodb.AttributeValue

+ ReturnConsumedCapacity string

+ ReturnItemCollectionMetrics string

+ ReturnValues string

+ TableName gocf.Stringable

+ type DynamoDBPutItemState struct

+ func NewDynamoDBPutItemState(stateName string, parameters DynamoDBPutItemParameters) *DynamoDBPutItemState

+ func (dgis *DynamoDBPutItemState) MarshalJSON() ([]byte, error)

type FailState

+ func (fs *FailState) AdjacentStates() []MachineState

+ type FargateNetworkConfiguration struct

+ AWSVPCConfiguration *gocf.ECSServiceAwsVPCConfiguration

+ type FargateTaskParameters struct

+ Cluster gocf.Stringable

+ Group string

+ LaunchType string

+ NetworkConfiguration *FargateNetworkConfiguration

+ Overrides map[string]interface{}

+ PlacementConstraints []map[string]string

+ PlacementStrategy []map[string]string

+ PlatformVersion string

+ TaskDefinition gocf.Stringable

+ type FargateTaskState struct

+ func NewFargateTaskState(stateName string, parameters FargateTaskParameters) *FargateTaskState

+ func (fts *FargateTaskState) MarshalJSON() ([]byte, error)

+ type GlueParameters struct

+ AllocatedCapacity *gocf.IntegerExpr

+ Arguments map[string]interface{}

+ JobName gocf.Stringable

+ JobRunID string

+ NotificationProperty interface{}

+ SecurityConfiguration gocf.Stringable

+ Timeout *gocf.IntegerExpr

+ type GlueState struct

+ func NewGlueState(stateName string, parameters GlueParameters) *GlueState

+ func (gs *GlueState) MarshalJSON() ([]byte, error)

+ type LambdaTaskState struct

+ func NewLambdaTaskState(stateName string, lambdaFn *sparta.LambdaAWSInfo) *LambdaTaskState

+ func (ts *LambdaTaskState) MarshalJSON() ([]byte, error)

type ParallelState

+ Catchers []*TaskCatch

+ Retriers []*TaskRetry

+ func (ps *ParallelState) AdjacentStates() []MachineState

+ func (ps *ParallelState) WithCatchers(catch ...*TaskCatch) *ParallelState

+ func (ps *ParallelState) WithRetriers(retries ...*TaskRetry) *ParallelState

type PassState

+ func (ps *PassState) AdjacentStates() []MachineState

+ type SNSTaskParameters struct

+ Message string

+ MessageAttributes map[string]interface{}

+ MessageStructure string

+ PhoneNumber string

+ Subject string

+ TargetArn gocf.Stringable

+ TopicArn gocf.Stringable

+ type SNSTaskState struct

+ func NewSNSTaskState(stateName string, parameters SNSTaskParameters) *SNSTaskState

+ func (sts *SNSTaskState) MarshalJSON() ([]byte, error)

+ type SQSTaskParameters struct

+ DelaySeconds int

+ MessageAttributes map[string]interface{}

+ MessageBody string

+ MessageDeduplicationID string

+ MessageGroupID string

+ QueueURL gocf.Stringable

+ type SQSTaskState struct

+ func NewSQSTaskState(stateName string, parameters SQSTaskParameters) *SQSTaskState

+ func (sqs *SQSTaskState) MarshalJSON() ([]byte, error)

+ type SageMakerTag struct

+ Key string

+ Value gocf.Stringable

+ type SageMakerTrainingJob struct

+ func NewSageMakerTrainingJob(stateName string, parameters SageMakerTrainingJobParameters) *SageMakerTrainingJob

+ func (smtj *SageMakerTrainingJob) MarshalJSON() ([]byte, error)

+ type SageMakerTrainingJobParameters struct

+ AlgorithmSpecification map[string]interface{}

+ HyperParameters map[string]interface{}

+ InputDataConfig []interface{}

+ OutputDataConfig map[string]interface{}

+ ResourceConfig map[string]interface{}

+ RoleArn gocf.Stringable

+ StoppingCondition interface{}

+ Tags []SageMakerTag

+ TrainingJobName string

+ VpcConfig map[string]interface{}

+ type SageMakerTransformJob struct

+ func NewSageMakerTransformJob(stateName string, parameters SageMakerTransformJobParameters) *SageMakerTransformJob

+ func (smtj *SageMakerTransformJob) MarshalJSON() ([]byte, error)

+ type SageMakerTransformJobParameters struct

+ BatchStrategy string

+ Environment map[string]string

+ MaxConcurrentTransforms int

+ MaxPayloadInMB int

+ ModelName string

+ Tags []SageMakerTag

+ TransformInput map[string]interface{}

+ TransformJobName string

+ TransformOutput map[string]interface{}

+ TransformResources map[string]interface{}

type StateMachine

+ func (sm *StateMachine) StateMachineNamedDecorator(stepFunctionResourceName string) sparta.ServiceDecoratorHookFunc

+ func (sm *StateMachine) WithRoleArn(roleArn gocf.Stringable) *StateMachine

type SuccessState

+ func (ss *SuccessState) AdjacentStates() []MachineState

type TaskCatch

+ func (tc *TaskCatch) MarshalJSON() ([]byte, error)

type TransitionState

+ AdjacentStates func() []MachineState

type WaitDelay

+ func (wd *WaitDelay) AdjacentStates() []MachineState

type WaitDynamicUntil

+ func (wdu *WaitDynamicUntil) AdjacentStates() []MachineState

type WaitUntil

+ func (wu *WaitUntil) AdjacentStates() []MachineState

v1.7.3

Dec 1, 2018

v1.7.2

Nov 18, 2018

v1.7.1

Nov 17, 2018

v1.7.0

Nov 11, 2018

v1.6.0

Nov 5, 2018

v1.5.0

Oct 23, 2018

v1.4.0

Oct 8, 2018

v1.3.0

Sep 3, 2018

Changes in this version

+ type And struct

+ Comparison []Comparison

+ Next MachineState

+ func (andOperation *And) MarshalJSON() ([]byte, error)

+ type BooleanEquals struct

+ Value interface{}

+ Variable string

+ func (cmp *BooleanEquals) MarshalJSON() ([]byte, error)

+ type ChoiceBranch interface

+ type ChoiceState struct

+ Choices []ChoiceBranch

+ Default TransitionState

+ func NewChoiceState(choiceStateName string, choices ...ChoiceBranch) *ChoiceState

+ func (cs *ChoiceState) MarshalJSON() ([]byte, error)

+ func (cs *ChoiceState) Name() string

+ func (cs *ChoiceState) WithComment(comment string) *ChoiceState

+ func (cs *ChoiceState) WithDefault(defaultState TransitionState) *ChoiceState

+ func (cs *ChoiceState) WithResultPath(resultPath string) *ChoiceState

+ type Comparison interface

+ type FailState struct

+ Cause error

+ ErrorName string

+ func NewFailState(failStateName string, errorName string, cause error) *FailState

+ func (fs *FailState) MarshalJSON() ([]byte, error)

+ func (fs *FailState) Name() string

+ func (fs *FailState) Next(nextState MachineState) MachineState

+ func (fs *FailState) NextState() MachineState

+ func (fs *FailState) WithComment(comment string) TransitionState

+ func (fs *FailState) WithInputPath(inputPath string) TransitionState

+ func (fs *FailState) WithOutputPath(outputPath string) TransitionState

+ type MachineState interface

+ Name func() string

+ type Not struct

+ Comparison Comparison

+ Next MachineState

+ func (notOperation *Not) MarshalJSON() ([]byte, error)

+ type NumericEquals struct

+ Value int64

+ Variable string

+ func (cmp *NumericEquals) MarshalJSON() ([]byte, error)

+ type NumericGreaterThan struct

+ Value int64

+ Variable string

+ func (cmp *NumericGreaterThan) MarshalJSON() ([]byte, error)

+ type NumericGreaterThanEquals struct

+ Value int64

+ Variable string

+ func (cmp *NumericGreaterThanEquals) MarshalJSON() ([]byte, error)

+ type NumericLessThan struct

+ Value int64

+ Variable string

+ func (cmp *NumericLessThan) MarshalJSON() ([]byte, error)

+ type NumericLessThanEquals struct

+ Value int64

+ Variable string

+ func (cmp *NumericLessThanEquals) MarshalJSON() ([]byte, error)

+ type Or struct

+ Comparison []Comparison

+ Next MachineState

+ func (orOperation *Or) MarshalJSON() ([]byte, error)

+ type ParallelState struct

+ Catch *TaskCatch

+ ResultPath string

+ Retry []*TaskRetry

+ States StateMachine

+ func NewParallelState(parallelStateName string, states StateMachine) *ParallelState

+ func (ps *ParallelState) MarshalJSON() ([]byte, error)

+ func (ps *ParallelState) Name() string

+ func (ps *ParallelState) Next(nextState MachineState) MachineState

+ func (ps *ParallelState) NextState() MachineState

+ func (ps *ParallelState) WithCatch(catch *TaskCatch) *ParallelState

+ func (ps *ParallelState) WithComment(comment string) TransitionState

+ func (ps *ParallelState) WithInputPath(inputPath string) TransitionState

+ func (ps *ParallelState) WithOutputPath(outputPath string) TransitionState

+ func (ps *ParallelState) WithResultPath(resultPath string) *ParallelState

+ func (ps *ParallelState) WithRetry(retries ...*TaskRetry) *ParallelState

+ type PassState struct

+ Result interface{}

+ ResultPath string

+ func NewPassState(name string, resultData interface{}) *PassState

+ func (ps *PassState) MarshalJSON() ([]byte, error)

+ func (ps *PassState) Name() string

+ func (ps *PassState) Next(nextState MachineState) MachineState

+ func (ps *PassState) NextState() MachineState

+ func (ps *PassState) WithComment(comment string) TransitionState

+ func (ps *PassState) WithInputPath(inputPath string) TransitionState

+ func (ps *PassState) WithOutputPath(outputPath string) TransitionState

+ func (ps *PassState) WithResult(result interface{}) *PassState

+ func (ps *PassState) WithResultPath(resultPath string) *PassState

+ type StateError string

+ const StatesAll

+ const StatesBranchFailed

+ const StatesNoChoiceMatched

+ const StatesPermissions

+ const StatesResultPathMatchFailure

+ const StatesTaskFailed

+ const StatesTimeout

+ type StateMachine struct

+ func NewStateMachine(stateMachineName string, startState TransitionState) *StateMachine

+ func (sm *StateMachine) Comment(comment string) *StateMachine

+ func (sm *StateMachine) MarshalJSON() ([]byte, error)

+ func (sm *StateMachine) StateMachineDecorator() sparta.ServiceDecoratorHookFunc

+ type StringEquals struct

+ Value string

+ Variable string

+ func (cmp *StringEquals) MarshalJSON() ([]byte, error)

+ type StringGreaterThan struct

+ Value string

+ Variable string

+ func (cmp *StringGreaterThan) MarshalJSON() ([]byte, error)

+ type StringGreaterThanEquals struct

+ Value string

+ Variable string

+ func (cmp *StringGreaterThanEquals) MarshalJSON() ([]byte, error)

+ type StringLessThan struct

+ Value string

+ Variable string

+ func (cmp *StringLessThan) MarshalJSON() ([]byte, error)

+ type StringLessThanEquals struct

+ Value string

+ Variable string

+ func (cmp *StringLessThanEquals) MarshalJSON() ([]byte, error)

+ type SuccessState struct

+ func NewSuccessState(name string) *SuccessState

+ func (ss *SuccessState) MarshalJSON() ([]byte, error)

+ func (ss *SuccessState) Name() string

+ func (ss *SuccessState) Next(nextState MachineState) MachineState

+ func (ss *SuccessState) NextState() MachineState

+ func (ss *SuccessState) WithComment(comment string) TransitionState

+ func (ss *SuccessState) WithInputPath(inputPath string) TransitionState

+ func (ss *SuccessState) WithOutputPath(outputPath string) TransitionState

+ type TaskCatch struct

+ ErrorEquals []StateError

+ NextState TransitionState

+ func NewTaskCatch(errors ...StateError) *TaskCatch

+ func (tc *TaskCatch) Next(nextState TransitionState) *TaskCatch

+ func (tc *TaskCatch) WithErrors(errors ...StateError) *TaskCatch

+ type TaskRetry struct

+ BackoffRate float32

+ ErrorEquals []StateError

+ IntervalSeconds time.Duration

+ MaxAttempts int

+ func NewTaskRetry() *TaskRetry

+ func (tr *TaskRetry) WithBackoffRate(backoffRate float32) *TaskRetry

+ func (tr *TaskRetry) WithErrors(errors ...StateError) *TaskRetry

+ func (tr *TaskRetry) WithInterval(interval time.Duration) *TaskRetry

+ func (tr *TaskRetry) WithMaxAttempts(maxAttempts int) *TaskRetry

+ type TaskState struct

+ Catch *TaskCatch

+ HeartbeatSeconds time.Duration

+ LambdaDecorator sparta.TemplateDecorator

+ ResultPath string

+ Retry []*TaskRetry

+ TimeoutSeconds time.Duration

+ func NewTaskState(stateName string, lambdaFn *sparta.LambdaAWSInfo) *TaskState

+ func (ts *TaskState) MarshalJSON() ([]byte, error)

+ func (ts *TaskState) Name() string

+ func (ts *TaskState) Next(nextState MachineState) MachineState

+ func (ts *TaskState) NextState() MachineState

+ func (ts *TaskState) WithCatch(catch *TaskCatch) *TaskState

+ func (ts *TaskState) WithComment(comment string) TransitionState

+ func (ts *TaskState) WithHeartbeat(pulse time.Duration) *TaskState

+ func (ts *TaskState) WithInputPath(inputPath string) TransitionState

+ func (ts *TaskState) WithOutputPath(outputPath string) TransitionState

+ func (ts *TaskState) WithResultPath(resultPath string) *TaskState

+ func (ts *TaskState) WithRetry(retries ...*TaskRetry) *TaskState

+ func (ts *TaskState) WithTimeout(timeout time.Duration) *TaskState

+ type TimestampEquals struct

+ Value time.Time

+ Variable string

+ func (cmp *TimestampEquals) MarshalJSON() ([]byte, error)

+ type TimestampGreaterThan struct

+ Value time.Time

+ Variable string

+ func (cmp *TimestampGreaterThan) MarshalJSON() ([]byte, error)

+ type TimestampGreaterThanEquals struct

+ Value time.Time

+ Variable string

+ func (cmp *TimestampGreaterThanEquals) MarshalJSON() ([]byte, error)

+ type TimestampLessThan struct

+ Value time.Time

+ Variable string

+ func (cmp *TimestampLessThan) MarshalJSON() ([]byte, error)

+ type TimestampLessThanEquals struct

+ Value time.Time

+ Variable string

+ func (cmp *TimestampLessThanEquals) MarshalJSON() ([]byte, error)

+ type TransitionState interface

+ Next func(state MachineState) MachineState

+ NextState func() MachineState

+ WithComment func(string) TransitionState

+ WithInputPath func(string) TransitionState

+ WithOutputPath func(string) TransitionState

+ type WaitDelay struct

+ func NewWaitDelayState(stateName string, delayInSeconds time.Duration) *WaitDelay

+ func (wd *WaitDelay) MarshalJSON() ([]byte, error)

+ func (wd *WaitDelay) Name() string

+ func (wd *WaitDelay) Next(nextState MachineState) MachineState

+ func (wd *WaitDelay) NextState() MachineState

+ func (wd *WaitDelay) WithComment(comment string) TransitionState

+ func (wd *WaitDelay) WithInputPath(inputPath string) TransitionState

+ func (wd *WaitDelay) WithOutputPath(outputPath string) TransitionState

+ type WaitDynamicUntil struct

+ TimestampPath string

+ func NewWaitDynamicUntilState(stateName string, timestampPath string) *WaitDynamicUntil

+ func (wdu *WaitDynamicUntil) MarshalJSON() ([]byte, error)

+ func (wdu *WaitDynamicUntil) Name() string

+ func (wdu *WaitDynamicUntil) Next(nextState MachineState) MachineState

+ func (wdu *WaitDynamicUntil) NextState() MachineState

+ func (wdu *WaitDynamicUntil) WithComment(comment string) TransitionState

+ func (wdu *WaitDynamicUntil) WithInputPath(inputPath string) TransitionState

+ func (wdu *WaitDynamicUntil) WithOutputPath(outputPath string) TransitionState

+ type WaitUntil struct

+ Timestamp time.Time

+ func NewWaitUntilState(stateName string, waitUntil time.Time) *WaitUntil

+ func (wu *WaitUntil) MarshalJSON() ([]byte, error)

+ func (wu *WaitUntil) Name() string

+ func (wu *WaitUntil) Next(nextState MachineState) MachineState

+ func (wu *WaitUntil) NextState() MachineState

+ func (wu *WaitUntil) WithComment(comment string) TransitionState

+ func (wu *WaitUntil) WithInputPath(inputPath string) TransitionState

+ func (wu *WaitUntil) WithOutputPath(outputPath string) TransitionState

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL