From fe60b4e90ae04573c7a23c4f0ecd2c1f09d4a52f Mon Sep 17 00:00:00 2001 From: Ninir Date: Tue, 10 Jan 2017 15:17:39 +0100 Subject: [PATCH] Added aws-sdk-go SFN service (#11109) --- builtin/providers/aws/config.go | 3 + .../aws/aws-sdk-go/service/sfn/api.go | 4093 +++++++++++++++++ .../aws/aws-sdk-go/service/sfn/service.go | 108 + vendor/vendor.json | 8 + 4 files changed, 4212 insertions(+) create mode 100644 vendor/github.com/aws/aws-sdk-go/service/sfn/api.go create mode 100644 vendor/github.com/aws/aws-sdk-go/service/sfn/service.go diff --git a/builtin/providers/aws/config.go b/builtin/providers/aws/config.go index 286b8b4d3..5ff64450c 100644 --- a/builtin/providers/aws/config.go +++ b/builtin/providers/aws/config.go @@ -52,6 +52,7 @@ import ( "github.com/aws/aws-sdk-go/service/route53" "github.com/aws/aws-sdk-go/service/s3" "github.com/aws/aws-sdk-go/service/ses" + "github.com/aws/aws-sdk-go/service/sfn" "github.com/aws/aws-sdk-go/service/simpledb" "github.com/aws/aws-sdk-go/service/sns" "github.com/aws/aws-sdk-go/service/sqs" @@ -141,6 +142,7 @@ type AWSClient struct { glacierconn *glacier.Glacier codedeployconn *codedeploy.CodeDeploy codecommitconn *codecommit.CodeCommit + sfnconn *sfn.SFN ssmconn *ssm.SSM wafconn *waf.WAF } @@ -292,6 +294,7 @@ func (c *Config) Client() (interface{}, error) { client.simpledbconn = simpledb.New(sess) client.s3conn = s3.New(awsS3Sess) client.sesConn = ses.New(sess) + client.sfnconn = sfn.New(sess) client.snsconn = sns.New(sess) client.sqsconn = sqs.New(sess) client.ssmconn = ssm.New(sess) diff --git a/vendor/github.com/aws/aws-sdk-go/service/sfn/api.go b/vendor/github.com/aws/aws-sdk-go/service/sfn/api.go new file mode 100644 index 000000000..8123f7e2a --- /dev/null +++ b/vendor/github.com/aws/aws-sdk-go/service/sfn/api.go @@ -0,0 +1,4093 @@ +// THIS FILE IS AUTOMATICALLY GENERATED. DO NOT EDIT. + +// Package sfn provides a client for AWS Step Functions. +package sfn + +import ( + "time" + + "github.com/aws/aws-sdk-go/aws/awsutil" + "github.com/aws/aws-sdk-go/aws/request" +) + +const opCreateActivity = "CreateActivity" + +// CreateActivityRequest generates a "aws/request.Request" representing the +// client's request for the CreateActivity operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See CreateActivity for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the CreateActivity method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the CreateActivityRequest method. +// req, resp := client.CreateActivityRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateActivity +func (c *SFN) CreateActivityRequest(input *CreateActivityInput) (req *request.Request, output *CreateActivityOutput) { + op := &request.Operation{ + Name: opCreateActivity, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &CreateActivityInput{} + } + + req = c.newRequest(op, input, output) + output = &CreateActivityOutput{} + req.Data = output + return +} + +// CreateActivity API operation for AWS Step Functions. +// +// Creates an activity. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation CreateActivity for usage and error information. +// +// Returned Error Codes: +// * ActivityLimitExceeded +// The maximum number of activities has been reached. Existing activities must +// be deleted before a new activity can be created. +// +// * InvalidName +// The provided name is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateActivity +func (c *SFN) CreateActivity(input *CreateActivityInput) (*CreateActivityOutput, error) { + req, out := c.CreateActivityRequest(input) + err := req.Send() + return out, err +} + +const opCreateStateMachine = "CreateStateMachine" + +// CreateStateMachineRequest generates a "aws/request.Request" representing the +// client's request for the CreateStateMachine operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See CreateStateMachine for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the CreateStateMachine method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the CreateStateMachineRequest method. +// req, resp := client.CreateStateMachineRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateStateMachine +func (c *SFN) CreateStateMachineRequest(input *CreateStateMachineInput) (req *request.Request, output *CreateStateMachineOutput) { + op := &request.Operation{ + Name: opCreateStateMachine, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &CreateStateMachineInput{} + } + + req = c.newRequest(op, input, output) + output = &CreateStateMachineOutput{} + req.Data = output + return +} + +// CreateStateMachine API operation for AWS Step Functions. +// +// Creates a state machine. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation CreateStateMachine for usage and error information. +// +// Returned Error Codes: +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// * InvalidDefinition +// The provided Amazon States Language definition is invalid. +// +// * InvalidName +// The provided name is invalid. +// +// * StateMachineAlreadyExists +// A state machine with the same name but a different definition or role ARN +// already exists. +// +// * StateMachineDeleting +// The specified state machine is being deleted. +// +// * StateMachineLimitExceeded +// The maximum number of state machines has been reached. Existing state machines +// must be deleted before a new state machine can be created. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateStateMachine +func (c *SFN) CreateStateMachine(input *CreateStateMachineInput) (*CreateStateMachineOutput, error) { + req, out := c.CreateStateMachineRequest(input) + err := req.Send() + return out, err +} + +const opDeleteActivity = "DeleteActivity" + +// DeleteActivityRequest generates a "aws/request.Request" representing the +// client's request for the DeleteActivity operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See DeleteActivity for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the DeleteActivity method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the DeleteActivityRequest method. +// req, resp := client.DeleteActivityRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteActivity +func (c *SFN) DeleteActivityRequest(input *DeleteActivityInput) (req *request.Request, output *DeleteActivityOutput) { + op := &request.Operation{ + Name: opDeleteActivity, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &DeleteActivityInput{} + } + + req = c.newRequest(op, input, output) + output = &DeleteActivityOutput{} + req.Data = output + return +} + +// DeleteActivity API operation for AWS Step Functions. +// +// Deletes an activity. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation DeleteActivity for usage and error information. +// +// Returned Error Codes: +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteActivity +func (c *SFN) DeleteActivity(input *DeleteActivityInput) (*DeleteActivityOutput, error) { + req, out := c.DeleteActivityRequest(input) + err := req.Send() + return out, err +} + +const opDeleteStateMachine = "DeleteStateMachine" + +// DeleteStateMachineRequest generates a "aws/request.Request" representing the +// client's request for the DeleteStateMachine operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See DeleteStateMachine for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the DeleteStateMachine method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the DeleteStateMachineRequest method. +// req, resp := client.DeleteStateMachineRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteStateMachine +func (c *SFN) DeleteStateMachineRequest(input *DeleteStateMachineInput) (req *request.Request, output *DeleteStateMachineOutput) { + op := &request.Operation{ + Name: opDeleteStateMachine, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &DeleteStateMachineInput{} + } + + req = c.newRequest(op, input, output) + output = &DeleteStateMachineOutput{} + req.Data = output + return +} + +// DeleteStateMachine API operation for AWS Step Functions. +// +// Deletes a state machine. This is an asynchronous operation-- it sets the +// state machine's status to "DELETING" and begins the delete process. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation DeleteStateMachine for usage and error information. +// +// Returned Error Codes: +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteStateMachine +func (c *SFN) DeleteStateMachine(input *DeleteStateMachineInput) (*DeleteStateMachineOutput, error) { + req, out := c.DeleteStateMachineRequest(input) + err := req.Send() + return out, err +} + +const opDescribeActivity = "DescribeActivity" + +// DescribeActivityRequest generates a "aws/request.Request" representing the +// client's request for the DescribeActivity operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See DescribeActivity for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the DescribeActivity method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the DescribeActivityRequest method. +// req, resp := client.DescribeActivityRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeActivity +func (c *SFN) DescribeActivityRequest(input *DescribeActivityInput) (req *request.Request, output *DescribeActivityOutput) { + op := &request.Operation{ + Name: opDescribeActivity, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &DescribeActivityInput{} + } + + req = c.newRequest(op, input, output) + output = &DescribeActivityOutput{} + req.Data = output + return +} + +// DescribeActivity API operation for AWS Step Functions. +// +// Describes an activity. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation DescribeActivity for usage and error information. +// +// Returned Error Codes: +// * ActivityDoesNotExist +// The specified activity does not exist. +// +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeActivity +func (c *SFN) DescribeActivity(input *DescribeActivityInput) (*DescribeActivityOutput, error) { + req, out := c.DescribeActivityRequest(input) + err := req.Send() + return out, err +} + +const opDescribeExecution = "DescribeExecution" + +// DescribeExecutionRequest generates a "aws/request.Request" representing the +// client's request for the DescribeExecution operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See DescribeExecution for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the DescribeExecution method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the DescribeExecutionRequest method. +// req, resp := client.DescribeExecutionRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeExecution +func (c *SFN) DescribeExecutionRequest(input *DescribeExecutionInput) (req *request.Request, output *DescribeExecutionOutput) { + op := &request.Operation{ + Name: opDescribeExecution, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &DescribeExecutionInput{} + } + + req = c.newRequest(op, input, output) + output = &DescribeExecutionOutput{} + req.Data = output + return +} + +// DescribeExecution API operation for AWS Step Functions. +// +// Describes an execution. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation DescribeExecution for usage and error information. +// +// Returned Error Codes: +// * ExecutionDoesNotExist +// The specified execution does not exist. +// +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeExecution +func (c *SFN) DescribeExecution(input *DescribeExecutionInput) (*DescribeExecutionOutput, error) { + req, out := c.DescribeExecutionRequest(input) + err := req.Send() + return out, err +} + +const opDescribeStateMachine = "DescribeStateMachine" + +// DescribeStateMachineRequest generates a "aws/request.Request" representing the +// client's request for the DescribeStateMachine operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See DescribeStateMachine for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the DescribeStateMachine method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the DescribeStateMachineRequest method. +// req, resp := client.DescribeStateMachineRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeStateMachine +func (c *SFN) DescribeStateMachineRequest(input *DescribeStateMachineInput) (req *request.Request, output *DescribeStateMachineOutput) { + op := &request.Operation{ + Name: opDescribeStateMachine, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &DescribeStateMachineInput{} + } + + req = c.newRequest(op, input, output) + output = &DescribeStateMachineOutput{} + req.Data = output + return +} + +// DescribeStateMachine API operation for AWS Step Functions. +// +// Describes a state machine. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation DescribeStateMachine for usage and error information. +// +// Returned Error Codes: +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// * StateMachineDoesNotExist +// The specified state machine does not exist. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeStateMachine +func (c *SFN) DescribeStateMachine(input *DescribeStateMachineInput) (*DescribeStateMachineOutput, error) { + req, out := c.DescribeStateMachineRequest(input) + err := req.Send() + return out, err +} + +const opGetActivityTask = "GetActivityTask" + +// GetActivityTaskRequest generates a "aws/request.Request" representing the +// client's request for the GetActivityTask operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See GetActivityTask for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the GetActivityTask method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the GetActivityTaskRequest method. +// req, resp := client.GetActivityTaskRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetActivityTask +func (c *SFN) GetActivityTaskRequest(input *GetActivityTaskInput) (req *request.Request, output *GetActivityTaskOutput) { + op := &request.Operation{ + Name: opGetActivityTask, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &GetActivityTaskInput{} + } + + req = c.newRequest(op, input, output) + output = &GetActivityTaskOutput{} + req.Data = output + return +} + +// GetActivityTask API operation for AWS Step Functions. +// +// Used by workers to retrieve a task (with the specified activity ARN) scheduled +// for execution by a running state machine. This initiates a long poll, where +// the service holds the HTTP connection open and responds as soon as a task +// becomes available (i.e. an execution of a task of this type is needed.) The +// maximum time the service holds on to the request before responding is 60 +// seconds. If no task is available within 60 seconds, the poll will return +// an empty result, that is, the taskToken returned is an empty string. +// +// Workers should set their client side socket timeout to at least 65 seconds +// (5 seconds higher than the maximum time the service may hold the poll request). +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation GetActivityTask for usage and error information. +// +// Returned Error Codes: +// * ActivityDoesNotExist +// The specified activity does not exist. +// +// * ActivityWorkerLimitExceeded +// The maximum number of workers concurrently polling for activity tasks has +// been reached. +// +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetActivityTask +func (c *SFN) GetActivityTask(input *GetActivityTaskInput) (*GetActivityTaskOutput, error) { + req, out := c.GetActivityTaskRequest(input) + err := req.Send() + return out, err +} + +const opGetExecutionHistory = "GetExecutionHistory" + +// GetExecutionHistoryRequest generates a "aws/request.Request" representing the +// client's request for the GetExecutionHistory operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See GetExecutionHistory for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the GetExecutionHistory method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the GetExecutionHistoryRequest method. +// req, resp := client.GetExecutionHistoryRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetExecutionHistory +func (c *SFN) GetExecutionHistoryRequest(input *GetExecutionHistoryInput) (req *request.Request, output *GetExecutionHistoryOutput) { + op := &request.Operation{ + Name: opGetExecutionHistory, + HTTPMethod: "POST", + HTTPPath: "/", + Paginator: &request.Paginator{ + InputTokens: []string{"nextToken"}, + OutputTokens: []string{"nextToken"}, + LimitToken: "maxResults", + TruncationToken: "", + }, + } + + if input == nil { + input = &GetExecutionHistoryInput{} + } + + req = c.newRequest(op, input, output) + output = &GetExecutionHistoryOutput{} + req.Data = output + return +} + +// GetExecutionHistory API operation for AWS Step Functions. +// +// Returns the history of the specified execution as a list of events. By default, +// the results are returned in ascending order of the timeStamp of the events. +// Use the reverseOrder parameter to get the latest events first. The results +// may be split into multiple pages. To retrieve subsequent pages, make the +// call again using the nextToken returned by the previous call. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation GetExecutionHistory for usage and error information. +// +// Returned Error Codes: +// * ExecutionDoesNotExist +// The specified execution does not exist. +// +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// * InvalidToken +// The provided token is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetExecutionHistory +func (c *SFN) GetExecutionHistory(input *GetExecutionHistoryInput) (*GetExecutionHistoryOutput, error) { + req, out := c.GetExecutionHistoryRequest(input) + err := req.Send() + return out, err +} + +// GetExecutionHistoryPages iterates over the pages of a GetExecutionHistory operation, +// calling the "fn" function with the response data for each page. To stop +// iterating, return false from the fn function. +// +// See GetExecutionHistory method for more information on how to use this operation. +// +// Note: This operation can generate multiple requests to a service. +// +// // Example iterating over at most 3 pages of a GetExecutionHistory operation. +// pageNum := 0 +// err := client.GetExecutionHistoryPages(params, +// func(page *GetExecutionHistoryOutput, lastPage bool) bool { +// pageNum++ +// fmt.Println(page) +// return pageNum <= 3 +// }) +// +func (c *SFN) GetExecutionHistoryPages(input *GetExecutionHistoryInput, fn func(p *GetExecutionHistoryOutput, lastPage bool) (shouldContinue bool)) error { + page, _ := c.GetExecutionHistoryRequest(input) + page.Handlers.Build.PushBack(request.MakeAddToUserAgentFreeFormHandler("Paginator")) + return page.EachPage(func(p interface{}, lastPage bool) bool { + return fn(p.(*GetExecutionHistoryOutput), lastPage) + }) +} + +const opListActivities = "ListActivities" + +// ListActivitiesRequest generates a "aws/request.Request" representing the +// client's request for the ListActivities operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See ListActivities for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the ListActivities method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the ListActivitiesRequest method. +// req, resp := client.ListActivitiesRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListActivities +func (c *SFN) ListActivitiesRequest(input *ListActivitiesInput) (req *request.Request, output *ListActivitiesOutput) { + op := &request.Operation{ + Name: opListActivities, + HTTPMethod: "POST", + HTTPPath: "/", + Paginator: &request.Paginator{ + InputTokens: []string{"nextToken"}, + OutputTokens: []string{"nextToken"}, + LimitToken: "maxResults", + TruncationToken: "", + }, + } + + if input == nil { + input = &ListActivitiesInput{} + } + + req = c.newRequest(op, input, output) + output = &ListActivitiesOutput{} + req.Data = output + return +} + +// ListActivities API operation for AWS Step Functions. +// +// Lists the existing activities. The results may be split into multiple pages. +// To retrieve subsequent pages, make the call again using the nextToken returned +// by the previous call. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation ListActivities for usage and error information. +// +// Returned Error Codes: +// * InvalidToken +// The provided token is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListActivities +func (c *SFN) ListActivities(input *ListActivitiesInput) (*ListActivitiesOutput, error) { + req, out := c.ListActivitiesRequest(input) + err := req.Send() + return out, err +} + +// ListActivitiesPages iterates over the pages of a ListActivities operation, +// calling the "fn" function with the response data for each page. To stop +// iterating, return false from the fn function. +// +// See ListActivities method for more information on how to use this operation. +// +// Note: This operation can generate multiple requests to a service. +// +// // Example iterating over at most 3 pages of a ListActivities operation. +// pageNum := 0 +// err := client.ListActivitiesPages(params, +// func(page *ListActivitiesOutput, lastPage bool) bool { +// pageNum++ +// fmt.Println(page) +// return pageNum <= 3 +// }) +// +func (c *SFN) ListActivitiesPages(input *ListActivitiesInput, fn func(p *ListActivitiesOutput, lastPage bool) (shouldContinue bool)) error { + page, _ := c.ListActivitiesRequest(input) + page.Handlers.Build.PushBack(request.MakeAddToUserAgentFreeFormHandler("Paginator")) + return page.EachPage(func(p interface{}, lastPage bool) bool { + return fn(p.(*ListActivitiesOutput), lastPage) + }) +} + +const opListExecutions = "ListExecutions" + +// ListExecutionsRequest generates a "aws/request.Request" representing the +// client's request for the ListExecutions operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See ListExecutions for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the ListExecutions method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the ListExecutionsRequest method. +// req, resp := client.ListExecutionsRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListExecutions +func (c *SFN) ListExecutionsRequest(input *ListExecutionsInput) (req *request.Request, output *ListExecutionsOutput) { + op := &request.Operation{ + Name: opListExecutions, + HTTPMethod: "POST", + HTTPPath: "/", + Paginator: &request.Paginator{ + InputTokens: []string{"nextToken"}, + OutputTokens: []string{"nextToken"}, + LimitToken: "maxResults", + TruncationToken: "", + }, + } + + if input == nil { + input = &ListExecutionsInput{} + } + + req = c.newRequest(op, input, output) + output = &ListExecutionsOutput{} + req.Data = output + return +} + +// ListExecutions API operation for AWS Step Functions. +// +// Lists the executions of a state machine that meet the filtering criteria. +// The results may be split into multiple pages. To retrieve subsequent pages, +// make the call again using the nextToken returned by the previous call. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation ListExecutions for usage and error information. +// +// Returned Error Codes: +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// * InvalidToken +// The provided token is invalid. +// +// * StateMachineDoesNotExist +// The specified state machine does not exist. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListExecutions +func (c *SFN) ListExecutions(input *ListExecutionsInput) (*ListExecutionsOutput, error) { + req, out := c.ListExecutionsRequest(input) + err := req.Send() + return out, err +} + +// ListExecutionsPages iterates over the pages of a ListExecutions operation, +// calling the "fn" function with the response data for each page. To stop +// iterating, return false from the fn function. +// +// See ListExecutions method for more information on how to use this operation. +// +// Note: This operation can generate multiple requests to a service. +// +// // Example iterating over at most 3 pages of a ListExecutions operation. +// pageNum := 0 +// err := client.ListExecutionsPages(params, +// func(page *ListExecutionsOutput, lastPage bool) bool { +// pageNum++ +// fmt.Println(page) +// return pageNum <= 3 +// }) +// +func (c *SFN) ListExecutionsPages(input *ListExecutionsInput, fn func(p *ListExecutionsOutput, lastPage bool) (shouldContinue bool)) error { + page, _ := c.ListExecutionsRequest(input) + page.Handlers.Build.PushBack(request.MakeAddToUserAgentFreeFormHandler("Paginator")) + return page.EachPage(func(p interface{}, lastPage bool) bool { + return fn(p.(*ListExecutionsOutput), lastPage) + }) +} + +const opListStateMachines = "ListStateMachines" + +// ListStateMachinesRequest generates a "aws/request.Request" representing the +// client's request for the ListStateMachines operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See ListStateMachines for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the ListStateMachines method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the ListStateMachinesRequest method. +// req, resp := client.ListStateMachinesRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListStateMachines +func (c *SFN) ListStateMachinesRequest(input *ListStateMachinesInput) (req *request.Request, output *ListStateMachinesOutput) { + op := &request.Operation{ + Name: opListStateMachines, + HTTPMethod: "POST", + HTTPPath: "/", + Paginator: &request.Paginator{ + InputTokens: []string{"nextToken"}, + OutputTokens: []string{"nextToken"}, + LimitToken: "maxResults", + TruncationToken: "", + }, + } + + if input == nil { + input = &ListStateMachinesInput{} + } + + req = c.newRequest(op, input, output) + output = &ListStateMachinesOutput{} + req.Data = output + return +} + +// ListStateMachines API operation for AWS Step Functions. +// +// Lists the existing state machines. The results may be split into multiple +// pages. To retrieve subsequent pages, make the call again using the nextToken +// returned by the previous call. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation ListStateMachines for usage and error information. +// +// Returned Error Codes: +// * InvalidToken +// The provided token is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListStateMachines +func (c *SFN) ListStateMachines(input *ListStateMachinesInput) (*ListStateMachinesOutput, error) { + req, out := c.ListStateMachinesRequest(input) + err := req.Send() + return out, err +} + +// ListStateMachinesPages iterates over the pages of a ListStateMachines operation, +// calling the "fn" function with the response data for each page. To stop +// iterating, return false from the fn function. +// +// See ListStateMachines method for more information on how to use this operation. +// +// Note: This operation can generate multiple requests to a service. +// +// // Example iterating over at most 3 pages of a ListStateMachines operation. +// pageNum := 0 +// err := client.ListStateMachinesPages(params, +// func(page *ListStateMachinesOutput, lastPage bool) bool { +// pageNum++ +// fmt.Println(page) +// return pageNum <= 3 +// }) +// +func (c *SFN) ListStateMachinesPages(input *ListStateMachinesInput, fn func(p *ListStateMachinesOutput, lastPage bool) (shouldContinue bool)) error { + page, _ := c.ListStateMachinesRequest(input) + page.Handlers.Build.PushBack(request.MakeAddToUserAgentFreeFormHandler("Paginator")) + return page.EachPage(func(p interface{}, lastPage bool) bool { + return fn(p.(*ListStateMachinesOutput), lastPage) + }) +} + +const opSendTaskFailure = "SendTaskFailure" + +// SendTaskFailureRequest generates a "aws/request.Request" representing the +// client's request for the SendTaskFailure operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See SendTaskFailure for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the SendTaskFailure method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the SendTaskFailureRequest method. +// req, resp := client.SendTaskFailureRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskFailure +func (c *SFN) SendTaskFailureRequest(input *SendTaskFailureInput) (req *request.Request, output *SendTaskFailureOutput) { + op := &request.Operation{ + Name: opSendTaskFailure, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &SendTaskFailureInput{} + } + + req = c.newRequest(op, input, output) + output = &SendTaskFailureOutput{} + req.Data = output + return +} + +// SendTaskFailure API operation for AWS Step Functions. +// +// Used by workers to report that the task identified by the taskToken failed. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation SendTaskFailure for usage and error information. +// +// Returned Error Codes: +// * TaskDoesNotExist + +// +// * InvalidToken +// The provided token is invalid. +// +// * TaskTimedOut + +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskFailure +func (c *SFN) SendTaskFailure(input *SendTaskFailureInput) (*SendTaskFailureOutput, error) { + req, out := c.SendTaskFailureRequest(input) + err := req.Send() + return out, err +} + +const opSendTaskHeartbeat = "SendTaskHeartbeat" + +// SendTaskHeartbeatRequest generates a "aws/request.Request" representing the +// client's request for the SendTaskHeartbeat operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See SendTaskHeartbeat for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the SendTaskHeartbeat method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the SendTaskHeartbeatRequest method. +// req, resp := client.SendTaskHeartbeatRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskHeartbeat +func (c *SFN) SendTaskHeartbeatRequest(input *SendTaskHeartbeatInput) (req *request.Request, output *SendTaskHeartbeatOutput) { + op := &request.Operation{ + Name: opSendTaskHeartbeat, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &SendTaskHeartbeatInput{} + } + + req = c.newRequest(op, input, output) + output = &SendTaskHeartbeatOutput{} + req.Data = output + return +} + +// SendTaskHeartbeat API operation for AWS Step Functions. +// +// Used by workers to report to the service that the task represented by the +// specified taskToken is still making progress. This action resets the Heartbeat +// clock. The Heartbeat threshold is specified in the state machine's Amazon +// States Language definition. This action does not in itself create an event +// in the execution history. However, if the task times out, the execution history +// will contain an ActivityTimedOut event. +// +// The Timeout of a task, defined in the state machine's Amazon States Language +// definition, is its maximum allowed duration, regardless of the number of +// SendTaskHeartbeat requests received. +// +// This operation is only useful for long-lived tasks to report the liveliness +// of the task. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation SendTaskHeartbeat for usage and error information. +// +// Returned Error Codes: +// * TaskDoesNotExist + +// +// * InvalidToken +// The provided token is invalid. +// +// * TaskTimedOut + +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskHeartbeat +func (c *SFN) SendTaskHeartbeat(input *SendTaskHeartbeatInput) (*SendTaskHeartbeatOutput, error) { + req, out := c.SendTaskHeartbeatRequest(input) + err := req.Send() + return out, err +} + +const opSendTaskSuccess = "SendTaskSuccess" + +// SendTaskSuccessRequest generates a "aws/request.Request" representing the +// client's request for the SendTaskSuccess operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See SendTaskSuccess for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the SendTaskSuccess method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the SendTaskSuccessRequest method. +// req, resp := client.SendTaskSuccessRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskSuccess +func (c *SFN) SendTaskSuccessRequest(input *SendTaskSuccessInput) (req *request.Request, output *SendTaskSuccessOutput) { + op := &request.Operation{ + Name: opSendTaskSuccess, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &SendTaskSuccessInput{} + } + + req = c.newRequest(op, input, output) + output = &SendTaskSuccessOutput{} + req.Data = output + return +} + +// SendTaskSuccess API operation for AWS Step Functions. +// +// Used by workers to report that the task identified by the taskToken completed +// successfully. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation SendTaskSuccess for usage and error information. +// +// Returned Error Codes: +// * TaskDoesNotExist + +// +// * InvalidOutput +// The provided JSON output data is invalid. +// +// * InvalidToken +// The provided token is invalid. +// +// * TaskTimedOut + +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskSuccess +func (c *SFN) SendTaskSuccess(input *SendTaskSuccessInput) (*SendTaskSuccessOutput, error) { + req, out := c.SendTaskSuccessRequest(input) + err := req.Send() + return out, err +} + +const opStartExecution = "StartExecution" + +// StartExecutionRequest generates a "aws/request.Request" representing the +// client's request for the StartExecution operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See StartExecution for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the StartExecution method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the StartExecutionRequest method. +// req, resp := client.StartExecutionRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StartExecution +func (c *SFN) StartExecutionRequest(input *StartExecutionInput) (req *request.Request, output *StartExecutionOutput) { + op := &request.Operation{ + Name: opStartExecution, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &StartExecutionInput{} + } + + req = c.newRequest(op, input, output) + output = &StartExecutionOutput{} + req.Data = output + return +} + +// StartExecution API operation for AWS Step Functions. +// +// Starts a state machine execution. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation StartExecution for usage and error information. +// +// Returned Error Codes: +// * ExecutionLimitExceeded +// The maximum number of running executions has been reached. Running executions +// must end or be stopped before a new execution can be started. +// +// * ExecutionAlreadyExists +// An execution with the same name already exists. +// +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// * InvalidExecutionInput +// The provided JSON input data is invalid. +// +// * InvalidName +// The provided name is invalid. +// +// * StateMachineDoesNotExist +// The specified state machine does not exist. +// +// * StateMachineDeleting +// The specified state machine is being deleted. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StartExecution +func (c *SFN) StartExecution(input *StartExecutionInput) (*StartExecutionOutput, error) { + req, out := c.StartExecutionRequest(input) + err := req.Send() + return out, err +} + +const opStopExecution = "StopExecution" + +// StopExecutionRequest generates a "aws/request.Request" representing the +// client's request for the StopExecution operation. The "output" return +// value can be used to capture response data after the request's "Send" method +// is called. +// +// See StopExecution for usage and error information. +// +// Creating a request object using this method should be used when you want to inject +// custom logic into the request's lifecycle using a custom handler, or if you want to +// access properties on the request object before or after sending the request. If +// you just want the service response, call the StopExecution method directly +// instead. +// +// Note: You must call the "Send" method on the returned request object in order +// to execute the request. +// +// // Example sending a request using the StopExecutionRequest method. +// req, resp := client.StopExecutionRequest(params) +// +// err := req.Send() +// if err == nil { // resp is now filled +// fmt.Println(resp) +// } +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StopExecution +func (c *SFN) StopExecutionRequest(input *StopExecutionInput) (req *request.Request, output *StopExecutionOutput) { + op := &request.Operation{ + Name: opStopExecution, + HTTPMethod: "POST", + HTTPPath: "/", + } + + if input == nil { + input = &StopExecutionInput{} + } + + req = c.newRequest(op, input, output) + output = &StopExecutionOutput{} + req.Data = output + return +} + +// StopExecution API operation for AWS Step Functions. +// +// Stops an execution. +// +// Returns awserr.Error for service API and SDK errors. Use runtime type assertions +// with awserr.Error's Code and Message methods to get detailed information about +// the error. +// +// See the AWS API reference guide for AWS Step Functions's +// API operation StopExecution for usage and error information. +// +// Returned Error Codes: +// * ExecutionDoesNotExist +// The specified execution does not exist. +// +// * InvalidArn +// The provided Amazon Resource Name (ARN) is invalid. +// +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StopExecution +func (c *SFN) StopExecution(input *StopExecutionInput) (*StopExecutionOutput, error) { + req, out := c.StopExecutionRequest(input) + err := req.Send() + return out, err +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ActivityFailedEventDetails +type ActivityFailedEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s ActivityFailedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ActivityFailedEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *ActivityFailedEventDetails) SetCause(v string) *ActivityFailedEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *ActivityFailedEventDetails) SetError(v string) *ActivityFailedEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ActivityListItem +type ActivityListItem struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) that identifies the activity. + // + // ActivityArn is a required field + ActivityArn *string `locationName:"activityArn" min:"1" type:"string" required:"true"` + + // The date the activity was created. + // + // CreationDate is a required field + CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The name of the activity. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s ActivityListItem) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ActivityListItem) GoString() string { + return s.String() +} + +// SetActivityArn sets the ActivityArn field's value. +func (s *ActivityListItem) SetActivityArn(v string) *ActivityListItem { + s.ActivityArn = &v + return s +} + +// SetCreationDate sets the CreationDate field's value. +func (s *ActivityListItem) SetCreationDate(v time.Time) *ActivityListItem { + s.CreationDate = &v + return s +} + +// SetName sets the Name field's value. +func (s *ActivityListItem) SetName(v string) *ActivityListItem { + s.Name = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ActivityScheduleFailedEventDetails +type ActivityScheduleFailedEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s ActivityScheduleFailedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ActivityScheduleFailedEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *ActivityScheduleFailedEventDetails) SetCause(v string) *ActivityScheduleFailedEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *ActivityScheduleFailedEventDetails) SetError(v string) *ActivityScheduleFailedEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ActivityScheduledEventDetails +type ActivityScheduledEventDetails struct { + _ struct{} `type:"structure"` + + // The maximum allowed duration between two heartbeats for the activity task. + HeartbeatInSeconds *int64 `locationName:"heartbeatInSeconds" type:"long"` + + // The JSON data input to the activity task. + Input *string `locationName:"input" type:"string"` + + // The Amazon Resource Name (ARN) of the scheduled activity. + // + // Resource is a required field + Resource *string `locationName:"resource" min:"1" type:"string" required:"true"` + + // The maximum allowed duration of the activity task. + TimeoutInSeconds *int64 `locationName:"timeoutInSeconds" type:"long"` +} + +// String returns the string representation +func (s ActivityScheduledEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ActivityScheduledEventDetails) GoString() string { + return s.String() +} + +// SetHeartbeatInSeconds sets the HeartbeatInSeconds field's value. +func (s *ActivityScheduledEventDetails) SetHeartbeatInSeconds(v int64) *ActivityScheduledEventDetails { + s.HeartbeatInSeconds = &v + return s +} + +// SetInput sets the Input field's value. +func (s *ActivityScheduledEventDetails) SetInput(v string) *ActivityScheduledEventDetails { + s.Input = &v + return s +} + +// SetResource sets the Resource field's value. +func (s *ActivityScheduledEventDetails) SetResource(v string) *ActivityScheduledEventDetails { + s.Resource = &v + return s +} + +// SetTimeoutInSeconds sets the TimeoutInSeconds field's value. +func (s *ActivityScheduledEventDetails) SetTimeoutInSeconds(v int64) *ActivityScheduledEventDetails { + s.TimeoutInSeconds = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ActivityStartedEventDetails +type ActivityStartedEventDetails struct { + _ struct{} `type:"structure"` + + // The name of the worker that the task was assigned to. These names are provided + // by the workers when calling GetActivityTask. + WorkerName *string `locationName:"workerName" type:"string"` +} + +// String returns the string representation +func (s ActivityStartedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ActivityStartedEventDetails) GoString() string { + return s.String() +} + +// SetWorkerName sets the WorkerName field's value. +func (s *ActivityStartedEventDetails) SetWorkerName(v string) *ActivityStartedEventDetails { + s.WorkerName = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ActivitySucceededEventDetails +type ActivitySucceededEventDetails struct { + _ struct{} `type:"structure"` + + // The JSON data output by the activity task. + Output *string `locationName:"output" type:"string"` +} + +// String returns the string representation +func (s ActivitySucceededEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ActivitySucceededEventDetails) GoString() string { + return s.String() +} + +// SetOutput sets the Output field's value. +func (s *ActivitySucceededEventDetails) SetOutput(v string) *ActivitySucceededEventDetails { + s.Output = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ActivityTimedOutEventDetails +type ActivityTimedOutEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the timeout. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s ActivityTimedOutEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ActivityTimedOutEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *ActivityTimedOutEventDetails) SetCause(v string) *ActivityTimedOutEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *ActivityTimedOutEventDetails) SetError(v string) *ActivityTimedOutEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateActivityInput +type CreateActivityInput struct { + _ struct{} `type:"structure"` + + // The name of the activity to create. This name must be unique for your AWS + // account and region. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s CreateActivityInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s CreateActivityInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *CreateActivityInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "CreateActivityInput"} + if s.Name == nil { + invalidParams.Add(request.NewErrParamRequired("Name")) + } + if s.Name != nil && len(*s.Name) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Name", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetName sets the Name field's value. +func (s *CreateActivityInput) SetName(v string) *CreateActivityInput { + s.Name = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateActivityOutput +type CreateActivityOutput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) that identifies the created activity. + // + // ActivityArn is a required field + ActivityArn *string `locationName:"activityArn" min:"1" type:"string" required:"true"` + + // The date the activity was created. + // + // CreationDate is a required field + CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix" required:"true"` +} + +// String returns the string representation +func (s CreateActivityOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s CreateActivityOutput) GoString() string { + return s.String() +} + +// SetActivityArn sets the ActivityArn field's value. +func (s *CreateActivityOutput) SetActivityArn(v string) *CreateActivityOutput { + s.ActivityArn = &v + return s +} + +// SetCreationDate sets the CreationDate field's value. +func (s *CreateActivityOutput) SetCreationDate(v time.Time) *CreateActivityOutput { + s.CreationDate = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateStateMachineInput +type CreateStateMachineInput struct { + _ struct{} `type:"structure"` + + // The Amazon States Language definition of the state machine. + // + // Definition is a required field + Definition *string `locationName:"definition" min:"1" type:"string" required:"true"` + + // The name of the state machine. This name must be unique for your AWS account + // and region. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` + + // The Amazon Resource Name (ARN) of the IAM role to use for this state machine. + // + // RoleArn is a required field + RoleArn *string `locationName:"roleArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s CreateStateMachineInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s CreateStateMachineInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *CreateStateMachineInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "CreateStateMachineInput"} + if s.Definition == nil { + invalidParams.Add(request.NewErrParamRequired("Definition")) + } + if s.Definition != nil && len(*s.Definition) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Definition", 1)) + } + if s.Name == nil { + invalidParams.Add(request.NewErrParamRequired("Name")) + } + if s.Name != nil && len(*s.Name) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Name", 1)) + } + if s.RoleArn == nil { + invalidParams.Add(request.NewErrParamRequired("RoleArn")) + } + if s.RoleArn != nil && len(*s.RoleArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("RoleArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetDefinition sets the Definition field's value. +func (s *CreateStateMachineInput) SetDefinition(v string) *CreateStateMachineInput { + s.Definition = &v + return s +} + +// SetName sets the Name field's value. +func (s *CreateStateMachineInput) SetName(v string) *CreateStateMachineInput { + s.Name = &v + return s +} + +// SetRoleArn sets the RoleArn field's value. +func (s *CreateStateMachineInput) SetRoleArn(v string) *CreateStateMachineInput { + s.RoleArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/CreateStateMachineOutput +type CreateStateMachineOutput struct { + _ struct{} `type:"structure"` + + // The date the state machine was created. + // + // CreationDate is a required field + CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The Amazon Resource Name (ARN) that identifies the created state machine. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s CreateStateMachineOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s CreateStateMachineOutput) GoString() string { + return s.String() +} + +// SetCreationDate sets the CreationDate field's value. +func (s *CreateStateMachineOutput) SetCreationDate(v time.Time) *CreateStateMachineOutput { + s.CreationDate = &v + return s +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *CreateStateMachineOutput) SetStateMachineArn(v string) *CreateStateMachineOutput { + s.StateMachineArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteActivityInput +type DeleteActivityInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the activity to delete. + // + // ActivityArn is a required field + ActivityArn *string `locationName:"activityArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s DeleteActivityInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DeleteActivityInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DeleteActivityInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DeleteActivityInput"} + if s.ActivityArn == nil { + invalidParams.Add(request.NewErrParamRequired("ActivityArn")) + } + if s.ActivityArn != nil && len(*s.ActivityArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ActivityArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetActivityArn sets the ActivityArn field's value. +func (s *DeleteActivityInput) SetActivityArn(v string) *DeleteActivityInput { + s.ActivityArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteActivityOutput +type DeleteActivityOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation +func (s DeleteActivityOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DeleteActivityOutput) GoString() string { + return s.String() +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteStateMachineInput +type DeleteStateMachineInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the state machine to delete. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s DeleteStateMachineInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DeleteStateMachineInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DeleteStateMachineInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DeleteStateMachineInput"} + if s.StateMachineArn == nil { + invalidParams.Add(request.NewErrParamRequired("StateMachineArn")) + } + if s.StateMachineArn != nil && len(*s.StateMachineArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("StateMachineArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *DeleteStateMachineInput) SetStateMachineArn(v string) *DeleteStateMachineInput { + s.StateMachineArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DeleteStateMachineOutput +type DeleteStateMachineOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation +func (s DeleteStateMachineOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DeleteStateMachineOutput) GoString() string { + return s.String() +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeActivityInput +type DescribeActivityInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the activity to describe. + // + // ActivityArn is a required field + ActivityArn *string `locationName:"activityArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s DescribeActivityInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeActivityInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DescribeActivityInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DescribeActivityInput"} + if s.ActivityArn == nil { + invalidParams.Add(request.NewErrParamRequired("ActivityArn")) + } + if s.ActivityArn != nil && len(*s.ActivityArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ActivityArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetActivityArn sets the ActivityArn field's value. +func (s *DescribeActivityInput) SetActivityArn(v string) *DescribeActivityInput { + s.ActivityArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeActivityOutput +type DescribeActivityOutput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) that identifies the activity. + // + // ActivityArn is a required field + ActivityArn *string `locationName:"activityArn" min:"1" type:"string" required:"true"` + + // The date the activity was created. + // + // CreationDate is a required field + CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The name of the activity. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s DescribeActivityOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeActivityOutput) GoString() string { + return s.String() +} + +// SetActivityArn sets the ActivityArn field's value. +func (s *DescribeActivityOutput) SetActivityArn(v string) *DescribeActivityOutput { + s.ActivityArn = &v + return s +} + +// SetCreationDate sets the CreationDate field's value. +func (s *DescribeActivityOutput) SetCreationDate(v time.Time) *DescribeActivityOutput { + s.CreationDate = &v + return s +} + +// SetName sets the Name field's value. +func (s *DescribeActivityOutput) SetName(v string) *DescribeActivityOutput { + s.Name = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeExecutionInput +type DescribeExecutionInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the execution to describe. + // + // ExecutionArn is a required field + ExecutionArn *string `locationName:"executionArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s DescribeExecutionInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeExecutionInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DescribeExecutionInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DescribeExecutionInput"} + if s.ExecutionArn == nil { + invalidParams.Add(request.NewErrParamRequired("ExecutionArn")) + } + if s.ExecutionArn != nil && len(*s.ExecutionArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ExecutionArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetExecutionArn sets the ExecutionArn field's value. +func (s *DescribeExecutionInput) SetExecutionArn(v string) *DescribeExecutionInput { + s.ExecutionArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeExecutionOutput +type DescribeExecutionOutput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) that identifies the execution. + // + // ExecutionArn is a required field + ExecutionArn *string `locationName:"executionArn" min:"1" type:"string" required:"true"` + + // The JSON input data of the execution. + // + // Input is a required field + Input *string `locationName:"input" type:"string" required:"true"` + + // The name of the execution. + Name *string `locationName:"name" min:"1" type:"string"` + + // The JSON output data of the execution. + Output *string `locationName:"output" type:"string"` + + // The date the execution was started. + // + // StartDate is a required field + StartDate *time.Time `locationName:"startDate" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The Amazon Resource Name (ARN) of the executed stated machine. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` + + // The current status of the execution. + // + // Status is a required field + Status *string `locationName:"status" type:"string" required:"true" enum:"ExecutionStatus"` + + // If the execution has already ended, the date the execution stopped. + StopDate *time.Time `locationName:"stopDate" type:"timestamp" timestampFormat:"unix"` +} + +// String returns the string representation +func (s DescribeExecutionOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeExecutionOutput) GoString() string { + return s.String() +} + +// SetExecutionArn sets the ExecutionArn field's value. +func (s *DescribeExecutionOutput) SetExecutionArn(v string) *DescribeExecutionOutput { + s.ExecutionArn = &v + return s +} + +// SetInput sets the Input field's value. +func (s *DescribeExecutionOutput) SetInput(v string) *DescribeExecutionOutput { + s.Input = &v + return s +} + +// SetName sets the Name field's value. +func (s *DescribeExecutionOutput) SetName(v string) *DescribeExecutionOutput { + s.Name = &v + return s +} + +// SetOutput sets the Output field's value. +func (s *DescribeExecutionOutput) SetOutput(v string) *DescribeExecutionOutput { + s.Output = &v + return s +} + +// SetStartDate sets the StartDate field's value. +func (s *DescribeExecutionOutput) SetStartDate(v time.Time) *DescribeExecutionOutput { + s.StartDate = &v + return s +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *DescribeExecutionOutput) SetStateMachineArn(v string) *DescribeExecutionOutput { + s.StateMachineArn = &v + return s +} + +// SetStatus sets the Status field's value. +func (s *DescribeExecutionOutput) SetStatus(v string) *DescribeExecutionOutput { + s.Status = &v + return s +} + +// SetStopDate sets the StopDate field's value. +func (s *DescribeExecutionOutput) SetStopDate(v time.Time) *DescribeExecutionOutput { + s.StopDate = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeStateMachineInput +type DescribeStateMachineInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the state machine to describe. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s DescribeStateMachineInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeStateMachineInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *DescribeStateMachineInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "DescribeStateMachineInput"} + if s.StateMachineArn == nil { + invalidParams.Add(request.NewErrParamRequired("StateMachineArn")) + } + if s.StateMachineArn != nil && len(*s.StateMachineArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("StateMachineArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *DescribeStateMachineInput) SetStateMachineArn(v string) *DescribeStateMachineInput { + s.StateMachineArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/DescribeStateMachineOutput +type DescribeStateMachineOutput struct { + _ struct{} `type:"structure"` + + // The date the state machine was created. + // + // CreationDate is a required field + CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The Amazon States Language definition of the state machine. + // + // Definition is a required field + Definition *string `locationName:"definition" min:"1" type:"string" required:"true"` + + // The name of the state machine. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` + + // The Amazon Resource Name (ARN) of the IAM role used for executing this state + // machine. + // + // RoleArn is a required field + RoleArn *string `locationName:"roleArn" min:"1" type:"string" required:"true"` + + // The Amazon Resource Name (ARN) that identifies the state machine. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` + + // The current status of the state machine. + Status *string `locationName:"status" type:"string" enum:"StateMachineStatus"` +} + +// String returns the string representation +func (s DescribeStateMachineOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s DescribeStateMachineOutput) GoString() string { + return s.String() +} + +// SetCreationDate sets the CreationDate field's value. +func (s *DescribeStateMachineOutput) SetCreationDate(v time.Time) *DescribeStateMachineOutput { + s.CreationDate = &v + return s +} + +// SetDefinition sets the Definition field's value. +func (s *DescribeStateMachineOutput) SetDefinition(v string) *DescribeStateMachineOutput { + s.Definition = &v + return s +} + +// SetName sets the Name field's value. +func (s *DescribeStateMachineOutput) SetName(v string) *DescribeStateMachineOutput { + s.Name = &v + return s +} + +// SetRoleArn sets the RoleArn field's value. +func (s *DescribeStateMachineOutput) SetRoleArn(v string) *DescribeStateMachineOutput { + s.RoleArn = &v + return s +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *DescribeStateMachineOutput) SetStateMachineArn(v string) *DescribeStateMachineOutput { + s.StateMachineArn = &v + return s +} + +// SetStatus sets the Status field's value. +func (s *DescribeStateMachineOutput) SetStatus(v string) *DescribeStateMachineOutput { + s.Status = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ExecutionAbortedEventDetails +type ExecutionAbortedEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s ExecutionAbortedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ExecutionAbortedEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *ExecutionAbortedEventDetails) SetCause(v string) *ExecutionAbortedEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *ExecutionAbortedEventDetails) SetError(v string) *ExecutionAbortedEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ExecutionFailedEventDetails +type ExecutionFailedEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s ExecutionFailedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ExecutionFailedEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *ExecutionFailedEventDetails) SetCause(v string) *ExecutionFailedEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *ExecutionFailedEventDetails) SetError(v string) *ExecutionFailedEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ExecutionListItem +type ExecutionListItem struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) that identifies the execution. + // + // ExecutionArn is a required field + ExecutionArn *string `locationName:"executionArn" min:"1" type:"string" required:"true"` + + // The name of the execution. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` + + // The date the execution started. + // + // StartDate is a required field + StartDate *time.Time `locationName:"startDate" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The Amazon Resource Name (ARN) of the executed state machine. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` + + // The current status of the execution. + // + // Status is a required field + Status *string `locationName:"status" type:"string" required:"true" enum:"ExecutionStatus"` + + // If the execution already ended, the date the execution stopped. + StopDate *time.Time `locationName:"stopDate" type:"timestamp" timestampFormat:"unix"` +} + +// String returns the string representation +func (s ExecutionListItem) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ExecutionListItem) GoString() string { + return s.String() +} + +// SetExecutionArn sets the ExecutionArn field's value. +func (s *ExecutionListItem) SetExecutionArn(v string) *ExecutionListItem { + s.ExecutionArn = &v + return s +} + +// SetName sets the Name field's value. +func (s *ExecutionListItem) SetName(v string) *ExecutionListItem { + s.Name = &v + return s +} + +// SetStartDate sets the StartDate field's value. +func (s *ExecutionListItem) SetStartDate(v time.Time) *ExecutionListItem { + s.StartDate = &v + return s +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *ExecutionListItem) SetStateMachineArn(v string) *ExecutionListItem { + s.StateMachineArn = &v + return s +} + +// SetStatus sets the Status field's value. +func (s *ExecutionListItem) SetStatus(v string) *ExecutionListItem { + s.Status = &v + return s +} + +// SetStopDate sets the StopDate field's value. +func (s *ExecutionListItem) SetStopDate(v time.Time) *ExecutionListItem { + s.StopDate = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ExecutionStartedEventDetails +type ExecutionStartedEventDetails struct { + _ struct{} `type:"structure"` + + // The JSON data input to the execution. + Input *string `locationName:"input" type:"string"` + + // The Amazon Resource Name (ARN) of the IAM role used for executing AWS Lambda + // tasks. + RoleArn *string `locationName:"roleArn" min:"1" type:"string"` +} + +// String returns the string representation +func (s ExecutionStartedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ExecutionStartedEventDetails) GoString() string { + return s.String() +} + +// SetInput sets the Input field's value. +func (s *ExecutionStartedEventDetails) SetInput(v string) *ExecutionStartedEventDetails { + s.Input = &v + return s +} + +// SetRoleArn sets the RoleArn field's value. +func (s *ExecutionStartedEventDetails) SetRoleArn(v string) *ExecutionStartedEventDetails { + s.RoleArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ExecutionSucceededEventDetails +type ExecutionSucceededEventDetails struct { + _ struct{} `type:"structure"` + + // The JSON data output by the execution. + Output *string `locationName:"output" type:"string"` +} + +// String returns the string representation +func (s ExecutionSucceededEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ExecutionSucceededEventDetails) GoString() string { + return s.String() +} + +// SetOutput sets the Output field's value. +func (s *ExecutionSucceededEventDetails) SetOutput(v string) *ExecutionSucceededEventDetails { + s.Output = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ExecutionTimedOutEventDetails +type ExecutionTimedOutEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the timeout. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s ExecutionTimedOutEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ExecutionTimedOutEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *ExecutionTimedOutEventDetails) SetCause(v string) *ExecutionTimedOutEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *ExecutionTimedOutEventDetails) SetError(v string) *ExecutionTimedOutEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetActivityTaskInput +type GetActivityTaskInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the activity to retrieve tasks from. + // + // ActivityArn is a required field + ActivityArn *string `locationName:"activityArn" min:"1" type:"string" required:"true"` + + // An arbitrary name may be provided in order to identify the worker that the + // task is assigned to. This name will be used when it is logged in the execution + // history. + WorkerName *string `locationName:"workerName" min:"1" type:"string"` +} + +// String returns the string representation +func (s GetActivityTaskInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s GetActivityTaskInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *GetActivityTaskInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "GetActivityTaskInput"} + if s.ActivityArn == nil { + invalidParams.Add(request.NewErrParamRequired("ActivityArn")) + } + if s.ActivityArn != nil && len(*s.ActivityArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ActivityArn", 1)) + } + if s.WorkerName != nil && len(*s.WorkerName) < 1 { + invalidParams.Add(request.NewErrParamMinLen("WorkerName", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetActivityArn sets the ActivityArn field's value. +func (s *GetActivityTaskInput) SetActivityArn(v string) *GetActivityTaskInput { + s.ActivityArn = &v + return s +} + +// SetWorkerName sets the WorkerName field's value. +func (s *GetActivityTaskInput) SetWorkerName(v string) *GetActivityTaskInput { + s.WorkerName = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetActivityTaskOutput +type GetActivityTaskOutput struct { + _ struct{} `type:"structure"` + + // The JSON input data for the task. + Input *string `locationName:"input" type:"string"` + + // A token that identifies the scheduled task. This token must be copied and + // included in subsequent calls to SendTaskHeartbeat, SendTaskSuccess or SendTaskFailure + // in order to report the progress or completion of the task. + TaskToken *string `locationName:"taskToken" min:"1" type:"string"` +} + +// String returns the string representation +func (s GetActivityTaskOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s GetActivityTaskOutput) GoString() string { + return s.String() +} + +// SetInput sets the Input field's value. +func (s *GetActivityTaskOutput) SetInput(v string) *GetActivityTaskOutput { + s.Input = &v + return s +} + +// SetTaskToken sets the TaskToken field's value. +func (s *GetActivityTaskOutput) SetTaskToken(v string) *GetActivityTaskOutput { + s.TaskToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetExecutionHistoryInput +type GetExecutionHistoryInput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) of the execution. + // + // ExecutionArn is a required field + ExecutionArn *string `locationName:"executionArn" min:"1" type:"string" required:"true"` + + // The maximum number of results that will be returned per call. nextToken can + // be used to obtain further pages of results. The default is 100 and the maximum + // allowed page size is 1000. + // + // This is an upper limit only; the actual number of results returned per call + // may be fewer than the specified maximum. + MaxResults *int64 `locationName:"maxResults" type:"integer"` + + // If a nextToken was returned by a previous call, there are more results available. + // To retrieve the next page of results, make the call again using the returned + // token in nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` + + // Lists events in descending order of their timeStamp. + ReverseOrder *bool `locationName:"reverseOrder" type:"boolean"` +} + +// String returns the string representation +func (s GetExecutionHistoryInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s GetExecutionHistoryInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *GetExecutionHistoryInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "GetExecutionHistoryInput"} + if s.ExecutionArn == nil { + invalidParams.Add(request.NewErrParamRequired("ExecutionArn")) + } + if s.ExecutionArn != nil && len(*s.ExecutionArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ExecutionArn", 1)) + } + if s.NextToken != nil && len(*s.NextToken) < 1 { + invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetExecutionArn sets the ExecutionArn field's value. +func (s *GetExecutionHistoryInput) SetExecutionArn(v string) *GetExecutionHistoryInput { + s.ExecutionArn = &v + return s +} + +// SetMaxResults sets the MaxResults field's value. +func (s *GetExecutionHistoryInput) SetMaxResults(v int64) *GetExecutionHistoryInput { + s.MaxResults = &v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *GetExecutionHistoryInput) SetNextToken(v string) *GetExecutionHistoryInput { + s.NextToken = &v + return s +} + +// SetReverseOrder sets the ReverseOrder field's value. +func (s *GetExecutionHistoryInput) SetReverseOrder(v bool) *GetExecutionHistoryInput { + s.ReverseOrder = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/GetExecutionHistoryOutput +type GetExecutionHistoryOutput struct { + _ struct{} `type:"structure"` + + // The list of events that occurred in the execution. + // + // Events is a required field + Events []*HistoryEvent `locationName:"events" type:"list" required:"true"` + + // If a nextToken is returned, there are more results available. To retrieve + // the next page of results, make the call again using the returned token in + // nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` +} + +// String returns the string representation +func (s GetExecutionHistoryOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s GetExecutionHistoryOutput) GoString() string { + return s.String() +} + +// SetEvents sets the Events field's value. +func (s *GetExecutionHistoryOutput) SetEvents(v []*HistoryEvent) *GetExecutionHistoryOutput { + s.Events = v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *GetExecutionHistoryOutput) SetNextToken(v string) *GetExecutionHistoryOutput { + s.NextToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/HistoryEvent +type HistoryEvent struct { + _ struct{} `type:"structure"` + + ActivityFailedEventDetails *ActivityFailedEventDetails `locationName:"activityFailedEventDetails" type:"structure"` + + ActivityScheduleFailedEventDetails *ActivityScheduleFailedEventDetails `locationName:"activityScheduleFailedEventDetails" type:"structure"` + + ActivityScheduledEventDetails *ActivityScheduledEventDetails `locationName:"activityScheduledEventDetails" type:"structure"` + + ActivityStartedEventDetails *ActivityStartedEventDetails `locationName:"activityStartedEventDetails" type:"structure"` + + ActivitySucceededEventDetails *ActivitySucceededEventDetails `locationName:"activitySucceededEventDetails" type:"structure"` + + ActivityTimedOutEventDetails *ActivityTimedOutEventDetails `locationName:"activityTimedOutEventDetails" type:"structure"` + + ExecutionAbortedEventDetails *ExecutionAbortedEventDetails `locationName:"executionAbortedEventDetails" type:"structure"` + + ExecutionFailedEventDetails *ExecutionFailedEventDetails `locationName:"executionFailedEventDetails" type:"structure"` + + ExecutionStartedEventDetails *ExecutionStartedEventDetails `locationName:"executionStartedEventDetails" type:"structure"` + + ExecutionSucceededEventDetails *ExecutionSucceededEventDetails `locationName:"executionSucceededEventDetails" type:"structure"` + + ExecutionTimedOutEventDetails *ExecutionTimedOutEventDetails `locationName:"executionTimedOutEventDetails" type:"structure"` + + // The id of the event. Events are numbered sequentially, starting at one. + // + // Id is a required field + Id *int64 `locationName:"id" type:"long" required:"true"` + + LambdaFunctionFailedEventDetails *LambdaFunctionFailedEventDetails `locationName:"lambdaFunctionFailedEventDetails" type:"structure"` + + LambdaFunctionScheduleFailedEventDetails *LambdaFunctionScheduleFailedEventDetails `locationName:"lambdaFunctionScheduleFailedEventDetails" type:"structure"` + + LambdaFunctionScheduledEventDetails *LambdaFunctionScheduledEventDetails `locationName:"lambdaFunctionScheduledEventDetails" type:"structure"` + + LambdaFunctionStartFailedEventDetails *LambdaFunctionStartFailedEventDetails `locationName:"lambdaFunctionStartFailedEventDetails" type:"structure"` + + LambdaFunctionSucceededEventDetails *LambdaFunctionSucceededEventDetails `locationName:"lambdaFunctionSucceededEventDetails" type:"structure"` + + LambdaFunctionTimedOutEventDetails *LambdaFunctionTimedOutEventDetails `locationName:"lambdaFunctionTimedOutEventDetails" type:"structure"` + + // The id of the previous event. + PreviousEventId *int64 `locationName:"previousEventId" type:"long"` + + StateEnteredEventDetails *StateEnteredEventDetails `locationName:"stateEnteredEventDetails" type:"structure"` + + StateExitedEventDetails *StateExitedEventDetails `locationName:"stateExitedEventDetails" type:"structure"` + + // The date the event occured. + // + // Timestamp is a required field + Timestamp *time.Time `locationName:"timestamp" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The type of the event. + // + // Type is a required field + Type *string `locationName:"type" type:"string" required:"true" enum:"HistoryEventType"` +} + +// String returns the string representation +func (s HistoryEvent) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s HistoryEvent) GoString() string { + return s.String() +} + +// SetActivityFailedEventDetails sets the ActivityFailedEventDetails field's value. +func (s *HistoryEvent) SetActivityFailedEventDetails(v *ActivityFailedEventDetails) *HistoryEvent { + s.ActivityFailedEventDetails = v + return s +} + +// SetActivityScheduleFailedEventDetails sets the ActivityScheduleFailedEventDetails field's value. +func (s *HistoryEvent) SetActivityScheduleFailedEventDetails(v *ActivityScheduleFailedEventDetails) *HistoryEvent { + s.ActivityScheduleFailedEventDetails = v + return s +} + +// SetActivityScheduledEventDetails sets the ActivityScheduledEventDetails field's value. +func (s *HistoryEvent) SetActivityScheduledEventDetails(v *ActivityScheduledEventDetails) *HistoryEvent { + s.ActivityScheduledEventDetails = v + return s +} + +// SetActivityStartedEventDetails sets the ActivityStartedEventDetails field's value. +func (s *HistoryEvent) SetActivityStartedEventDetails(v *ActivityStartedEventDetails) *HistoryEvent { + s.ActivityStartedEventDetails = v + return s +} + +// SetActivitySucceededEventDetails sets the ActivitySucceededEventDetails field's value. +func (s *HistoryEvent) SetActivitySucceededEventDetails(v *ActivitySucceededEventDetails) *HistoryEvent { + s.ActivitySucceededEventDetails = v + return s +} + +// SetActivityTimedOutEventDetails sets the ActivityTimedOutEventDetails field's value. +func (s *HistoryEvent) SetActivityTimedOutEventDetails(v *ActivityTimedOutEventDetails) *HistoryEvent { + s.ActivityTimedOutEventDetails = v + return s +} + +// SetExecutionAbortedEventDetails sets the ExecutionAbortedEventDetails field's value. +func (s *HistoryEvent) SetExecutionAbortedEventDetails(v *ExecutionAbortedEventDetails) *HistoryEvent { + s.ExecutionAbortedEventDetails = v + return s +} + +// SetExecutionFailedEventDetails sets the ExecutionFailedEventDetails field's value. +func (s *HistoryEvent) SetExecutionFailedEventDetails(v *ExecutionFailedEventDetails) *HistoryEvent { + s.ExecutionFailedEventDetails = v + return s +} + +// SetExecutionStartedEventDetails sets the ExecutionStartedEventDetails field's value. +func (s *HistoryEvent) SetExecutionStartedEventDetails(v *ExecutionStartedEventDetails) *HistoryEvent { + s.ExecutionStartedEventDetails = v + return s +} + +// SetExecutionSucceededEventDetails sets the ExecutionSucceededEventDetails field's value. +func (s *HistoryEvent) SetExecutionSucceededEventDetails(v *ExecutionSucceededEventDetails) *HistoryEvent { + s.ExecutionSucceededEventDetails = v + return s +} + +// SetExecutionTimedOutEventDetails sets the ExecutionTimedOutEventDetails field's value. +func (s *HistoryEvent) SetExecutionTimedOutEventDetails(v *ExecutionTimedOutEventDetails) *HistoryEvent { + s.ExecutionTimedOutEventDetails = v + return s +} + +// SetId sets the Id field's value. +func (s *HistoryEvent) SetId(v int64) *HistoryEvent { + s.Id = &v + return s +} + +// SetLambdaFunctionFailedEventDetails sets the LambdaFunctionFailedEventDetails field's value. +func (s *HistoryEvent) SetLambdaFunctionFailedEventDetails(v *LambdaFunctionFailedEventDetails) *HistoryEvent { + s.LambdaFunctionFailedEventDetails = v + return s +} + +// SetLambdaFunctionScheduleFailedEventDetails sets the LambdaFunctionScheduleFailedEventDetails field's value. +func (s *HistoryEvent) SetLambdaFunctionScheduleFailedEventDetails(v *LambdaFunctionScheduleFailedEventDetails) *HistoryEvent { + s.LambdaFunctionScheduleFailedEventDetails = v + return s +} + +// SetLambdaFunctionScheduledEventDetails sets the LambdaFunctionScheduledEventDetails field's value. +func (s *HistoryEvent) SetLambdaFunctionScheduledEventDetails(v *LambdaFunctionScheduledEventDetails) *HistoryEvent { + s.LambdaFunctionScheduledEventDetails = v + return s +} + +// SetLambdaFunctionStartFailedEventDetails sets the LambdaFunctionStartFailedEventDetails field's value. +func (s *HistoryEvent) SetLambdaFunctionStartFailedEventDetails(v *LambdaFunctionStartFailedEventDetails) *HistoryEvent { + s.LambdaFunctionStartFailedEventDetails = v + return s +} + +// SetLambdaFunctionSucceededEventDetails sets the LambdaFunctionSucceededEventDetails field's value. +func (s *HistoryEvent) SetLambdaFunctionSucceededEventDetails(v *LambdaFunctionSucceededEventDetails) *HistoryEvent { + s.LambdaFunctionSucceededEventDetails = v + return s +} + +// SetLambdaFunctionTimedOutEventDetails sets the LambdaFunctionTimedOutEventDetails field's value. +func (s *HistoryEvent) SetLambdaFunctionTimedOutEventDetails(v *LambdaFunctionTimedOutEventDetails) *HistoryEvent { + s.LambdaFunctionTimedOutEventDetails = v + return s +} + +// SetPreviousEventId sets the PreviousEventId field's value. +func (s *HistoryEvent) SetPreviousEventId(v int64) *HistoryEvent { + s.PreviousEventId = &v + return s +} + +// SetStateEnteredEventDetails sets the StateEnteredEventDetails field's value. +func (s *HistoryEvent) SetStateEnteredEventDetails(v *StateEnteredEventDetails) *HistoryEvent { + s.StateEnteredEventDetails = v + return s +} + +// SetStateExitedEventDetails sets the StateExitedEventDetails field's value. +func (s *HistoryEvent) SetStateExitedEventDetails(v *StateExitedEventDetails) *HistoryEvent { + s.StateExitedEventDetails = v + return s +} + +// SetTimestamp sets the Timestamp field's value. +func (s *HistoryEvent) SetTimestamp(v time.Time) *HistoryEvent { + s.Timestamp = &v + return s +} + +// SetType sets the Type field's value. +func (s *HistoryEvent) SetType(v string) *HistoryEvent { + s.Type = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/LambdaFunctionFailedEventDetails +type LambdaFunctionFailedEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s LambdaFunctionFailedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s LambdaFunctionFailedEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *LambdaFunctionFailedEventDetails) SetCause(v string) *LambdaFunctionFailedEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *LambdaFunctionFailedEventDetails) SetError(v string) *LambdaFunctionFailedEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/LambdaFunctionScheduleFailedEventDetails +type LambdaFunctionScheduleFailedEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s LambdaFunctionScheduleFailedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s LambdaFunctionScheduleFailedEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *LambdaFunctionScheduleFailedEventDetails) SetCause(v string) *LambdaFunctionScheduleFailedEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *LambdaFunctionScheduleFailedEventDetails) SetError(v string) *LambdaFunctionScheduleFailedEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/LambdaFunctionScheduledEventDetails +type LambdaFunctionScheduledEventDetails struct { + _ struct{} `type:"structure"` + + // The JSON data input to the lambda function. + Input *string `locationName:"input" type:"string"` + + // The Amazon Resource Name (ARN) of the scheduled lambda function. + // + // Resource is a required field + Resource *string `locationName:"resource" min:"1" type:"string" required:"true"` + + // The maximum allowed duration of the lambda function. + TimeoutInSeconds *int64 `locationName:"timeoutInSeconds" type:"long"` +} + +// String returns the string representation +func (s LambdaFunctionScheduledEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s LambdaFunctionScheduledEventDetails) GoString() string { + return s.String() +} + +// SetInput sets the Input field's value. +func (s *LambdaFunctionScheduledEventDetails) SetInput(v string) *LambdaFunctionScheduledEventDetails { + s.Input = &v + return s +} + +// SetResource sets the Resource field's value. +func (s *LambdaFunctionScheduledEventDetails) SetResource(v string) *LambdaFunctionScheduledEventDetails { + s.Resource = &v + return s +} + +// SetTimeoutInSeconds sets the TimeoutInSeconds field's value. +func (s *LambdaFunctionScheduledEventDetails) SetTimeoutInSeconds(v int64) *LambdaFunctionScheduledEventDetails { + s.TimeoutInSeconds = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/LambdaFunctionStartFailedEventDetails +type LambdaFunctionStartFailedEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s LambdaFunctionStartFailedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s LambdaFunctionStartFailedEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *LambdaFunctionStartFailedEventDetails) SetCause(v string) *LambdaFunctionStartFailedEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *LambdaFunctionStartFailedEventDetails) SetError(v string) *LambdaFunctionStartFailedEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/LambdaFunctionSucceededEventDetails +type LambdaFunctionSucceededEventDetails struct { + _ struct{} `type:"structure"` + + // The JSON data output by the lambda function. + Output *string `locationName:"output" type:"string"` +} + +// String returns the string representation +func (s LambdaFunctionSucceededEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s LambdaFunctionSucceededEventDetails) GoString() string { + return s.String() +} + +// SetOutput sets the Output field's value. +func (s *LambdaFunctionSucceededEventDetails) SetOutput(v string) *LambdaFunctionSucceededEventDetails { + s.Output = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/LambdaFunctionTimedOutEventDetails +type LambdaFunctionTimedOutEventDetails struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the timeout. + Cause *string `locationName:"cause" type:"string"` + + // The error code of the failure. + Error *string `locationName:"error" type:"string"` +} + +// String returns the string representation +func (s LambdaFunctionTimedOutEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s LambdaFunctionTimedOutEventDetails) GoString() string { + return s.String() +} + +// SetCause sets the Cause field's value. +func (s *LambdaFunctionTimedOutEventDetails) SetCause(v string) *LambdaFunctionTimedOutEventDetails { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *LambdaFunctionTimedOutEventDetails) SetError(v string) *LambdaFunctionTimedOutEventDetails { + s.Error = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListActivitiesInput +type ListActivitiesInput struct { + _ struct{} `type:"structure"` + + // The maximum number of results that will be returned per call. nextToken can + // be used to obtain further pages of results. The default is 100 and the maximum + // allowed page size is 1000. + // + // This is an upper limit only; the actual number of results returned per call + // may be fewer than the specified maximum. + MaxResults *int64 `locationName:"maxResults" type:"integer"` + + // If a nextToken was returned by a previous call, there are more results available. + // To retrieve the next page of results, make the call again using the returned + // token in nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` +} + +// String returns the string representation +func (s ListActivitiesInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ListActivitiesInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *ListActivitiesInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "ListActivitiesInput"} + if s.NextToken != nil && len(*s.NextToken) < 1 { + invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetMaxResults sets the MaxResults field's value. +func (s *ListActivitiesInput) SetMaxResults(v int64) *ListActivitiesInput { + s.MaxResults = &v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *ListActivitiesInput) SetNextToken(v string) *ListActivitiesInput { + s.NextToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListActivitiesOutput +type ListActivitiesOutput struct { + _ struct{} `type:"structure"` + + // The list of activities. + // + // Activities is a required field + Activities []*ActivityListItem `locationName:"activities" type:"list" required:"true"` + + // If a nextToken is returned, there are more results available. To retrieve + // the next page of results, make the call again using the returned token in + // nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` +} + +// String returns the string representation +func (s ListActivitiesOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ListActivitiesOutput) GoString() string { + return s.String() +} + +// SetActivities sets the Activities field's value. +func (s *ListActivitiesOutput) SetActivities(v []*ActivityListItem) *ListActivitiesOutput { + s.Activities = v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *ListActivitiesOutput) SetNextToken(v string) *ListActivitiesOutput { + s.NextToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListExecutionsInput +type ListExecutionsInput struct { + _ struct{} `type:"structure"` + + // The maximum number of results that will be returned per call. nextToken can + // be used to obtain further pages of results. The default is 100 and the maximum + // allowed page size is 1000. + // + // This is an upper limit only; the actual number of results returned per call + // may be fewer than the specified maximum. + MaxResults *int64 `locationName:"maxResults" type:"integer"` + + // If a nextToken was returned by a previous call, there are more results available. + // To retrieve the next page of results, make the call again using the returned + // token in nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` + + // The Amazon Resource Name (ARN) of the state machine whose executions will + // be listed. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` + + // If specified, only list the executions whose current execution status matches + // the given filter. + StatusFilter *string `locationName:"statusFilter" type:"string" enum:"ExecutionStatus"` +} + +// String returns the string representation +func (s ListExecutionsInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ListExecutionsInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *ListExecutionsInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "ListExecutionsInput"} + if s.NextToken != nil && len(*s.NextToken) < 1 { + invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) + } + if s.StateMachineArn == nil { + invalidParams.Add(request.NewErrParamRequired("StateMachineArn")) + } + if s.StateMachineArn != nil && len(*s.StateMachineArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("StateMachineArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetMaxResults sets the MaxResults field's value. +func (s *ListExecutionsInput) SetMaxResults(v int64) *ListExecutionsInput { + s.MaxResults = &v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *ListExecutionsInput) SetNextToken(v string) *ListExecutionsInput { + s.NextToken = &v + return s +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *ListExecutionsInput) SetStateMachineArn(v string) *ListExecutionsInput { + s.StateMachineArn = &v + return s +} + +// SetStatusFilter sets the StatusFilter field's value. +func (s *ListExecutionsInput) SetStatusFilter(v string) *ListExecutionsInput { + s.StatusFilter = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListExecutionsOutput +type ListExecutionsOutput struct { + _ struct{} `type:"structure"` + + // The list of matching executions. + // + // Executions is a required field + Executions []*ExecutionListItem `locationName:"executions" type:"list" required:"true"` + + // If a nextToken is returned, there are more results available. To retrieve + // the next page of results, make the call again using the returned token in + // nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` +} + +// String returns the string representation +func (s ListExecutionsOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ListExecutionsOutput) GoString() string { + return s.String() +} + +// SetExecutions sets the Executions field's value. +func (s *ListExecutionsOutput) SetExecutions(v []*ExecutionListItem) *ListExecutionsOutput { + s.Executions = v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *ListExecutionsOutput) SetNextToken(v string) *ListExecutionsOutput { + s.NextToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListStateMachinesInput +type ListStateMachinesInput struct { + _ struct{} `type:"structure"` + + // The maximum number of results that will be returned per call. nextToken can + // be used to obtain further pages of results. The default is 100 and the maximum + // allowed page size is 1000. + // + // This is an upper limit only; the actual number of results returned per call + // may be fewer than the specified maximum. + MaxResults *int64 `locationName:"maxResults" type:"integer"` + + // If a nextToken was returned by a previous call, there are more results available. + // To retrieve the next page of results, make the call again using the returned + // token in nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` +} + +// String returns the string representation +func (s ListStateMachinesInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ListStateMachinesInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *ListStateMachinesInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "ListStateMachinesInput"} + if s.NextToken != nil && len(*s.NextToken) < 1 { + invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetMaxResults sets the MaxResults field's value. +func (s *ListStateMachinesInput) SetMaxResults(v int64) *ListStateMachinesInput { + s.MaxResults = &v + return s +} + +// SetNextToken sets the NextToken field's value. +func (s *ListStateMachinesInput) SetNextToken(v string) *ListStateMachinesInput { + s.NextToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/ListStateMachinesOutput +type ListStateMachinesOutput struct { + _ struct{} `type:"structure"` + + // If a nextToken is returned, there are more results available. To retrieve + // the next page of results, make the call again using the returned token in + // nextToken. Keep all other arguments unchanged. + // + // The configured maxResults determines how many results can be returned in + // a single call. + NextToken *string `locationName:"nextToken" min:"1" type:"string"` + + // StateMachines is a required field + StateMachines []*StateMachineListItem `locationName:"stateMachines" type:"list" required:"true"` +} + +// String returns the string representation +func (s ListStateMachinesOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s ListStateMachinesOutput) GoString() string { + return s.String() +} + +// SetNextToken sets the NextToken field's value. +func (s *ListStateMachinesOutput) SetNextToken(v string) *ListStateMachinesOutput { + s.NextToken = &v + return s +} + +// SetStateMachines sets the StateMachines field's value. +func (s *ListStateMachinesOutput) SetStateMachines(v []*StateMachineListItem) *ListStateMachinesOutput { + s.StateMachines = v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskFailureInput +type SendTaskFailureInput struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the failure. + Cause *string `locationName:"cause" type:"string"` + + // An arbitrary error code that identifies the cause of the failure. + Error *string `locationName:"error" type:"string"` + + // The token that represents this task. Task tokens are generated by the service + // when the tasks are assigned to a worker (see GetActivityTask::taskToken). + // + // TaskToken is a required field + TaskToken *string `locationName:"taskToken" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s SendTaskFailureInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s SendTaskFailureInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *SendTaskFailureInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "SendTaskFailureInput"} + if s.TaskToken == nil { + invalidParams.Add(request.NewErrParamRequired("TaskToken")) + } + if s.TaskToken != nil && len(*s.TaskToken) < 1 { + invalidParams.Add(request.NewErrParamMinLen("TaskToken", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetCause sets the Cause field's value. +func (s *SendTaskFailureInput) SetCause(v string) *SendTaskFailureInput { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *SendTaskFailureInput) SetError(v string) *SendTaskFailureInput { + s.Error = &v + return s +} + +// SetTaskToken sets the TaskToken field's value. +func (s *SendTaskFailureInput) SetTaskToken(v string) *SendTaskFailureInput { + s.TaskToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskFailureOutput +type SendTaskFailureOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation +func (s SendTaskFailureOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s SendTaskFailureOutput) GoString() string { + return s.String() +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskHeartbeatInput +type SendTaskHeartbeatInput struct { + _ struct{} `type:"structure"` + + // The token that represents this task. Task tokens are generated by the service + // when the tasks are assigned to a worker (see GetActivityTask::taskToken). + // + // TaskToken is a required field + TaskToken *string `locationName:"taskToken" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s SendTaskHeartbeatInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s SendTaskHeartbeatInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *SendTaskHeartbeatInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "SendTaskHeartbeatInput"} + if s.TaskToken == nil { + invalidParams.Add(request.NewErrParamRequired("TaskToken")) + } + if s.TaskToken != nil && len(*s.TaskToken) < 1 { + invalidParams.Add(request.NewErrParamMinLen("TaskToken", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetTaskToken sets the TaskToken field's value. +func (s *SendTaskHeartbeatInput) SetTaskToken(v string) *SendTaskHeartbeatInput { + s.TaskToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskHeartbeatOutput +type SendTaskHeartbeatOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation +func (s SendTaskHeartbeatOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s SendTaskHeartbeatOutput) GoString() string { + return s.String() +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskSuccessInput +type SendTaskSuccessInput struct { + _ struct{} `type:"structure"` + + // The JSON output of the task. + // + // Output is a required field + Output *string `locationName:"output" type:"string" required:"true"` + + // The token that represents this task. Task tokens are generated by the service + // when the tasks are assigned to a worker (see GetActivityTask::taskToken). + // + // TaskToken is a required field + TaskToken *string `locationName:"taskToken" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s SendTaskSuccessInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s SendTaskSuccessInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *SendTaskSuccessInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "SendTaskSuccessInput"} + if s.Output == nil { + invalidParams.Add(request.NewErrParamRequired("Output")) + } + if s.TaskToken == nil { + invalidParams.Add(request.NewErrParamRequired("TaskToken")) + } + if s.TaskToken != nil && len(*s.TaskToken) < 1 { + invalidParams.Add(request.NewErrParamMinLen("TaskToken", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetOutput sets the Output field's value. +func (s *SendTaskSuccessInput) SetOutput(v string) *SendTaskSuccessInput { + s.Output = &v + return s +} + +// SetTaskToken sets the TaskToken field's value. +func (s *SendTaskSuccessInput) SetTaskToken(v string) *SendTaskSuccessInput { + s.TaskToken = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskSuccessOutput +type SendTaskSuccessOutput struct { + _ struct{} `type:"structure"` +} + +// String returns the string representation +func (s SendTaskSuccessOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s SendTaskSuccessOutput) GoString() string { + return s.String() +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StartExecutionInput +type StartExecutionInput struct { + _ struct{} `type:"structure"` + + // The JSON input data for the execution. + Input *string `locationName:"input" type:"string"` + + // The name of the execution. This name must be unique for your AWS account + // and region. + Name *string `locationName:"name" min:"1" type:"string"` + + // The Amazon Resource Name (ARN) of the state machine to execute. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s StartExecutionInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s StartExecutionInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *StartExecutionInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "StartExecutionInput"} + if s.Name != nil && len(*s.Name) < 1 { + invalidParams.Add(request.NewErrParamMinLen("Name", 1)) + } + if s.StateMachineArn == nil { + invalidParams.Add(request.NewErrParamRequired("StateMachineArn")) + } + if s.StateMachineArn != nil && len(*s.StateMachineArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("StateMachineArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetInput sets the Input field's value. +func (s *StartExecutionInput) SetInput(v string) *StartExecutionInput { + s.Input = &v + return s +} + +// SetName sets the Name field's value. +func (s *StartExecutionInput) SetName(v string) *StartExecutionInput { + s.Name = &v + return s +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *StartExecutionInput) SetStateMachineArn(v string) *StartExecutionInput { + s.StateMachineArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StartExecutionOutput +type StartExecutionOutput struct { + _ struct{} `type:"structure"` + + // The Amazon Resource Name (ARN) that identifies the execution. + // + // ExecutionArn is a required field + ExecutionArn *string `locationName:"executionArn" min:"1" type:"string" required:"true"` + + // The date the execution was started. + // + // StartDate is a required field + StartDate *time.Time `locationName:"startDate" type:"timestamp" timestampFormat:"unix" required:"true"` +} + +// String returns the string representation +func (s StartExecutionOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s StartExecutionOutput) GoString() string { + return s.String() +} + +// SetExecutionArn sets the ExecutionArn field's value. +func (s *StartExecutionOutput) SetExecutionArn(v string) *StartExecutionOutput { + s.ExecutionArn = &v + return s +} + +// SetStartDate sets the StartDate field's value. +func (s *StartExecutionOutput) SetStartDate(v time.Time) *StartExecutionOutput { + s.StartDate = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StateEnteredEventDetails +type StateEnteredEventDetails struct { + _ struct{} `type:"structure"` + + // The JSON input data to the state. + Input *string `locationName:"input" type:"string"` + + // The name of the state. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s StateEnteredEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s StateEnteredEventDetails) GoString() string { + return s.String() +} + +// SetInput sets the Input field's value. +func (s *StateEnteredEventDetails) SetInput(v string) *StateEnteredEventDetails { + s.Input = &v + return s +} + +// SetName sets the Name field's value. +func (s *StateEnteredEventDetails) SetName(v string) *StateEnteredEventDetails { + s.Name = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StateExitedEventDetails +type StateExitedEventDetails struct { + _ struct{} `type:"structure"` + + // The name of the state. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` + + // The JSON output data of the state. + Output *string `locationName:"output" type:"string"` +} + +// String returns the string representation +func (s StateExitedEventDetails) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s StateExitedEventDetails) GoString() string { + return s.String() +} + +// SetName sets the Name field's value. +func (s *StateExitedEventDetails) SetName(v string) *StateExitedEventDetails { + s.Name = &v + return s +} + +// SetOutput sets the Output field's value. +func (s *StateExitedEventDetails) SetOutput(v string) *StateExitedEventDetails { + s.Output = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StateMachineListItem +type StateMachineListItem struct { + _ struct{} `type:"structure"` + + // The date the state machine was created. + // + // CreationDate is a required field + CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix" required:"true"` + + // The name of the state machine. + // + // Name is a required field + Name *string `locationName:"name" min:"1" type:"string" required:"true"` + + // The Amazon Resource Name (ARN) that identifies the state machine. + // + // StateMachineArn is a required field + StateMachineArn *string `locationName:"stateMachineArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s StateMachineListItem) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s StateMachineListItem) GoString() string { + return s.String() +} + +// SetCreationDate sets the CreationDate field's value. +func (s *StateMachineListItem) SetCreationDate(v time.Time) *StateMachineListItem { + s.CreationDate = &v + return s +} + +// SetName sets the Name field's value. +func (s *StateMachineListItem) SetName(v string) *StateMachineListItem { + s.Name = &v + return s +} + +// SetStateMachineArn sets the StateMachineArn field's value. +func (s *StateMachineListItem) SetStateMachineArn(v string) *StateMachineListItem { + s.StateMachineArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StopExecutionInput +type StopExecutionInput struct { + _ struct{} `type:"structure"` + + // A more detailed explanation of the cause of the termination. + Cause *string `locationName:"cause" type:"string"` + + // An arbitrary error code that identifies the cause of the termination. + Error *string `locationName:"error" type:"string"` + + // The Amazon Resource Name (ARN) of the execution to stop. + // + // ExecutionArn is a required field + ExecutionArn *string `locationName:"executionArn" min:"1" type:"string" required:"true"` +} + +// String returns the string representation +func (s StopExecutionInput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s StopExecutionInput) GoString() string { + return s.String() +} + +// Validate inspects the fields of the type to determine if they are valid. +func (s *StopExecutionInput) Validate() error { + invalidParams := request.ErrInvalidParams{Context: "StopExecutionInput"} + if s.ExecutionArn == nil { + invalidParams.Add(request.NewErrParamRequired("ExecutionArn")) + } + if s.ExecutionArn != nil && len(*s.ExecutionArn) < 1 { + invalidParams.Add(request.NewErrParamMinLen("ExecutionArn", 1)) + } + + if invalidParams.Len() > 0 { + return invalidParams + } + return nil +} + +// SetCause sets the Cause field's value. +func (s *StopExecutionInput) SetCause(v string) *StopExecutionInput { + s.Cause = &v + return s +} + +// SetError sets the Error field's value. +func (s *StopExecutionInput) SetError(v string) *StopExecutionInput { + s.Error = &v + return s +} + +// SetExecutionArn sets the ExecutionArn field's value. +func (s *StopExecutionInput) SetExecutionArn(v string) *StopExecutionInput { + s.ExecutionArn = &v + return s +} + +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/StopExecutionOutput +type StopExecutionOutput struct { + _ struct{} `type:"structure"` + + // The date the execution was stopped. + // + // StopDate is a required field + StopDate *time.Time `locationName:"stopDate" type:"timestamp" timestampFormat:"unix" required:"true"` +} + +// String returns the string representation +func (s StopExecutionOutput) String() string { + return awsutil.Prettify(s) +} + +// GoString returns the string representation +func (s StopExecutionOutput) GoString() string { + return s.String() +} + +// SetStopDate sets the StopDate field's value. +func (s *StopExecutionOutput) SetStopDate(v time.Time) *StopExecutionOutput { + s.StopDate = &v + return s +} + +const ( + // ExecutionStatusRunning is a ExecutionStatus enum value + ExecutionStatusRunning = "RUNNING" + + // ExecutionStatusSucceeded is a ExecutionStatus enum value + ExecutionStatusSucceeded = "SUCCEEDED" + + // ExecutionStatusFailed is a ExecutionStatus enum value + ExecutionStatusFailed = "FAILED" + + // ExecutionStatusTimedOut is a ExecutionStatus enum value + ExecutionStatusTimedOut = "TIMED_OUT" + + // ExecutionStatusAborted is a ExecutionStatus enum value + ExecutionStatusAborted = "ABORTED" +) + +const ( + // HistoryEventTypeActivityFailed is a HistoryEventType enum value + HistoryEventTypeActivityFailed = "ActivityFailed" + + // HistoryEventTypeActivityScheduleFailed is a HistoryEventType enum value + HistoryEventTypeActivityScheduleFailed = "ActivityScheduleFailed" + + // HistoryEventTypeActivityScheduled is a HistoryEventType enum value + HistoryEventTypeActivityScheduled = "ActivityScheduled" + + // HistoryEventTypeActivityStarted is a HistoryEventType enum value + HistoryEventTypeActivityStarted = "ActivityStarted" + + // HistoryEventTypeActivitySucceeded is a HistoryEventType enum value + HistoryEventTypeActivitySucceeded = "ActivitySucceeded" + + // HistoryEventTypeActivityTimedOut is a HistoryEventType enum value + HistoryEventTypeActivityTimedOut = "ActivityTimedOut" + + // HistoryEventTypeChoiceStateEntered is a HistoryEventType enum value + HistoryEventTypeChoiceStateEntered = "ChoiceStateEntered" + + // HistoryEventTypeChoiceStateExited is a HistoryEventType enum value + HistoryEventTypeChoiceStateExited = "ChoiceStateExited" + + // HistoryEventTypeExecutionFailed is a HistoryEventType enum value + HistoryEventTypeExecutionFailed = "ExecutionFailed" + + // HistoryEventTypeExecutionStarted is a HistoryEventType enum value + HistoryEventTypeExecutionStarted = "ExecutionStarted" + + // HistoryEventTypeExecutionSucceeded is a HistoryEventType enum value + HistoryEventTypeExecutionSucceeded = "ExecutionSucceeded" + + // HistoryEventTypeExecutionAborted is a HistoryEventType enum value + HistoryEventTypeExecutionAborted = "ExecutionAborted" + + // HistoryEventTypeExecutionTimedOut is a HistoryEventType enum value + HistoryEventTypeExecutionTimedOut = "ExecutionTimedOut" + + // HistoryEventTypeFailStateEntered is a HistoryEventType enum value + HistoryEventTypeFailStateEntered = "FailStateEntered" + + // HistoryEventTypeLambdaFunctionFailed is a HistoryEventType enum value + HistoryEventTypeLambdaFunctionFailed = "LambdaFunctionFailed" + + // HistoryEventTypeLambdaFunctionScheduleFailed is a HistoryEventType enum value + HistoryEventTypeLambdaFunctionScheduleFailed = "LambdaFunctionScheduleFailed" + + // HistoryEventTypeLambdaFunctionScheduled is a HistoryEventType enum value + HistoryEventTypeLambdaFunctionScheduled = "LambdaFunctionScheduled" + + // HistoryEventTypeLambdaFunctionStartFailed is a HistoryEventType enum value + HistoryEventTypeLambdaFunctionStartFailed = "LambdaFunctionStartFailed" + + // HistoryEventTypeLambdaFunctionStarted is a HistoryEventType enum value + HistoryEventTypeLambdaFunctionStarted = "LambdaFunctionStarted" + + // HistoryEventTypeLambdaFunctionSucceeded is a HistoryEventType enum value + HistoryEventTypeLambdaFunctionSucceeded = "LambdaFunctionSucceeded" + + // HistoryEventTypeLambdaFunctionTimedOut is a HistoryEventType enum value + HistoryEventTypeLambdaFunctionTimedOut = "LambdaFunctionTimedOut" + + // HistoryEventTypeSucceedStateEntered is a HistoryEventType enum value + HistoryEventTypeSucceedStateEntered = "SucceedStateEntered" + + // HistoryEventTypeSucceedStateExited is a HistoryEventType enum value + HistoryEventTypeSucceedStateExited = "SucceedStateExited" + + // HistoryEventTypeTaskStateEntered is a HistoryEventType enum value + HistoryEventTypeTaskStateEntered = "TaskStateEntered" + + // HistoryEventTypeTaskStateExited is a HistoryEventType enum value + HistoryEventTypeTaskStateExited = "TaskStateExited" + + // HistoryEventTypePassStateEntered is a HistoryEventType enum value + HistoryEventTypePassStateEntered = "PassStateEntered" + + // HistoryEventTypePassStateExited is a HistoryEventType enum value + HistoryEventTypePassStateExited = "PassStateExited" + + // HistoryEventTypeParallelStateEntered is a HistoryEventType enum value + HistoryEventTypeParallelStateEntered = "ParallelStateEntered" + + // HistoryEventTypeParallelStateExited is a HistoryEventType enum value + HistoryEventTypeParallelStateExited = "ParallelStateExited" + + // HistoryEventTypeWaitStateEntered is a HistoryEventType enum value + HistoryEventTypeWaitStateEntered = "WaitStateEntered" + + // HistoryEventTypeWaitStateExited is a HistoryEventType enum value + HistoryEventTypeWaitStateExited = "WaitStateExited" +) + +const ( + // StateMachineStatusActive is a StateMachineStatus enum value + StateMachineStatusActive = "ACTIVE" + + // StateMachineStatusDeleting is a StateMachineStatus enum value + StateMachineStatusDeleting = "DELETING" +) diff --git a/vendor/github.com/aws/aws-sdk-go/service/sfn/service.go b/vendor/github.com/aws/aws-sdk-go/service/sfn/service.go new file mode 100644 index 000000000..77bf817e7 --- /dev/null +++ b/vendor/github.com/aws/aws-sdk-go/service/sfn/service.go @@ -0,0 +1,108 @@ +// THIS FILE IS AUTOMATICALLY GENERATED. DO NOT EDIT. + +package sfn + +import ( + "github.com/aws/aws-sdk-go/aws" + "github.com/aws/aws-sdk-go/aws/client" + "github.com/aws/aws-sdk-go/aws/client/metadata" + "github.com/aws/aws-sdk-go/aws/request" + "github.com/aws/aws-sdk-go/aws/signer/v4" + "github.com/aws/aws-sdk-go/private/protocol/jsonrpc" +) + +// AWS Step Functions is a web service that enables you to coordinate the components +// of distributed applications and microservices using visual workflows. You +// build applications from individual components that each perform a discrete +// function, or task, allowing you to scale and change applications quickly. +// Step Functions provides a graphical console to visualize the components of +// your application as a series of steps. It automatically triggers and tracks +// each step, and retries when there are errors, so your application executes +// in order and as expected, every time. Step Functions logs the state of each +// step, so when things do go wrong, you can diagnose and debug problems quickly. +// +// Step Functions manages the operations and underlying infrastructure for you +// to ensure your application is available at any scale. You can run tasks on +// the AWS cloud, on your own servers, or an any system that has access to AWS. +// Step Functions can be accessed and used with the Step Functions console, +// the AWS SDKs (included with your Beta release invitation email), or an HTTP +// API (the subject of this document). +// The service client's operations are safe to be used concurrently. +// It is not safe to mutate any of the client's properties though. +// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23 +type SFN struct { + *client.Client +} + +// Used for custom client initialization logic +var initClient func(*client.Client) + +// Used for custom request initialization logic +var initRequest func(*request.Request) + +// Service information constants +const ( + ServiceName = "states" // Service endpoint prefix API calls made to. + EndpointsID = ServiceName // Service ID for Regions and Endpoints metadata. +) + +// New creates a new instance of the SFN client with a session. +// If additional configuration is needed for the client instance use the optional +// aws.Config parameter to add your extra config. +// +// Example: +// // Create a SFN client from just a session. +// svc := sfn.New(mySession) +// +// // Create a SFN client with additional configuration +// svc := sfn.New(mySession, aws.NewConfig().WithRegion("us-west-2")) +func New(p client.ConfigProvider, cfgs ...*aws.Config) *SFN { + c := p.ClientConfig(EndpointsID, cfgs...) + return newClient(*c.Config, c.Handlers, c.Endpoint, c.SigningRegion, c.SigningName) +} + +// newClient creates, initializes and returns a new service client instance. +func newClient(cfg aws.Config, handlers request.Handlers, endpoint, signingRegion, signingName string) *SFN { + svc := &SFN{ + Client: client.New( + cfg, + metadata.ClientInfo{ + ServiceName: ServiceName, + SigningName: signingName, + SigningRegion: signingRegion, + Endpoint: endpoint, + APIVersion: "2016-11-23", + JSONVersion: "1.0", + TargetPrefix: "AWSStepFunctions", + }, + handlers, + ), + } + + // Handlers + svc.Handlers.Sign.PushBackNamed(v4.SignRequestHandler) + svc.Handlers.Build.PushBackNamed(jsonrpc.BuildHandler) + svc.Handlers.Unmarshal.PushBackNamed(jsonrpc.UnmarshalHandler) + svc.Handlers.UnmarshalMeta.PushBackNamed(jsonrpc.UnmarshalMetaHandler) + svc.Handlers.UnmarshalError.PushBackNamed(jsonrpc.UnmarshalErrorHandler) + + // Run custom client initialization if present + if initClient != nil { + initClient(svc.Client) + } + + return svc +} + +// newRequest creates a new request for a SFN operation and runs any +// custom request initialization. +func (c *SFN) newRequest(op *request.Operation, params, data interface{}) *request.Request { + req := c.NewRequest(op, params, data) + + // Run custom request initialization if present + if initRequest != nil { + initRequest(req) + } + + return req +} diff --git a/vendor/vendor.json b/vendor/vendor.json index 5b322e447..d2a0b5f12 100644 --- a/vendor/vendor.json +++ b/vendor/vendor.json @@ -989,6 +989,14 @@ "version": "v1.6.9", "versionExact": "v1.6.9" }, + { + "checksumSHA1": "Z0KJh0BT1VDqX3wU9Nj/+6hmi9s=", + "path": "github.com/aws/aws-sdk-go/service/sfn", + "revision": "36670f6ab1769ad77fa5f7e2c194398733503635", + "revisionTime": "2016-12-30T00:33:20Z", + "version": "v1.6.9", + "versionExact": "v1.6.9" + }, { "checksumSHA1": "l2IvDSyTWaPmHKJ6HNinOf+3GzA=", "path": "github.com/aws/aws-sdk-go/service/simpledb",