s3

Documentation

Index

• Constants
• func IsNotExist(err error) bool
• type Config
• type ConfigOption
  • func WithRegion(region string) ConfigOption
  • func WithStorageClass(storageClass string) ConfigOption
• type Service
  • func New(endpoint, accessKey, secretAccess, bucket string, useSSL bool, partSize uint64, ...) (Service, error)
  • func (a Service) ConvertError(err error) error
  • func (a Service) Enabled() bool
  • func (a Service) List(ctx context.Context, pathname string) ([]model.Item, error)
  • func (a Service) Mkdir(ctx context.Context, name string, _ os.FileMode) error
  • func (a Service) Name() string
  • func (a Service) Path(pathname string) string
  • func (a Service) ReadFrom(ctx context.Context, pathname string) (model.ReadAtSeekCloser, error)
  • func (a Service) RemoveAll(ctx context.Context, name string) error
  • func (a Service) Rename(ctx context.Context, oldName, newName string) error
  • func (a Service) Stat(ctx context.Context, pathname string) (model.Item, error)
  • func (a Service) UpdateDate(_ context.Context, _ string, _ time.Time) error
  • func (a Service) Walk(ctx context.Context, pathname string, walkFn func(model.Item) error) error
  • func (a Service) WithIgnoreFn(ignoreFn func(model.Item) bool) model.Storage
  • func (a Service) WriteTo(ctx context.Context, pathname string, reader io.Reader, opts model.WriteOpts) error

Constants

const Name = "object"

Functions

func IsNotExist

func IsNotExist(err error) bool

Types

type Config

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

type ConfigOption

type ConfigOption func(Config) Config

func WithRegion

func WithRegion(region string) ConfigOption

func WithStorageClass

func WithStorageClass(storageClass string) ConfigOption

type Service

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

func New

func New(endpoint, accessKey, secretAccess, bucket string, useSSL bool, partSize uint64, options ...ConfigOption) (Service, error)

func (Service) ConvertError

func (a Service) ConvertError(err error) error

func (Service) Enabled

func (a Service) Enabled() bool

func (Service) List

func (a Service) List(ctx context.Context, pathname string) ([]model.Item, error)

func (Service) Mkdir

func (a Service) Mkdir(ctx context.Context, name string, _ os.FileMode) error

func (Service) Name

func (a Service) Name() string

func (Service) Path

func (a Service) Path(pathname string) string

func (Service) ReadFrom

func (a Service) ReadFrom(ctx context.Context, pathname string) (model.ReadAtSeekCloser, error)

func (Service) RemoveAll

func (a Service) RemoveAll(ctx context.Context, name string) error

func (Service) Rename

func (a Service) Rename(ctx context.Context, oldName, newName string) error

func (Service) Stat

func (a Service) Stat(ctx context.Context, pathname string) (model.Item, error)

func (Service) UpdateDate

func (a Service) UpdateDate(_ context.Context, _ string, _ time.Time) error

func (Service) Walk

func (a Service) Walk(ctx context.Context, pathname string, walkFn func(model.Item) error) error

func (Service) WithIgnoreFn

func (a Service) WithIgnoreFn(ignoreFn func(model.Item) bool) model.Storage

func (Service) WriteTo

func (a Service) WriteTo(ctx context.Context, pathname string, reader io.Reader, opts model.WriteOpts) error