awsclient

Documentation

Index

• func NewSession(m *dbschema.NgingCloudStorage) (*session.Session, error)
• type AWSClient
  • func Connect(m *dbschema.NgingCloudStorage, bucketName string) (client *AWSClient, err error)
  • func (s *AWSClient) CompleteMultipartUpload(ctx echo.Context, objectName string, uploadId string) error
  • func (s *AWSClient) GetBucketCors() ([]*s3.CORSRule, error)
  • func (s *AWSClient) ListPage(ctx echo.Context, objectPrefix string) (dirs []os.FileInfo, err error)
  • func (s *AWSClient) PutBucketCors(ctx echo.Context) error
  • func (s *AWSClient) SetBucketName(bucketName string) *AWSClient
  • func (s *AWSClient) Upload(reader io.Reader, objectName string) (*s3manager.UploadOutput, error)

Functions

func NewSession

func NewSession(m *dbschema.NgingCloudStorage) (*session.Session, error)

Types

type AWSClient

type AWSClient struct {
	*s3.S3
	// contains filtered or unexported fields
}

func Connect

func Connect(m *dbschema.NgingCloudStorage, bucketName string) (client *AWSClient, err error)

func (*AWSClient) CompleteMultipartUpload

func (s *AWSClient) CompleteMultipartUpload(ctx echo.Context, objectName string, uploadId string) error

func (*AWSClient) GetBucketCors

func (s *AWSClient) GetBucketCors() ([]*s3.CORSRule, error)

func (*AWSClient) ListPage

func (s *AWSClient) ListPage(ctx echo.Context, objectPrefix string) (dirs []os.FileInfo, err error)

func (*AWSClient) PutBucketCors

func (s *AWSClient) PutBucketCors(ctx echo.Context) error

func (*AWSClient) SetBucketName

func (s *AWSClient) SetBucketName(bucketName string) *AWSClient

func (*AWSClient) Upload

func (s *AWSClient) Upload(reader io.Reader, objectName string) (*s3manager.UploadOutput, error)