aws

Documentation

Index

• type Aws
  • func NewAws(conf Config) (*Aws, error)
  • func (a *Aws) AbortMultipartUpload(ctx context.Context, uploadID string, name string) error
  • func (a *Aws) AccessURL(ctx context.Context, name string, expire time.Duration, ...) (string, error)
  • func (a *Aws) AuthSign(ctx context.Context, uploadID string, name string, expire time.Duration, ...) (*s3.AuthSignResult, error)
  • func (a *Aws) CompleteMultipartUpload(ctx context.Context, uploadID string, name string, parts []s3.Part) (*s3.CompleteMultipartUploadResult, error)
  • func (a *Aws) CopyObject(ctx context.Context, src string, dst string) (*s3.CopyObjectInfo, error)
  • func (a *Aws) DeleteObject(ctx context.Context, name string) error
  • func (a *Aws) Engine() string
  • func (a *Aws) FormData(ctx context.Context, name string, size int64, contentType string, ...) (*s3.FormData, error)
  • func (a *Aws) InitiateMultipartUpload(ctx context.Context, name string) (*s3.InitiateMultipartUploadResult, error)
  • func (a *Aws) IsNotFound(err error) bool
  • func (a *Aws) ListUploadedParts(ctx context.Context, uploadID string, name string, partNumberMarker int, ...) (*s3.ListUploadedPartsResult, error)
  • func (a *Aws) PartLimit() *s3.PartLimit
  • func (a *Aws) PartSize(ctx context.Context, size int64) (int64, error)
  • func (a *Aws) PresignedPutObject(ctx context.Context, name string, expire time.Duration) (string, error)
  • func (a *Aws) StatObject(ctx context.Context, name string) (*s3.ObjectInfo, error)
• type Config

Types

type Aws

type Aws struct {
	// contains filtered or unexported fields
}

func NewAws

func NewAws(conf Config) (*Aws, error)

func (*Aws) AbortMultipartUpload

func (a *Aws) AbortMultipartUpload(ctx context.Context, uploadID string, name string) error

func (*Aws) AccessURL

func (a *Aws) AccessURL(ctx context.Context, name string, expire time.Duration, opt *s3.AccessURLOption) (string, error)

func (*Aws) AuthSign

func (a *Aws) AuthSign(ctx context.Context, uploadID string, name string, expire time.Duration, partNumbers []int) (*s3.AuthSignResult, error)

func (*Aws) CompleteMultipartUpload

func (a *Aws) CompleteMultipartUpload(ctx context.Context, uploadID string, name string, parts []s3.Part) (*s3.CompleteMultipartUploadResult, error)

func (*Aws) CopyObject

func (a *Aws) CopyObject(ctx context.Context, src string, dst string) (*s3.CopyObjectInfo, error)

func (*Aws) DeleteObject

func (a *Aws) DeleteObject(ctx context.Context, name string) error

func (*Aws) Engine

func (a *Aws) Engine() string

func (*Aws) FormData

func (a *Aws) FormData(ctx context.Context, name string, size int64, contentType string, duration time.Duration) (*s3.FormData, error)

func (*Aws) InitiateMultipartUpload

func (a *Aws) InitiateMultipartUpload(ctx context.Context, name string) (*s3.InitiateMultipartUploadResult, error)

func (*Aws) IsNotFound

func (a *Aws) IsNotFound(err error) bool

func (*Aws) ListUploadedParts

func (a *Aws) ListUploadedParts(ctx context.Context, uploadID string, name string, partNumberMarker int, maxParts int) (*s3.ListUploadedPartsResult, error)

func (*Aws) PartLimit

func (a *Aws) PartLimit() *s3.PartLimit

func (*Aws) PartSize

func (a *Aws) PartSize(ctx context.Context, size int64) (int64, error)

func (*Aws) PresignedPutObject

func (a *Aws) PresignedPutObject(ctx context.Context, name string, expire time.Duration) (string, error)

func (*Aws) StatObject

func (a *Aws) StatObject(ctx context.Context, name string) (*s3.ObjectInfo, error)

type Config

type Config struct {
	Region          string
	Bucket          string
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
}