Rename chunkSize with partSize for minio storage

Author: boris-ilijic

packaging/conf/pbm-conf-reference.yml

@@ -104,7 +104,7 @@
 #        signature-ver: V4
 
 ## The size of data chunks in bytes to be uploaded to the storage bucket in a single request.
-#      chunkSize: 10485760
+#      partSize: 10485760
 
 ## Data upload configuration
 #      maxUploadParts: 10,000

pbm/config/config_test.go

@@ -167,7 +167,7 @@ func TestIsSameStorage(t *testing.T) {
 				SessionToken:    "sess",
 			},
 			Secure:    true,
-			ChunkSize: 6 << 20,
+			PartSize: 6 << 20,
 			Retryer:   &mio.Retryer{},
 		}
 		eq := &mio.Config{

pbm/storage/mio/config.go

@@ -17,7 +17,7 @@ type Config struct {
 	Secure         bool              `bson:"secure" json:"secure" yaml:"secure"`
 	DebugTrace     bool              `bson:"debugTrace,omitempty" json:"debugTrace,omitempty" yaml:"debugTrace,omitempty"`
 
-	ChunkSize    int64    `bson:"chunkSize,omitempty" json:"chunkSize,omitempty" yaml:"chunkSize,omitempty"`
+	PartSize     int64    `bson:"partSize,omitempty" json:"partSize,omitempty" yaml:"partSize,omitempty"`
 	MaxObjSizeGB *float64 `bson:"maxObjSizeGB,omitempty" json:"maxObjSizeGB,omitempty" yaml:"maxObjSizeGB,omitempty"`
 
 	Retryer *Retryer `bson:"retryer,omitempty" json:"retryer,omitempty" yaml:"retryer,omitempty"`
@@ -87,8 +87,8 @@ func (cfg *Config) Cast() error {
 		return errors.New("endpointURL cannot be empty")
 	}
 
-	if cfg.ChunkSize == 0 {
-		cfg.ChunkSize = defaultPartSize
+	if cfg.PartSize == 0 {
+		cfg.PartSize = defaultPartSize
 	}
 
 	if cfg.Retryer == nil {

pbm/storage/mio/config_test.go

@@ -21,7 +21,7 @@ func TestClone(t *testing.T) {
 			SessionToken:    "sess",
 		},
 		Secure:       true,
-		ChunkSize:    6 << 20,
+		PartSize:     6 << 20,
 		MaxObjSizeGB: &f,
 		Retryer: &Retryer{
 			NumMaxRetries: 1,
@@ -54,7 +54,7 @@ func TestEqual(t *testing.T) {
 			SessionToken:    "sess",
 		},
 		Secure:       true,
-		ChunkSize:    6 << 20,
+		PartSize:     6 << 20,
 		MaxObjSizeGB: &f,
 		Retryer: &Retryer{
 			NumMaxRetries: 1,
@@ -82,7 +82,7 @@ func TestCast(t *testing.T) {
 	}
 	want := &Config{
 		EndpointURL: "url",
-		ChunkSize:   defaultPartSize,
+		PartSize:    defaultPartSize,
 		Retryer: &Retryer{
 			NumMaxRetries: defaultMaxRetries,
 		},

pbm/storage/mio/minio.go

@@ -144,7 +144,7 @@ func (m *Minio) Save(name string, data io.Reader, options ...storage.Option) err
 		defaultPartSize,
 		minPartSize,
 		maxUploadParts,
-		m.cfg.ChunkSize,
+		m.cfg.PartSize,
 	)
 
 	if m.log != nil && opts.UseLogger {