Function NewManager

ots3/uploader.go:94–132

NewManager creates a new S3 manager

(accessKey, accessSecret, endpoint, region, bucket string, opts ...ManagerOptionFunc)

// NewManager creates a new S3 manager
func NewManager(accessKey, accessSecret, endpoint, region, bucket string, opts ...ManagerOptionFunc) *Manager {
	c := &ManagerConfig{
		doer:  http.DefaultClient,
		keyer: key.New(),
		locationFunc: func(location string) (url string) {
			return location
		},
		autoExtension: true,
	}
	for _, f := range opts {
		f(c)
	}

	s3Config := &aws.Config{
		Credentials:      credentials.NewStaticCredentials(accessKey, accessSecret, ""),
		Endpoint:         aws.String(endpoint),
		Region:           aws.String(region),
		DisableSSL:       aws.Bool(true),
		S3ForcePathStyle: aws.Bool(true),
	}
	sess := session.Must(session.NewSession(s3Config))
	c.keyer.Key("/")
	m := &Manager{
		bucket:        bucket,
		sess:          sess,
		tracer:        c.tracer,
		doer:          c.doer,
		pathPrefix:    c.pathPrefix,
		keyer:         c.keyer,
		locationFunc:  c.locationFunc,
		autoExtension: c.autoExtension,
	}

	// add opentracing capabilities if opt factoryIn
	if c.tracer != nil {
		sess.Handlers.Build.PushFront(m.otHandler())
	}
	return m
}

// Upload uploads an io.reader to the S3 server, and returns the url on S3. The extension of the uploaded file
// is auto detected.