Skip to content

Commit 08206eb

Browse files
authored
Merge pull request #86 from volcengine/release_v2.7.23
v2.7.23
2 parents c05e8a9 + e1bd8d0 commit 08206eb

29 files changed

Lines changed: 244 additions & 41 deletions

CHANGELOG.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,7 @@
11
# ChangeLog of TOS SDK for Go
2+
## 版本号 v2.7.23 日期:2025-09-26
3+
- 支持 GenericInput 设置自定义签名时间和 header
4+
25
## 版本号 v2.7.22 日期:2025-09-19
36
- 支持自定义 Proxy
47

tos/acl.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,7 @@ func (cli *ClientV2) PutObjectACL(ctx context.Context, input *PutObjectACLInput)
8585
content = bytes.NewReader(data)
8686
}
8787
builder := cli.newBuilder(input.Bucket, input.Key).
88+
SetGeneric(input.GenericInput).
8889
WithQuery("acl", "").
8990
WithParams(*input)
9091
res, err := builder.WithRetry(OnRetryFromStart, StatusCodeClassifier{}).Request(ctx, http.MethodPut, content, cli.roundTripper(http.StatusOK))
@@ -135,6 +136,7 @@ func (cli *ClientV2) GetObjectACL(ctx context.Context, input *GetObjectACLInput)
135136
return nil, err
136137
}
137138
res, err := cli.newBuilder(input.Bucket, input.Key).
139+
SetGeneric(input.GenericInput).
138140
WithQuery("acl", "").
139141
WithParams(*input).
140142
WithRetry(nil, StatusCodeClassifier{}).

tos/base_client.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@ func (cli *baseClient) PutObjectTagging(ctx context.Context, input *PutObjectTag
3131
return nil, err
3232
}
3333
res, err := cli.newBuilder(input.Bucket, input.Key, option...).
34+
SetGeneric(input.GenericInput).
3435
WithQuery("tagging", "").
3536
WithParams(*input).
3637
WithHeader(HeaderContentMD5, contentMD5).
@@ -53,6 +54,7 @@ func (cli *baseClient) GetObjectTagging(ctx context.Context, input *GetObjectTag
5354
return nil, err
5455
}
5556
res, err := cli.newBuilder(input.Bucket, input.Key, option...).
57+
SetGeneric(input.GenericInput).
5658
WithQuery("tagging", "").
5759
WithParams(*input).
5860
WithRetry(nil, StatusCodeClassifier{}).
@@ -77,6 +79,7 @@ func (cli *baseClient) DeleteObjectTagging(ctx context.Context, input *DeleteObj
7779
return nil, err
7880
}
7981
res, err := cli.newBuilder(input.Bucket, input.Key, option...).
82+
SetGeneric(input.GenericInput).
8083
WithQuery("tagging", "").
8184
WithParams(*input).
8285
WithRetry(nil, StatusCodeClassifier{}).
@@ -134,6 +137,7 @@ func (cli *baseClient) PutSymlink(ctx context.Context, input *PutSymlinkInput, o
134137
return nil, err
135138
}
136139
res, err := cli.newBuilder(input.Bucket, input.Key, option...).
140+
SetGeneric(input.GenericInput).
137141
WithQuery("symlink", "").
138142
WithHeader(HeaderSymlinkTarget, url.QueryEscape(input.SymlinkTargetKey)).
139143
WithParams(*input).
@@ -156,6 +160,7 @@ func (cli *baseClient) GetSymlink(ctx context.Context, input *GetSymlinkInput, o
156160
return nil, err
157161
}
158162
res, err := cli.newBuilder(input.Bucket, input.Key, option...).
163+
SetGeneric(input.GenericInput).
159164
WithQuery("symlink", "").
160165
WithParams(*input).
161166
WithRetry(nil, StatusCodeClassifier{}).
@@ -181,6 +186,7 @@ func (cli *baseClient) GetBucketACL(ctx context.Context, input *GetBucketACLInpu
181186
return nil, err
182187
}
183188
res, err := cli.newBuilder(input.Bucket, "").
189+
SetGeneric(input.GenericInput).
184190
WithQuery("acl", "").
185191
WithRetry(nil, StatusCodeClassifier{}).
186192
Request(ctx, http.MethodGet, nil, cli.roundTripper(http.StatusOK))
@@ -209,6 +215,7 @@ func (cli *baseClient) PutBucketACL(ctx context.Context, input *PutBucketACLInpu
209215

210216
reqBuilder := cli.newBuilder(input.Bucket, "").
211217
WithQuery("acl", "").
218+
SetGeneric(input.GenericInput).
212219
WithRetry(OnRetryFromStart, StatusCodeClassifier{}).
213220
WithParams(*input)
214221
var reqData io.Reader

tos/bucket.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,9 @@ package tos
33
import (
44
"bytes"
55
"context"
6-
"github.com/volcengine/ve-tos-golang-sdk/v2/tos/enum"
76
"net/http"
7+
8+
"github.com/volcengine/ve-tos-golang-sdk/v2/tos/enum"
89
)
910

1011
// Bucket create a Bucket handle
@@ -155,6 +156,7 @@ func (cli *Client) ListBuckets(ctx context.Context, _ *ListBucketsInput) (*ListB
155156
// ListBuckets list the buckets that the AK can access
156157
func (cli *ClientV2) ListBuckets(ctx context.Context, input *ListBucketsInput) (*ListBucketsOutput, error) {
157158
res, err := cli.newBuilder("", "").
159+
SetGeneric(input.GenericInput).
158160
WithParams(*input).
159161
WithRetry(nil, StatusCodeClassifier{}).
160162
Request(ctx, http.MethodGet, nil, cli.roundTripper(http.StatusOK))
@@ -181,6 +183,7 @@ func (cli *ClientV2) PutBucketStorageClass(ctx context.Context, input *PutBucket
181183
return nil, err
182184
}
183185
res, err := cli.newBuilder(input.Bucket, "").
186+
SetGeneric(input.GenericInput).
184187
WithQuery("storageClass", "").
185188
WithParams(*input).
186189
WithRetry(nil, StatusCodeClassifier{}).
@@ -201,6 +204,7 @@ func (cli *ClientV2) GetBucketLocation(ctx context.Context, input *GetBucketLoca
201204
return nil, err
202205
}
203206
res, err := cli.newBuilder(input.Bucket, "").
207+
SetGeneric(input.GenericInput).
204208
WithQuery("location", "").
205209
WithRetry(nil, StatusCodeClassifier{}).
206210
Request(ctx, http.MethodGet, nil, cli.roundTripper(http.StatusOK))
@@ -230,6 +234,7 @@ func (cli *ClientV2) PutBucketVersioning(ctx context.Context, input *PutBucketVe
230234
return nil, err
231235
}
232236
res, err := cli.newBuilder(input.Bucket, "").
237+
SetGeneric(input.GenericInput).
233238
WithQuery("versioning", "").
234239
WithHeader(HeaderContentMD5, contentMD5).
235240
WithRetry(OnRetryFromStart, StatusCodeClassifier{}).
@@ -251,6 +256,7 @@ func (cli *ClientV2) GetBucketVersioning(ctx context.Context, input *GetBucketVe
251256
return nil, err
252257
}
253258
res, err := cli.newBuilder(input.Bucket, "").
259+
SetGeneric(input.GenericInput).
254260
WithQuery("versioning", "").
255261
WithRetry(nil, StatusCodeClassifier{}).
256262
Request(ctx, http.MethodGet, nil, cli.roundTripper(http.StatusOK))
@@ -273,6 +279,7 @@ func (cli *ClientV2) GetBucketInfo(ctx context.Context, input *GetBucketInfoInpu
273279
return nil, err
274280
}
275281
res, err := cli.newBuilder(input.Bucket, "").
282+
SetGeneric(input.GenericInput).
276283
WithQuery("bucketInfo", "").
277284
WithRetry(nil, StatusCodeClassifier{}).
278285
Request(ctx, http.MethodGet, nil, cli.roundTripper(http.StatusOK))

tos/bucket_inventory.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ func (cli *ClientV2) GetBucketInventory(ctx context.Context, input *GetBucketInv
1414
return nil, err
1515
}
1616
res, err := cli.newBuilder(input.Bucket, "").
17+
SetGeneric(input.GenericInput).
1718
WithQuery("inventory", "").
1819
WithQuery("id", input.ID).
1920
WithRetry(nil, StatusCodeClassifier{}).
@@ -44,6 +45,7 @@ func (cli *ClientV2) PutBucketInventory(ctx context.Context, input *PutBucketInv
4445
}
4546

4647
res, err := cli.newBuilder(input.Bucket, "").
48+
SetGeneric(input.GenericInput).
4749
WithQuery("inventory", "").
4850
WithQuery("id", input.ID).
4951
WithHeader(HeaderContentMD5, contentMD5).
@@ -67,6 +69,7 @@ func (cli *ClientV2) DeleteBucketInventory(ctx context.Context, input *DeleteBuc
6769
return nil, err
6870
}
6971
res, err := cli.newBuilder(input.Bucket, "").
72+
SetGeneric(input.GenericInput).
7073
WithQuery("inventory", "").
7174
WithQuery("id", input.ID).
7275
WithRetry(nil, StatusCodeClassifier{}).
@@ -88,6 +91,7 @@ func (cli *ClientV2) ListBucketInventory(ctx context.Context, input *ListBucketI
8891
return nil, err
8992
}
9093
res, err := cli.newBuilder(input.Bucket, "").
94+
SetGeneric(input.GenericInput).
9195
WithQuery("inventory", "").
9296
WithQuery("continuation-token", input.ContinuationToken).
9397
WithRetry(nil, StatusCodeClassifier{}).

tos/bucket_tag.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ func (cli *ClientV2) PutBucketTagging(ctx context.Context, input *PutBucketTaggi
2020
return nil, err
2121
}
2222
res, err := cli.newBuilder(input.Bucket, "").
23+
SetGeneric(input.GenericInput).
2324
WithQuery("tagging", "").
2425
WithParams(*input).
2526
WithHeader(HeaderContentMD5, contentMD5).
@@ -41,6 +42,7 @@ func (cli *ClientV2) GetBucketTagging(ctx context.Context, input *GetBucketTaggi
4142
return nil, err
4243
}
4344
res, err := cli.newBuilder(input.Bucket, "").
45+
SetGeneric(input.GenericInput).
4446
WithQuery("tagging", "").
4547
WithParams(*input).
4648
WithRetry(nil, StatusCodeClassifier{}).
@@ -64,6 +66,7 @@ func (cli *ClientV2) DeleteBucketTagging(ctx context.Context, input *DeleteBucke
6466
return nil, err
6567
}
6668
res, err := cli.newBuilder(input.Bucket, "").
69+
SetGeneric(input.GenericInput).
6770
WithQuery("tagging", "").
6871
WithParams(*input).
6972
WithRetry(nil, StatusCodeClassifier{}).

tos/client.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -775,6 +775,7 @@ func (cli *ClientV2) PutFetchTaskV2(ctx context.Context, input *PutFetchTaskInpu
775775
}
776776

777777
res, err := cli.newBuilder(input.Bucket, "").
778+
SetGeneric(input.GenericInput).
778779
WithQuery("fetchTask", "").
779780
WithHeader(HeaderContentMD5, contentMD5).
780781
WithParams(*input).

tos/consts.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import (
77

88
const (
99
// Version tos-go-sdk version
10-
Version = "v2.7.22"
10+
Version = "v2.7.23"
1111
)
1212

1313
const TempFileSuffix = ".temp"

tos/copy.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,7 @@ func (cli *ClientV2) CopyObject(ctx context.Context, input *CopyObjectInput) (*C
139139
}
140140

141141
res, err := cli.newBuilder(input.Bucket, input.Key).
142+
SetGeneric(input.GenericInput).
142143
WithParams(*input).
143144
WithCopySource(input.SrcBucket, input.SrcKey).
144145
WithRetry(nil, ServerErrorClassifier{}).
@@ -273,6 +274,7 @@ func (cli *ClientV2) UploadPartCopyV2(
273274
}
274275

275276
req := cli.newBuilder(input.Bucket, input.Key).
277+
SetGeneric(input.GenericInput).
276278
WithParams(*input)
277279

278280
if input.CopySourceRange != "" {

tos/cors.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ func (cli *ClientV2) GetBucketCORS(ctx context.Context, input *GetBucketCORSInpu
1515
return nil, err
1616
}
1717
res, err := cli.newBuilder(input.Bucket, "").
18+
SetGeneric(input.GenericInput).
1819
WithQuery("cors", "").
1920
WithRetry(nil, StatusCodeClassifier{}).
2021
Request(ctx, http.MethodGet, nil, cli.roundTripper(http.StatusOK))
@@ -45,6 +46,7 @@ func (cli *ClientV2) PutBucketCORS(ctx context.Context, input *PutBucketCORSInpu
4546
}
4647

4748
res, err := cli.newBuilder(input.Bucket, "").
49+
SetGeneric(input.GenericInput).
4850
WithQuery("cors", "").
4951
WithHeader(HeaderContentMD5, contentMD5).
5052
WithRetry(OnRetryFromStart, StatusCodeClassifier{}).
@@ -68,6 +70,7 @@ func (cli *ClientV2) DeleteBucketCORS(ctx context.Context, input *DeleteBucketCO
6870
return nil, err
6971
}
7072
res, err := cli.newBuilder(input.Bucket, "").
73+
SetGeneric(input.GenericInput).
7174
WithQuery("cors", "").
7275
WithRetry(nil, StatusCodeClassifier{}).
7376
Request(ctx, http.MethodDelete, nil, cli.roundTripper(http.StatusNoContent))

0 commit comments

Comments
 (0)