storage

package

Go to main page

Versions in this module

v1

v1.4.0

Sep 21, 2021

Changes in this version

type Metadata

+ func (m Metadata) CacheControl() string

+ func (m Metadata) Expires() string

+ func (m Metadata) SetCacheControl(cacheControl string) Metadata

+ func (m Metadata) SetExpires(expires string) Metadata

type Options

+ func (o *Options) SetRegion(region string)

type S3

+ func (s *S3) RemoveBucket(ctx context.Context, name string) error

+ func (s *S3) Select(ctx context.Context, url *url.URL, query *SelectQuery, ...) error

+ type SelectQuery struct

+ CompressionType string

+ Expression string

+ ExpressionType string

v1.4.0-rc.1

Aug 12, 2021

v1.3.0

Jul 1, 2021

Changes in this version

type Options

+ NoSignRequest bool

v1.2.1

Dec 3, 2020

Changes in this version

+ type SessionCache struct

v1.2.0

Nov 5, 2020

Changes in this version

type Filesystem

+ func NewLocalClient(opts Options) *Filesystem

+ func (f *Filesystem) Create(path string) (*os.File, error)

+ func (f *Filesystem) MkdirAll(path string) error

+ func (f *Filesystem) Open(path string) (*os.File, error)

+ type Options struct

+ DryRun bool

+ Endpoint string

+ MaxRetries int

+ NoVerifySSL bool

type S3

+ func NewRemoteClient(ctx context.Context, url *url.URL, opts Options) (*S3, error)

+ func (s *S3) Read(ctx context.Context, src *url.URL) (io.ReadCloser, error)

v1.1.0

Jul 22, 2020

Changes in this version

+ type Metadata map[string]string

+ func NewMetadata() Metadata

+ func (m Metadata) ACL() string

+ func (m Metadata) ContentType() string

+ func (m Metadata) SSE() string

+ func (m Metadata) SSEKeyID() string

+ func (m Metadata) SetACL(acl string) Metadata

+ func (m Metadata) SetContentType(contentType string) Metadata

+ func (m Metadata) SetSSE(sse string) Metadata

+ func (m Metadata) SetSSEKeyID(kid string) Metadata

+ func (m Metadata) SetStorageClass(class string) Metadata

+ func (m Metadata) StorageClass() string

type StorageClass

+ func (s StorageClass) IsGlacier() bool

v1.0.0

Apr 1, 2020

Changes in this version

+ var ErrGivenObjectNotFound = fmt.Errorf("given object not found")

+ var ErrNoObjectFound = fmt.Errorf("no object found")

+ func Init(opts S3Options) error

+ func IsCancelationError(err error) bool

+ func ShouldProcessUrl(url *url.URL, followSymlinks bool) bool

+ type Bucket struct

+ CreationDate time.Time

+ Name string

+ func (b Bucket) JSON() string

+ func (b Bucket) String() string

+ type CustomRetryer struct

+ func NewCustomRetryer(maxRetries int) *CustomRetryer

+ func (c *CustomRetryer) ShouldRetry(req *request.Request) bool

+ type Filesystem struct

+ func NewFilesystem() *Filesystem

+ func (f *Filesystem) Copy(ctx context.Context, src, dst *url.URL, _ map[string]string) error

+ func (f *Filesystem) Delete(ctx context.Context, url *url.URL) error

+ func (f *Filesystem) Get(_ context.Context, _ *url.URL, _ io.WriterAt, _ int, _ int64) (int64, error)

+ func (f *Filesystem) List(ctx context.Context, src *url.URL, followSymlinks bool) <-chan *Object

+ func (f *Filesystem) ListBuckets(_ context.Context, _ string) ([]Bucket, error)

+ func (f *Filesystem) MakeBucket(_ context.Context, _ string) error

+ func (f *Filesystem) MultiDelete(ctx context.Context, urlch <-chan *url.URL) <-chan *Object

+ func (f *Filesystem) Put(_ context.Context, _ io.Reader, _ *url.URL, _ map[string]string, _ int, ...) error

+ func (f *Filesystem) Stat(ctx context.Context, url *url.URL) (*Object, error)

+ type MockStorage struct

+ func (_m *MockStorage) Copy(ctx context.Context, src *url.URL, dst *url.URL, metadata map[string]string) error

+ func (_m *MockStorage) Delete(ctx context.Context, src *url.URL) error

+ func (_m *MockStorage) Get(ctx context.Context, src *url.URL, dst io.WriterAt, concurrency int, ...) (int64, error)

+ func (_m *MockStorage) List(ctx context.Context, src *url.URL, followSymlinks bool) <-chan *Object

+ func (_m *MockStorage) ListBuckets(ctx context.Context, prefix string) ([]Bucket, error)

+ func (_m *MockStorage) MakeBucket(ctx context.Context, bucket string) error

+ func (_m *MockStorage) MultiDelete(ctx context.Context, urls <-chan *url.URL) <-chan *Object

+ func (_m *MockStorage) Put(ctx context.Context, src io.Reader, dst *url.URL, metadata map[string]string, ...) error

+ func (_m *MockStorage) Stat(ctx context.Context, src *url.URL) (*Object, error)

+ type Object struct

+ Err error

+ Etag string

+ ModTime *time.Time

+ Size int64

+ StorageClass StorageClass

+ Type ObjectType

+ URL *url.URL

+ func (o *Object) JSON() string

+ func (o *Object) String() string

+ type ObjectType struct

+ func (o ObjectType) IsDir() bool

+ func (o ObjectType) IsSymlink() bool

+ func (o ObjectType) MarshalJSON() ([]byte, error)

+ func (o ObjectType) String() string

+ type S3 struct

+ func NewS3Storage(opts S3Options) (*S3, error)

+ func (s *S3) Copy(ctx context.Context, from, to *url.URL, metadata map[string]string) error

+ func (s *S3) Delete(ctx context.Context, url *url.URL) error

+ func (s *S3) Get(ctx context.Context, from *url.URL, to io.WriterAt, concurrency int, ...) (int64, error)

+ func (s *S3) List(ctx context.Context, url *url.URL, _ bool) <-chan *Object

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

+ func (s *S3) MakeBucket(ctx context.Context, name string) error

+ func (s *S3) MultiDelete(ctx context.Context, urlch <-chan *url.URL) <-chan *Object

+ func (s *S3) Put(ctx context.Context, reader io.Reader, to *url.URL, metadata map[string]string, ...) error

+ func (s *S3) Stat(ctx context.Context, url *url.URL) (*Object, error)

+ type S3Options struct

+ Endpoint string

+ MaxRetries int

+ NoVerifySSL bool

+ Region string

+ type Storage interface

+ Copy func(ctx context.Context, src, dst *url.URL, metadata map[string]string) error

+ Delete func(ctx context.Context, src *url.URL) error

+ Get func(ctx context.Context, src *url.URL, dst io.WriterAt, concurrency int, ...) (int64, error)

+ List func(ctx context.Context, src *url.URL, followSymlinks bool) <-chan *Object

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

+ MakeBucket func(ctx context.Context, bucket string) error

+ MultiDelete func(ctx context.Context, urls <-chan *url.URL) <-chan *Object

+ Put func(ctx context.Context, src io.Reader, dst *url.URL, metadata map[string]string, ...) error

+ Stat func(ctx context.Context, src *url.URL) (*Object, error)

+ func NewClient(url *url.URL) Storage

+ type StorageClass string

+ const StorageGlacier

+ const StorageInvalid

+ const StorageReducedRedundancy

+ const StorageStandard

+ const StorageStandardIA

+ func LookupClass(s string) StorageClass

+ func (s StorageClass) ShortCode() string

Other modules containing this package

github.com/peak/s5cmd/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL