added debug info

s3/get.go

@@ -69,7 +69,7 @@ func (s *storager) assignMetadata(options []storage.Option, object *s3.GetObject
 func (s *storager) Get(ctx context.Context, location string, options ...storage.Option) (os.FileInfo, error) {
 	started := time.Now()
 	defer func() {
-		fmt.Printf("s3:Get %v %s\n", location, time.Since(started))
+		s.logF("s3:Get %v %s\n", location, time.Since(started))
 	}()
 	location = strings.Trim(location, "/")
 	info, err := s.get(ctx, location, options)

s3/list.go

@@ -2,7 +2,6 @@ package s3
 
 import (
 	"context"
-	"fmt"
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/credentials"
 	"github.com/aws/aws-sdk-go/service/s3"
@@ -77,7 +76,7 @@ func (s *storager) addFiles(parent string, result *[]os.FileInfo, objects []*s3.
 func (s *storager) list(ctx context.Context, parent string, result *[]os.FileInfo, page *option.Page, matcher option.Match) error {
 	started := time.Now()
 	defer func() {
-		fmt.Printf("s3:List %v %s\n", parent, time.Since(started))
+		s.logF("s3:List %v %s\n", parent, time.Since(started))
 	}()
 
 	input := &s3.ListObjectsInput{

s3/move.go

@@ -10,9 +10,14 @@ import (
 	"github.com/viant/afs/storage"
 	"path"
 	"strings"
+	"time"
 )
 
 func (s *storager) Move(ctx context.Context, sourcePath, destBucket, destPath string, options ...storage.Option) error {
+	started := time.Now()
+	defer func() {
+		s.logF("s3:Move %v-> %v/%v %s\n", sourcePath, destBucket, destPath, time.Since(started))
+	}()
 	sourcePath = strings.Trim(sourcePath, "/")
 	destPath = strings.Trim(destPath, "/")
 	source, err := s.get(ctx, sourcePath, options)

s3/open.go

@@ -23,7 +23,7 @@ import (
 func (s *storager) Open(ctx context.Context, location string, options ...storage.Option) (io.ReadCloser, error) {
 	started := time.Now()
 	defer func() {
-		fmt.Printf("s3:Open %v %s\n", location, time.Since(started))
+		s.logF("s3:Open %v %s\n", location, time.Since(started))
 	}()
 	var sess *session.Session
 	if s.config == nil {

s3/storager.go

@@ -2,7 +2,6 @@ package s3
 
 import (
 	"context"
-	"fmt"
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/session"
 	"github.com/aws/aws-sdk-go/service/s3"
@@ -28,13 +27,21 @@ type storager struct {
 	bucket string
 	region string
 	config *aws.Config
+	logger *option.Logger
 }
 
 //Close closes storager
 func (s *storager) Close() error {
 	return nil
 }
 
+func (s storager) logF(format string, args ...interface{}) {
+	if s.logger == nil {
+		return
+	}
+	s.logger.Logf(format, args...)
+}
+
 //FilterAuthOptions filters auth options
 func (s storager) FilterAuthOptions(options []storage.Option) []storage.Option {
 	var authOptions = make([]storage.Option, 0)
@@ -113,12 +120,15 @@ func newStorager(ctx context.Context, baseURL string, options ...storage.Option)
 	result := &storager{
 		bucket: url.Host(baseURL),
 	}
+
 	var err error
 	result.config, err = getAwsConfig(options)
 	if err != nil {
 		return nil, errors.Wrapf(err, "failed to get aws config")
 	}
 	result.initS3Client()
+	result.logger = &option.Logger{}
+	option.Assign(options, &result.logger)
 	return result, nil
 }
 
@@ -139,7 +149,7 @@ func (s *storager) initS3Client() {
 func (s *storager) adjustRegionIfNeeded() {
 	started := time.Now()
 	defer func() {
-		fmt.Printf("s3:GetBucketLocation %v %s\n", s.bucket, time.Since(started))
+		s.logF("s3:GetBucketLocation %v %s\n", s.bucket, time.Since(started))
 	}()
 	output, err := s.S3.GetBucketLocation(&s3.GetBucketLocationInput{Bucket: &s.bucket})
 	if err != nil {