-
Notifications
You must be signed in to change notification settings - Fork 623
/
api_op_SendTaskSuccess.go
130 lines (106 loc) · 3.77 KB
/
api_op_SendTaskSuccess.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT.
package sfn
import (
"context"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/internal/awsutil"
)
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" sensitive:"true"`
// The token that represents this task. Task tokens are generated by Step Functions
// when tasks are assigned to a worker, or in the context object (https://docs.aws.amazon.com/step-functions/latest/dg/input-output-contextobject.html)
// when a workflow enters a task state. See GetActivityTaskOutput$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)
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *SendTaskSuccessInput) Validate() error {
invalidParams := aws.ErrInvalidParams{Context: "SendTaskSuccessInput"}
if s.Output == nil {
invalidParams.Add(aws.NewErrParamRequired("Output"))
}
if s.TaskToken == nil {
invalidParams.Add(aws.NewErrParamRequired("TaskToken"))
}
if s.TaskToken != nil && len(*s.TaskToken) < 1 {
invalidParams.Add(aws.NewErrParamMinLen("TaskToken", 1))
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
type SendTaskSuccessOutput struct {
_ struct{} `type:"structure"`
}
// String returns the string representation
func (s SendTaskSuccessOutput) String() string {
return awsutil.Prettify(s)
}
const opSendTaskSuccess = "SendTaskSuccess"
// SendTaskSuccessRequest returns a request value for making API operation for
// AWS Step Functions.
//
// Used by activity workers and task states using the callback (https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.html#connect-wait-token)
// pattern to report that the task identified by the taskToken completed successfully.
//
// // Example sending a request using SendTaskSuccessRequest.
// req := client.SendTaskSuccessRequest(params)
// resp, err := req.Send(context.TODO())
// if err == nil {
// fmt.Println(resp)
// }
//
// Please also see https://docs.aws.amazon.com/goto/WebAPI/states-2016-11-23/SendTaskSuccess
func (c *Client) SendTaskSuccessRequest(input *SendTaskSuccessInput) SendTaskSuccessRequest {
op := &aws.Operation{
Name: opSendTaskSuccess,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &SendTaskSuccessInput{}
}
req := c.newRequest(op, input, &SendTaskSuccessOutput{})
return SendTaskSuccessRequest{Request: req, Input: input, Copy: c.SendTaskSuccessRequest}
}
// SendTaskSuccessRequest is the request type for the
// SendTaskSuccess API operation.
type SendTaskSuccessRequest struct {
*aws.Request
Input *SendTaskSuccessInput
Copy func(*SendTaskSuccessInput) SendTaskSuccessRequest
}
// Send marshals and sends the SendTaskSuccess API request.
func (r SendTaskSuccessRequest) Send(ctx context.Context) (*SendTaskSuccessResponse, error) {
r.Request.SetContext(ctx)
err := r.Request.Send()
if err != nil {
return nil, err
}
resp := &SendTaskSuccessResponse{
SendTaskSuccessOutput: r.Request.Data.(*SendTaskSuccessOutput),
response: &aws.Response{Request: r.Request},
}
return resp, nil
}
// SendTaskSuccessResponse is the response type for the
// SendTaskSuccess API operation.
type SendTaskSuccessResponse struct {
*SendTaskSuccessOutput
response *aws.Response
}
// SDKResponseMetdata returns the response metadata for the
// SendTaskSuccess request.
func (r *SendTaskSuccessResponse) SDKResponseMetdata() *aws.Response {
return r.response
}