rename to multipart_upload

open-gpdb · Oct 7, 2024 · c61376d · c61376d
1 parent 449d747
commit c61376d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/cmd/client/main.go b/cmd/client/main.go
@@ -28,7 +28,7 @@ var (
 	storageClass       string
 	tableSpace         string
 	multipartChunksize int64
-	doMultipart        bool
+	MultipartUpload    bool
 
 	offset uint64
 
@@ -122,8 +122,8 @@ func putFunc(con net.Conn, instanceCnf *config.Instance, args []string) error {
 			Value: fmt.Sprintf("%d", multipartChunksize),
 		},
 		{
-			Name:  message.DoMultipart,
-			Value: fmt.Sprintf("%t", doMultipart),
+			Name:  message.MultipartUpload,
+			Value: fmt.Sprintf("%t", MultipartUpload),
 		},
 	}).Encode()
 	_, err := con.Write(msg)

diff --git a/pkg/message/put_message_v2.go b/pkg/message/put_message_v2.go
@@ -9,7 +9,7 @@ import (
 const StorageClassSetting = "StorageClass"
 const TableSpaceSetting = "TableSpace"
 const MultipartChunksize = "MultipartChunksize"
-const DoMultipart = "DoMultipart"
+const MultipartUpload = "MultipartUpload"
 
 type PutMessageV2 struct {
 	Encrypt bool

diff --git a/pkg/storage/s3storage.go b/pkg/storage/s3storage.go
@@ -78,7 +78,7 @@ func (s *S3StorageInteractor) PutFileToDest(name string, r io.Reader, settings [
 	if err != nil {
 		return err
 	}
-	doMultipart, err := strconv.ParseBool(ResolveStorageSetting(settings, message.DoMultipart, "1"))
+	MultipartUpload, err := strconv.ParseBool(ResolveStorageSetting(settings, message.MultipartUpload, "1"))
 	if err != nil {
 		return err
 	}
@@ -95,7 +95,7 @@ func (s *S3StorageInteractor) PutFileToDest(name string, r io.Reader, settings [
 		return err
 	}
 
-	if doMultipart {
+	if MultipartUpload {
 		_, err = up.Upload(
 			&s3manager.UploadInput{
 				Bucket:       aws.String(bucket),