2 files changed, 11 insertions, 9 deletions
diff --git a/vendor/codeberg.org/gruf/go-store/v2/storage/disk.go b/vendor/codeberg.org/gruf/go-store/v2/storage/disk.go
index 21dba7671..3104400f3 100644
--- a/vendor/codeberg.org/gruf/go-store/v2/storage/disk.go
+++ b/vendor/codeberg.org/gruf/go-store/v2/storage/disk.go
@@ -195,7 +195,7 @@ func (st *DiskStorage) ReadBytes(ctx context.Context, key string) ([]byte, error
 // ReadStream implements Storage.ReadStream().
 func (st *DiskStorage) ReadStream(ctx context.Context, key string) (io.ReadCloser, error) {
 	// Get file path for key
-	kpath, err := st.filepath(key)
+	kpath, err := st.Filepath(key)
 	if err != nil {
 		return nil, err
 	}
@@ -235,7 +235,7 @@ func (st *DiskStorage) WriteBytes(ctx context.Context, key string, value []byte)
 // WriteStream implements Storage.WriteStream().
 func (st *DiskStorage) WriteStream(ctx context.Context, key string, r io.Reader) (int64, error) {
 	// Get file path for key
-	kpath, err := st.filepath(key)
+	kpath, err := st.Filepath(key)
 	if err != nil {
 		return 0, err
 	}
@@ -291,7 +291,7 @@ func (st *DiskStorage) WriteStream(ctx context.Context, key string, r io.Reader)
 // Stat implements Storage.Stat().
 func (st *DiskStorage) Stat(ctx context.Context, key string) (bool, error) {
 	// Get file path for key
-	kpath, err := st.filepath(key)
+	kpath, err := st.Filepath(key)
 	if err != nil {
 		return false, err
 	}
@@ -313,7 +313,7 @@ func (st *DiskStorage) Stat(ctx context.Context, key string) (bool, error) {
 // Remove implements Storage.Remove().
 func (st *DiskStorage) Remove(ctx context.Context, key string) error {
 	// Get file path for key
-	kpath, err := st.filepath(key)
+	kpath, err := st.Filepath(key)
 	if err != nil {
 		return err
 	}
@@ -384,8 +384,8 @@ func (st *DiskStorage) WalkKeys(ctx context.Context, opts WalkKeysOptions) error
 	})
 }
 
-// filepath checks and returns a formatted filepath for given key.
-func (st *DiskStorage) filepath(key string) (string, error) {
+// Filepath checks and returns a formatted Filepath for given key.
+func (st *DiskStorage) Filepath(key string) (string, error) {
 	// Calculate transformed key path
 	key = st.config.Transform.KeyToPath(key)
 
diff --git a/vendor/codeberg.org/gruf/go-store/v2/storage/s3.go b/vendor/codeberg.org/gruf/go-store/v2/storage/s3.go
index 501de230d..965fe0d4f 100644
--- a/vendor/codeberg.org/gruf/go-store/v2/storage/s3.go
+++ b/vendor/codeberg.org/gruf/go-store/v2/storage/s3.go
@@ -15,6 +15,7 @@ var DefaultS3Config = &S3Config{
 	CoreOpts:     minio.Options{},
 	GetOpts:      minio.GetObjectOptions{},
 	PutOpts:      minio.PutObjectOptions{},
+	PutChunkOpts: minio.PutObjectPartOptions{},
 	PutChunkSize: 4 * 1024 * 1024, // 4MiB
 	StatOpts:     minio.StatObjectOptions{},
 	RemoveOpts:   minio.RemoveObjectOptions{},
@@ -37,6 +38,9 @@ type S3Config struct {
 	// a byte stream reader of unknown size as a multi-part object.
 	PutChunkSize int64
 
+	// PutChunkOpts are S3 client options passed during chunked .Write___() calls.
+	PutChunkOpts minio.PutObjectPartOptions
+
 	// StatOpts are S3 client options passed during .Stat() calls.
 	StatOpts minio.StatObjectOptions
 
@@ -251,9 +255,7 @@ loop:
 			index,
 			rbuf,
 			int64(n),
-			"",
-			"",
-			nil,
+			st.config.PutChunkOpts,
 		)
 		if err != nil {
 			return 0, err