storage

Jan 10, 2022

Changes in this version

+ var ErrFileNotFound = errors.New("file not found")

type Client

+ func (c *Client) StreamAt(key string, off int64, n int64) (io.ReadCloser, int64, error)

type Strategy

+ StreamAt func(key string, off int64, n int64) (io.ReadCloser, int64, error)

Jun 22, 2021

Changes in this version

+ func Apply(opts ...Option) option

+ type Attrs struct

+ ContentType string

+ StorageClass string

+ type Client struct

+ StorageStrategy Strategy

+ func NewStorageClient(ctx context.Context, storageStrategy Strategy) (*Client, error)

+ func (c *Client) Delete(ctx context.Context, uri string, options ...Option) error

+ func (c *Client) Download(ctx context.Context, uri string, options ...Option) ([]byte, error)

+ func (c *Client) DownloadTo(ctx context.Context, source string, destination string, options ...Option) error

+ func (c *Client) Exist(ctx context.Context, uri string) (bool, error)

+ func (c *Client) GetAttrs(ctx context.Context, uri string) (Attrs, error)

+ func (c *Client) Upload(ctx context.Context, uri string, data []byte, options ...Option) error

+ func (c *Client) UploadFile(ctx context.Context, uri string, data io.ReadCloser, options ...Option) error

+ type ExcludeFunc func(objectName string) bool

+ type Option func(o *option)

+ func Concurrency(c int) Option

+ func Exclude(ex ExcludeFunc) Option

+ func Length(l int64) Option

+ func MaxTries(n int) Option

+ func Offset(off int64) Option

+ func OnErrorRetryDelay(d time.Duration) Option

+ func StorageClass(cl string) Option

+ type Strategy interface

+ Delete func(ctx context.Context, uri string, options ...Option) error

+ Download func(ctx context.Context, uri string, options ...Option) ([]byte, error)

+ DownloadToFile func(ctx context.Context, source string, destination string, options ...Option) error

+ Exist func(ctx context.Context, uri string) (bool, error)

+ GetAttrs func(ctx context.Context, uri string) (Attrs, error)

+ Upload func(ctx context.Context, uri string, data []byte, options ...Option) error

+ UploadFile func(ctx context.Context, uri string, data io.ReadCloser, options ...Option) error