Merge pull request #91 from volcengine/release_v2.9.0

v2.9.0

Author: zyBaosu

CHANGELOG.md

@@ -1,4 +1,13 @@
 # ChangeLog of TOS SDK for Go
+## 版本号 v2.9.0 日期：2025-12-10
+- 默认开启 DNS 缓存
+- PreSignedURLInput 支持签名输入 header
+- 新增 SetObjectTime 接口
+- 新增 GetBucketInfo 接口
+- UploadFile 接口支持上传回调
+- 新增快速判断桶 DoesBucketExist 是否存在接口
+- 新增快速判断对象 DoesObjectExist 是否存在的接口
+
 ## 版本号 v2.8.0 日期：2025-12-03
 - 新增 GetFetchTaskV2 接口
 - 新增 CredentialsProvider 鉴权方式

tos/access_monitor.go

@@ -0,0 +1,65 @@
+package tos
+
+import (
+	"bytes"
+	"context"
+	"github.com/volcengine/ve-tos-golang-sdk/v2/tos/enum"
+	"net/http"
+)
+
+type putBucketAccessMonitor struct {
+	Status enum.StatusType `json:"Status"`
+}
+
+func (cli *ClientV2) PutBucketAccessMonitor(ctx context.Context, input *PutBucketAccessMonitorInput) (*PutBucketAccessMonitorOutput, error) {
+	if input == nil {
+		return nil, InputIsNilClientError
+	}
+	if err := isValidBucketName(input.Bucket, cli.isCustomDomain); err != nil {
+		return nil, err
+	}
+
+	data, contentMD5, err := marshalInput("PutBucketAccessMonitor", putBucketAccessMonitor{
+		Status: input.Status,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	res, err := cli.newBuilder(input.Bucket, "").
+		SetGeneric(input.GenericInput).
+		WithQuery("accessmonitor", "").
+		WithHeader(HeaderContentMD5, contentMD5).
+		WithRetry(OnRetryFromStart, StatusCodeClassifier{}).
+		Request(ctx, http.MethodPut, bytes.NewReader(data), cli.roundTripper(http.StatusOK))
+
+	if err != nil {
+		return nil, err
+	}
+	defer res.Close()
+	output := PutBucketAccessMonitorOutput{RequestInfo: res.RequestInfo()}
+	return &output, nil
+}
+
+func (cli *ClientV2) GetBucketAccessMonitor(ctx context.Context, input *GetBucketAccessMonitorInput) (*GetBucketAccessMonitorOutput, error) {
+	if input == nil {
+		return nil, InputIsNilClientError
+	}
+	if err := isValidBucketName(input.Bucket, cli.isCustomDomain); err != nil {
+		return nil, err
+	}
+	res, err := cli.newBuilder(input.Bucket, "").
+		SetGeneric(input.GenericInput).
+		WithQuery("accessmonitor", "").
+		WithRetry(nil, StatusCodeClassifier{}).
+		Request(ctx, http.MethodGet, nil, cli.roundTripper(http.StatusOK))
+	if err != nil {
+		return nil, err
+	}
+	defer res.Close()
+	output := GetBucketAccessMonitorOutput{RequestInfo: res.RequestInfo()}
+	if err = marshalOutput(res, &output); err != nil {
+		return nil, err
+	}
+	return &output, nil
+}

tos/bucket.go

@@ -293,3 +293,30 @@ func (cli *ClientV2) GetBucketInfo(ctx context.Context, input *GetBucketInfoInpu
 	}
 	return &output, nil
 }
+
+func (cli *ClientV2) DoesBucketExist(ctx context.Context, input *DoesBucketExistInput) (bool, error) {
+	if input == nil {
+		return false, InputIsNilClientError
+	}
+	if err := isValidBucketName(input.Bucket, cli.isCustomDomain); err != nil {
+		return false, err
+	}
+	res, err := cli.HeadBucket(ctx, &HeadBucketInput{
+		Bucket: input.Bucket,
+	})
+
+	if err != nil {
+		if serr, ok := err.(*TosServerError); ok {
+			if serr.EC == "0006-00000001" {
+				return false, nil
+			}
+		}
+		return false, err
+	}
+
+	if res.StatusCode == http.StatusOK {
+		return true, nil
+	}
+
+	return false, err
+}

tos/check.go

@@ -113,7 +113,7 @@ func isValidMetadataDirective(directiveType enum.MetadataDirectiveType) error {
 func isValidPermission(permissionType enum.PermissionType) error {
 	if permissionType == enum.PermissionRead || permissionType == enum.PermissionReadAcp ||
 		permissionType == enum.PermissionWriteAcp || permissionType == enum.PermissionWrite ||
-		permissionType == enum.PermissionFullControl {
+		permissionType == enum.PermissionFullControl || permissionType == enum.PermissionReadNonList {
 		return nil
 	}
 	return InvalidPermission