-
Notifications
You must be signed in to change notification settings - Fork 623
/
api_op_RetryStageExecution.go
154 lines (126 loc) · 4.66 KB
/
api_op_RetryStageExecution.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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT.
package codepipeline
import (
"context"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/internal/awsutil"
)
// Represents the input of a RetryStageExecution action.
type RetryStageExecutionInput struct {
_ struct{} `type:"structure"`
// The ID of the pipeline execution in the failed stage to be retried. Use the
// GetPipelineState action to retrieve the current pipelineExecutionId of the
// failed stage
//
// PipelineExecutionId is a required field
PipelineExecutionId *string `locationName:"pipelineExecutionId" type:"string" required:"true"`
// The name of the pipeline that contains the failed stage.
//
// PipelineName is a required field
PipelineName *string `locationName:"pipelineName" min:"1" type:"string" required:"true"`
// The scope of the retry attempt. Currently, the only supported value is FAILED_ACTIONS.
//
// RetryMode is a required field
RetryMode StageRetryMode `locationName:"retryMode" type:"string" required:"true" enum:"true"`
// The name of the failed stage to be retried.
//
// StageName is a required field
StageName *string `locationName:"stageName" min:"1" type:"string" required:"true"`
}
// String returns the string representation
func (s RetryStageExecutionInput) String() string {
return awsutil.Prettify(s)
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *RetryStageExecutionInput) Validate() error {
invalidParams := aws.ErrInvalidParams{Context: "RetryStageExecutionInput"}
if s.PipelineExecutionId == nil {
invalidParams.Add(aws.NewErrParamRequired("PipelineExecutionId"))
}
if s.PipelineName == nil {
invalidParams.Add(aws.NewErrParamRequired("PipelineName"))
}
if s.PipelineName != nil && len(*s.PipelineName) < 1 {
invalidParams.Add(aws.NewErrParamMinLen("PipelineName", 1))
}
if len(s.RetryMode) == 0 {
invalidParams.Add(aws.NewErrParamRequired("RetryMode"))
}
if s.StageName == nil {
invalidParams.Add(aws.NewErrParamRequired("StageName"))
}
if s.StageName != nil && len(*s.StageName) < 1 {
invalidParams.Add(aws.NewErrParamMinLen("StageName", 1))
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// Represents the output of a RetryStageExecution action.
type RetryStageExecutionOutput struct {
_ struct{} `type:"structure"`
// The ID of the current workflow execution in the failed stage.
PipelineExecutionId *string `locationName:"pipelineExecutionId" type:"string"`
}
// String returns the string representation
func (s RetryStageExecutionOutput) String() string {
return awsutil.Prettify(s)
}
const opRetryStageExecution = "RetryStageExecution"
// RetryStageExecutionRequest returns a request value for making API operation for
// AWS CodePipeline.
//
// Resumes the pipeline execution by retrying the last failed actions in a stage.
//
// // Example sending a request using RetryStageExecutionRequest.
// req := client.RetryStageExecutionRequest(params)
// resp, err := req.Send(context.TODO())
// if err == nil {
// fmt.Println(resp)
// }
//
// Please also see https://docs.aws.amazon.com/goto/WebAPI/codepipeline-2015-07-09/RetryStageExecution
func (c *Client) RetryStageExecutionRequest(input *RetryStageExecutionInput) RetryStageExecutionRequest {
op := &aws.Operation{
Name: opRetryStageExecution,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &RetryStageExecutionInput{}
}
req := c.newRequest(op, input, &RetryStageExecutionOutput{})
return RetryStageExecutionRequest{Request: req, Input: input, Copy: c.RetryStageExecutionRequest}
}
// RetryStageExecutionRequest is the request type for the
// RetryStageExecution API operation.
type RetryStageExecutionRequest struct {
*aws.Request
Input *RetryStageExecutionInput
Copy func(*RetryStageExecutionInput) RetryStageExecutionRequest
}
// Send marshals and sends the RetryStageExecution API request.
func (r RetryStageExecutionRequest) Send(ctx context.Context) (*RetryStageExecutionResponse, error) {
r.Request.SetContext(ctx)
err := r.Request.Send()
if err != nil {
return nil, err
}
resp := &RetryStageExecutionResponse{
RetryStageExecutionOutput: r.Request.Data.(*RetryStageExecutionOutput),
response: &aws.Response{Request: r.Request},
}
return resp, nil
}
// RetryStageExecutionResponse is the response type for the
// RetryStageExecution API operation.
type RetryStageExecutionResponse struct {
*RetryStageExecutionOutput
response *aws.Response
}
// SDKResponseMetdata returns the response metadata for the
// RetryStageExecution request.
func (r *RetryStageExecutionResponse) SDKResponseMetdata() *aws.Response {
return r.response
}