diff options
Diffstat (limited to 'vendor/github.com/aws/aws-sdk-go/service/s3/waiters.go')
-rw-r--r-- | vendor/github.com/aws/aws-sdk-go/service/s3/waiters.go | 214 |
1 files changed, 214 insertions, 0 deletions
diff --git a/vendor/github.com/aws/aws-sdk-go/service/s3/waiters.go b/vendor/github.com/aws/aws-sdk-go/service/s3/waiters.go new file mode 100644 index 0000000..cccfa8c --- /dev/null +++ b/vendor/github.com/aws/aws-sdk-go/service/s3/waiters.go | |||
@@ -0,0 +1,214 @@ | |||
1 | // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. | ||
2 | |||
3 | package s3 | ||
4 | |||
5 | import ( | ||
6 | "time" | ||
7 | |||
8 | "github.com/aws/aws-sdk-go/aws" | ||
9 | "github.com/aws/aws-sdk-go/aws/request" | ||
10 | ) | ||
11 | |||
12 | // WaitUntilBucketExists uses the Amazon S3 API operation | ||
13 | // HeadBucket to wait for a condition to be met before returning. | ||
14 | // If the condition is not meet within the max attempt window an error will | ||
15 | // be returned. | ||
16 | func (c *S3) WaitUntilBucketExists(input *HeadBucketInput) error { | ||
17 | return c.WaitUntilBucketExistsWithContext(aws.BackgroundContext(), input) | ||
18 | } | ||
19 | |||
20 | // WaitUntilBucketExistsWithContext is an extended version of WaitUntilBucketExists. | ||
21 | // With the support for passing in a context and options to configure the | ||
22 | // Waiter and the underlying request options. | ||
23 | // | ||
24 | // The context must be non-nil and will be used for request cancellation. If | ||
25 | // the context is nil a panic will occur. In the future the SDK may create | ||
26 | // sub-contexts for http.Requests. See https://golang.org/pkg/context/ | ||
27 | // for more information on using Contexts. | ||
28 | func (c *S3) WaitUntilBucketExistsWithContext(ctx aws.Context, input *HeadBucketInput, opts ...request.WaiterOption) error { | ||
29 | w := request.Waiter{ | ||
30 | Name: "WaitUntilBucketExists", | ||
31 | MaxAttempts: 20, | ||
32 | Delay: request.ConstantWaiterDelay(5 * time.Second), | ||
33 | Acceptors: []request.WaiterAcceptor{ | ||
34 | { | ||
35 | State: request.SuccessWaiterState, | ||
36 | Matcher: request.StatusWaiterMatch, | ||
37 | Expected: 200, | ||
38 | }, | ||
39 | { | ||
40 | State: request.SuccessWaiterState, | ||
41 | Matcher: request.StatusWaiterMatch, | ||
42 | Expected: 301, | ||
43 | }, | ||
44 | { | ||
45 | State: request.SuccessWaiterState, | ||
46 | Matcher: request.StatusWaiterMatch, | ||
47 | Expected: 403, | ||
48 | }, | ||
49 | { | ||
50 | State: request.RetryWaiterState, | ||
51 | Matcher: request.StatusWaiterMatch, | ||
52 | Expected: 404, | ||
53 | }, | ||
54 | }, | ||
55 | Logger: c.Config.Logger, | ||
56 | NewRequest: func(opts []request.Option) (*request.Request, error) { | ||
57 | var inCpy *HeadBucketInput | ||
58 | if input != nil { | ||
59 | tmp := *input | ||
60 | inCpy = &tmp | ||
61 | } | ||
62 | req, _ := c.HeadBucketRequest(inCpy) | ||
63 | req.SetContext(ctx) | ||
64 | req.ApplyOptions(opts...) | ||
65 | return req, nil | ||
66 | }, | ||
67 | } | ||
68 | w.ApplyOptions(opts...) | ||
69 | |||
70 | return w.WaitWithContext(ctx) | ||
71 | } | ||
72 | |||
73 | // WaitUntilBucketNotExists uses the Amazon S3 API operation | ||
74 | // HeadBucket to wait for a condition to be met before returning. | ||
75 | // If the condition is not meet within the max attempt window an error will | ||
76 | // be returned. | ||
77 | func (c *S3) WaitUntilBucketNotExists(input *HeadBucketInput) error { | ||
78 | return c.WaitUntilBucketNotExistsWithContext(aws.BackgroundContext(), input) | ||
79 | } | ||
80 | |||
81 | // WaitUntilBucketNotExistsWithContext is an extended version of WaitUntilBucketNotExists. | ||
82 | // With the support for passing in a context and options to configure the | ||
83 | // Waiter and the underlying request options. | ||
84 | // | ||
85 | // The context must be non-nil and will be used for request cancellation. If | ||
86 | // the context is nil a panic will occur. In the future the SDK may create | ||
87 | // sub-contexts for http.Requests. See https://golang.org/pkg/context/ | ||
88 | // for more information on using Contexts. | ||
89 | func (c *S3) WaitUntilBucketNotExistsWithContext(ctx aws.Context, input *HeadBucketInput, opts ...request.WaiterOption) error { | ||
90 | w := request.Waiter{ | ||
91 | Name: "WaitUntilBucketNotExists", | ||
92 | MaxAttempts: 20, | ||
93 | Delay: request.ConstantWaiterDelay(5 * time.Second), | ||
94 | Acceptors: []request.WaiterAcceptor{ | ||
95 | { | ||
96 | State: request.SuccessWaiterState, | ||
97 | Matcher: request.StatusWaiterMatch, | ||
98 | Expected: 404, | ||
99 | }, | ||
100 | }, | ||
101 | Logger: c.Config.Logger, | ||
102 | NewRequest: func(opts []request.Option) (*request.Request, error) { | ||
103 | var inCpy *HeadBucketInput | ||
104 | if input != nil { | ||
105 | tmp := *input | ||
106 | inCpy = &tmp | ||
107 | } | ||
108 | req, _ := c.HeadBucketRequest(inCpy) | ||
109 | req.SetContext(ctx) | ||
110 | req.ApplyOptions(opts...) | ||
111 | return req, nil | ||
112 | }, | ||
113 | } | ||
114 | w.ApplyOptions(opts...) | ||
115 | |||
116 | return w.WaitWithContext(ctx) | ||
117 | } | ||
118 | |||
119 | // WaitUntilObjectExists uses the Amazon S3 API operation | ||
120 | // HeadObject to wait for a condition to be met before returning. | ||
121 | // If the condition is not meet within the max attempt window an error will | ||
122 | // be returned. | ||
123 | func (c *S3) WaitUntilObjectExists(input *HeadObjectInput) error { | ||
124 | return c.WaitUntilObjectExistsWithContext(aws.BackgroundContext(), input) | ||
125 | } | ||
126 | |||
127 | // WaitUntilObjectExistsWithContext is an extended version of WaitUntilObjectExists. | ||
128 | // With the support for passing in a context and options to configure the | ||
129 | // Waiter and the underlying request options. | ||
130 | // | ||
131 | // The context must be non-nil and will be used for request cancellation. If | ||
132 | // the context is nil a panic will occur. In the future the SDK may create | ||
133 | // sub-contexts for http.Requests. See https://golang.org/pkg/context/ | ||
134 | // for more information on using Contexts. | ||
135 | func (c *S3) WaitUntilObjectExistsWithContext(ctx aws.Context, input *HeadObjectInput, opts ...request.WaiterOption) error { | ||
136 | w := request.Waiter{ | ||
137 | Name: "WaitUntilObjectExists", | ||
138 | MaxAttempts: 20, | ||
139 | Delay: request.ConstantWaiterDelay(5 * time.Second), | ||
140 | Acceptors: []request.WaiterAcceptor{ | ||
141 | { | ||
142 | State: request.SuccessWaiterState, | ||
143 | Matcher: request.StatusWaiterMatch, | ||
144 | Expected: 200, | ||
145 | }, | ||
146 | { | ||
147 | State: request.RetryWaiterState, | ||
148 | Matcher: request.StatusWaiterMatch, | ||
149 | Expected: 404, | ||
150 | }, | ||
151 | }, | ||
152 | Logger: c.Config.Logger, | ||
153 | NewRequest: func(opts []request.Option) (*request.Request, error) { | ||
154 | var inCpy *HeadObjectInput | ||
155 | if input != nil { | ||
156 | tmp := *input | ||
157 | inCpy = &tmp | ||
158 | } | ||
159 | req, _ := c.HeadObjectRequest(inCpy) | ||
160 | req.SetContext(ctx) | ||
161 | req.ApplyOptions(opts...) | ||
162 | return req, nil | ||
163 | }, | ||
164 | } | ||
165 | w.ApplyOptions(opts...) | ||
166 | |||
167 | return w.WaitWithContext(ctx) | ||
168 | } | ||
169 | |||
170 | // WaitUntilObjectNotExists uses the Amazon S3 API operation | ||
171 | // HeadObject to wait for a condition to be met before returning. | ||
172 | // If the condition is not meet within the max attempt window an error will | ||
173 | // be returned. | ||
174 | func (c *S3) WaitUntilObjectNotExists(input *HeadObjectInput) error { | ||
175 | return c.WaitUntilObjectNotExistsWithContext(aws.BackgroundContext(), input) | ||
176 | } | ||
177 | |||
178 | // WaitUntilObjectNotExistsWithContext is an extended version of WaitUntilObjectNotExists. | ||
179 | // With the support for passing in a context and options to configure the | ||
180 | // Waiter and the underlying request options. | ||
181 | // | ||
182 | // The context must be non-nil and will be used for request cancellation. If | ||
183 | // the context is nil a panic will occur. In the future the SDK may create | ||
184 | // sub-contexts for http.Requests. See https://golang.org/pkg/context/ | ||
185 | // for more information on using Contexts. | ||
186 | func (c *S3) WaitUntilObjectNotExistsWithContext(ctx aws.Context, input *HeadObjectInput, opts ...request.WaiterOption) error { | ||
187 | w := request.Waiter{ | ||
188 | Name: "WaitUntilObjectNotExists", | ||
189 | MaxAttempts: 20, | ||
190 | Delay: request.ConstantWaiterDelay(5 * time.Second), | ||
191 | Acceptors: []request.WaiterAcceptor{ | ||
192 | { | ||
193 | State: request.SuccessWaiterState, | ||
194 | Matcher: request.StatusWaiterMatch, | ||
195 | Expected: 404, | ||
196 | }, | ||
197 | }, | ||
198 | Logger: c.Config.Logger, | ||
199 | NewRequest: func(opts []request.Option) (*request.Request, error) { | ||
200 | var inCpy *HeadObjectInput | ||
201 | if input != nil { | ||
202 | tmp := *input | ||
203 | inCpy = &tmp | ||
204 | } | ||
205 | req, _ := c.HeadObjectRequest(inCpy) | ||
206 | req.SetContext(ctx) | ||
207 | req.ApplyOptions(opts...) | ||
208 | return req, nil | ||
209 | }, | ||
210 | } | ||
211 | w.ApplyOptions(opts...) | ||
212 | |||
213 | return w.WaitWithContext(ctx) | ||
214 | } | ||