-
Notifications
You must be signed in to change notification settings - Fork 626
/
api_op_UploadMultipartPart.go
198 lines (181 loc) · 7.26 KB
/
api_op_UploadMultipartPart.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
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
// Code generated by smithy-go-codegen DO NOT EDIT.
package glacier
import (
"context"
awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware"
"github.com/aws/aws-sdk-go-v2/aws/signer/v4"
glaciercust "github.com/aws/aws-sdk-go-v2/service/glacier/internal/customizations"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
"io"
)
// This operation uploads a part of an archive. You can upload archive parts in any
// order. You can also upload them in parallel. You can upload up to 10,000 parts
// for a multipart upload. Amazon Glacier rejects your upload part request if any
// of the following conditions is true:
//
// * SHA256 tree hash does not matchTo ensure
// that part data is not corrupted in transmission, you compute a SHA256 tree hash
// of the part and include it in your request. Upon receiving the part data, Amazon
// S3 Glacier also computes a SHA256 tree hash. If these hash values don't match,
// the operation fails. For information about computing a SHA256 tree hash, see
// Computing Checksums
// (https://docs.aws.amazon.com/amazonglacier/latest/dev/checksum-calculations.html).
//
// *
// Part size does not matchThe size of each part except the last must match the
// size specified in the corresponding InitiateMultipartUpload request. The size of
// the last part must be the same size as, or smaller than, the specified size. If
// you upload a part whose size is smaller than the part size you specified in your
// initiate multipart upload request and that part is not the last part, then the
// upload part request will succeed. However, the subsequent Complete Multipart
// Upload request will fail.
//
// * Range does not alignThe byte range value in the
// request does not align with the part size specified in the corresponding
// initiate request. For example, if you specify a part size of 4194304 bytes (4
// MB), then 0 to 4194303 bytes (4 MB - 1) and 4194304 (4 MB) to 8388607 (8 MB - 1)
// are valid part ranges. However, if you set a range value of 2 MB to 6 MB, the
// range does not align with the part size and the upload will fail.
//
// This
// operation is idempotent. If you upload the same part multiple times, the data
// included in the most recent request overwrites the previously uploaded data. An
// AWS account has full permission to perform all operations (actions). However,
// AWS Identity and Access Management (IAM) users don't have any permissions by
// default. You must grant them explicit permission to perform specific actions.
// For more information, see Access Control Using AWS Identity and Access
// Management (IAM)
// (https://docs.aws.amazon.com/amazonglacier/latest/dev/using-iam-with-amazon-glacier.html).
// For conceptual information and underlying REST API, see Uploading Large Archives
// in Parts (Multipart Upload)
// (https://docs.aws.amazon.com/amazonglacier/latest/dev/uploading-archive-mpu.html)
// and Upload Part
// (https://docs.aws.amazon.com/amazonglacier/latest/dev/api-upload-part.html) in
// the Amazon Glacier Developer Guide.
func (c *Client) UploadMultipartPart(ctx context.Context, params *UploadMultipartPartInput, optFns ...func(*Options)) (*UploadMultipartPartOutput, error) {
if params == nil {
params = &UploadMultipartPartInput{}
}
result, metadata, err := c.invokeOperation(ctx, "UploadMultipartPart", params, optFns, addOperationUploadMultipartPartMiddlewares)
if err != nil {
return nil, err
}
out := result.(*UploadMultipartPartOutput)
out.ResultMetadata = metadata
return out, nil
}
// Provides options to upload a part of an archive in a multipart upload operation.
type UploadMultipartPartInput struct {
// The AccountId value is the AWS account ID of the account that owns the vault.
// You can either specify an AWS account ID or optionally a single '-' (hyphen), in
// which case Amazon S3 Glacier uses the AWS account ID associated with the
// credentials used to sign the request. If you use an account ID, do not include
// any hyphens ('-') in the ID.
//
// This member is required.
AccountId *string
// The upload ID of the multipart upload.
//
// This member is required.
UploadId *string
// The name of the vault.
//
// This member is required.
VaultName *string
// The data to upload.
Body io.Reader
// The SHA256 tree hash of the data being uploaded.
Checksum *string
// Identifies the range of bytes in the assembled archive that will be uploaded in
// this part. Amazon S3 Glacier uses this information to assemble the archive in
// the proper sequence. The format of this header follows RFC 2616. An example
// header is Content-Range:bytes 0-4194303/*.
Range *string
}
// Contains the Amazon S3 Glacier response to your request.
type UploadMultipartPartOutput struct {
// The SHA256 tree hash that Amazon S3 Glacier computed for the uploaded part.
Checksum *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
}
func addOperationUploadMultipartPartMiddlewares(stack *middleware.Stack, options Options) (err error) {
err = stack.Serialize.Add(&awsRestjson1_serializeOpUploadMultipartPart{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsRestjson1_deserializeOpUploadMultipartPart{}, middleware.After)
if err != nil {
return err
}
if err = addSetLoggerMiddleware(stack, options); err != nil {
return err
}
if err = awsmiddleware.AddClientRequestIDMiddleware(stack); err != nil {
return err
}
if err = smithyhttp.AddComputeContentLengthMiddleware(stack); err != nil {
return err
}
if err = addResolveEndpointMiddleware(stack, options); err != nil {
return err
}
if err = v4.AddComputePayloadSHA256Middleware(stack); err != nil {
return err
}
if err = addRetryMiddlewares(stack, options); err != nil {
return err
}
if err = addHTTPSignerV4Middleware(stack, options); err != nil {
return err
}
if err = awsmiddleware.AddRawResponseToMetadata(stack); err != nil {
return err
}
if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil {
return err
}
if err = addClientUserAgent(stack); err != nil {
return err
}
if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = addOpUploadMultipartPartValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opUploadMultipartPart(options.Region), middleware.Before); err != nil {
return err
}
if err = addRequestIDRetrieverMiddleware(stack); err != nil {
return err
}
if err = addResponseErrorMiddleware(stack); err != nil {
return err
}
if err = glaciercust.AddTreeHashMiddleware(stack); err != nil {
return err
}
if err = glaciercust.AddGlacierAPIVersionMiddleware(stack, ServiceAPIVersion); err != nil {
return err
}
if err = glaciercust.AddDefaultAccountIDMiddleware(stack, setDefaultAccountID); err != nil {
return err
}
if err = addRequestResponseLogging(stack, options); err != nil {
return err
}
return nil
}
func newServiceMetadataMiddleware_opUploadMultipartPart(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
SigningName: "glacier",
OperationName: "UploadMultipartPart",
}
}