storage

Nov 9, 2022

Changes in this version

type ObjectNotFound

+ Path string

Nov 9, 2022

Changes in this version

+ const S3ListMaxKeys

Oct 27, 2022

Changes in this version

type Backend

+ List func(ctx context.Context, prefix string) ([]string, error)

+ Move func(ctx context.Context, srcPath, dstPath string) error

type BackendMethod

+ const ListMethod

+ const MoveMethod

type S3

+ func (s *S3) List(ctx context.Context, prefix string) ([]string, error)

+ func (s *S3) Move(ctx context.Context, srcPath, dstPath string) error

type S3Client

+ CopyObject func(ctx context.Context, params *s3.CopyObjectInput, optFns ...func(*s3.Options)) (*s3.CopyObjectOutput, error)

+ ListObjectsV2 func(ctx context.Context, params *s3.ListObjectsV2Input, ...) (*s3.ListObjectsV2Output, error)

type Swift

+ func (s *Swift) List(ctx context.Context, prefix string) ([]string, error)

+ func (s *Swift) Move(ctx context.Context, srcPath, dstPath string) error

Oct 13, 2022

Changes in this version

type Backend

+ Info func(ctx context.Context, path string) (types.Info, error)

type BackendMethod

+ const InfoMethod

+ type ObjectNotFound struct

+ func (o ObjectNotFound) Error() string

type S3

+ func (s *S3) Info(ctx context.Context, path string) (types.Info, error)

type Swift

+ func (s *Swift) Info(ctx context.Context, path string) (types.Info, error)

Oct 21, 2021

Changes in this version

+ const DefaultPartSize

+ const DefaultUploadConcurrency

+ func WithPartSize(size int64) s3Opt

+ func WithUploadConcurrency(concurrency int) s3Opt

Nov 18, 2020

Changes in this version

+ const NotFoundErrCode

+ func WithRetryPolicy(policy RetryPolicy) s3Opt

+ type Backend interface

+ Delete func(ctx context.Context, path string) error

+ Get func(ctx context.Context, path string) (io.ReadCloser, error)

+ Size func(ctx context.Context, path string) (int64, error)

+ Upload func(ctx context.Context, file io.Reader, path string) error

+ type BackendMethod string

+ const DeleteMethod

+ const GetMethod

+ const SizeMethod

+ const UploadMethod

+ type RetryPolicy struct

+ Attempts int

+ MethodHandlers map[BackendMethod][]string

+ WaitDuration time.Duration

+ type S3 struct

+ func NewS3(cfg S3Config, opts ...s3Opt) *S3

+ func (s *S3) Delete(ctx context.Context, path string) error

+ func (s *S3) Get(ctx context.Context, path string) (io.ReadCloser, error)

+ func (s *S3) Size(ctx context.Context, path string) (int64, error)

+ func (s *S3) Upload(ctx context.Context, file io.Reader, path string) error

+ type S3Client interface

+ DeleteObject func(ctx context.Context, input *s3.DeleteObjectInput, opts ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)

+ GetObject func(ctx context.Context, input *s3.GetObjectInput, opts ...func(*s3.Options)) (*s3.GetObjectOutput, error)

+ HeadObject func(ctx context.Context, input *s3.HeadObjectInput, opts ...func(*s3.Options)) (*s3.HeadObjectOutput, error)

+ type S3Config struct

+ AK string

+ Bucket string

+ Endpoint string

+ Region string

+ SK string

+ type Swift struct

+ func NewSwift(cfg SwiftConfig) (*Swift, error)

+ func (s *Swift) Delete(ctx context.Context, path string) error

+ func (s *Swift) Get(ctx context.Context, path string) (io.ReadCloser, error)

+ func (s *Swift) Size(ctx context.Context, path string) (int64, error)

+ func (s *Swift) Upload(ctx context.Context, reader io.Reader, path string) error

+ type SwiftConfig struct

+ ChunkSize int64

+ Container string

+ Prefix string