blob

Dec 28, 2023

Changes in this version

type WriterOptions

+ DisableContentTypeDetection bool

Jul 19, 2023

Changes in this version

type Bucket

+ func (b *Bucket) Open(path string) (fs.File, error)

+ func (b *Bucket) SetIOFSCallback(fn func() (context.Context, *ReaderOptions))

+ func (b *Bucket) Sub(dir string) (fs.FS, error)

Jun 19, 2023

Changes in this version

type Bucket

+ func (b *Bucket) Download(ctx context.Context, key string, w io.Writer, opts *ReaderOptions) error

+ func (b *Bucket) Upload(ctx context.Context, key string, r io.Reader, opts *WriterOptions) error

Aug 3, 2022

Changes in this version

type Reader

+ func (r *Reader) Seek(offset int64, whence int) (int64, error)

type WriterOptions

+ MaxConcurrency int

Apr 2, 2022

Changes in this version

type Bucket

+ func SingleKeyBucket(bucket *Bucket, singleKey string) *Bucket

Dec 9, 2020

Changes in this version

+ var FirstPageToken = []byte("first page")

type Attributes

+ CreateTime time.Time

+ ETag string

type Bucket

+ func (b *Bucket) IsAccessible(ctx context.Context) (bool, error)

+ func (b *Bucket) ListPage(ctx context.Context, pageToken []byte, pageSize int, opts *ListOptions) (retval []*ListObject, nextPageToken []byte, err error)

type SignedURLOptions

+ BeforeSign func(asFunc func(interface{}) bool) error

Feb 10, 2020

Changes in this version

type Reader

+ func (r *Reader) WriteTo(w io.Writer) (int64, error)

type SignedURLOptions

+ ContentType string

+ EnforceAbsentContentType bool

type Writer

+ func (w *Writer) ReadFrom(r io.Reader) (int64, error)

Aug 9, 2019

Changes in this version

type SignedURLOptions

+ Method string

May 29, 2019

Changes in this version

type Bucket

+ func PrefixedBucket(bucket *Bucket, prefix string) *Bucket

type ReaderOptions

+ BeforeRead func(asFunc func(interface{}) bool) error

Apr 24, 2019

Changes in this version

type Bucket

+ func (b *Bucket) Copy(ctx context.Context, dstKey, srcKey string, opts *CopyOptions) (err error)

+ type CopyOptions struct

+ BeforeCopy func(asFunc func(interface{}) bool) error

type URLMux

+ func (mux *URLMux) BucketSchemes() []string

+ func (mux *URLMux) ValidBucketScheme(scheme string) bool

Mar 20, 2019

Changes in this version

type Bucket

+ func (b *Bucket) Close() error

Feb 28, 2019

Changes in this version

type Bucket

+ func (b *Bucket) Exists(ctx context.Context, key string) (bool, error)

Feb 12, 2019

Changes in this version

+ var OpenCensusViews = append(oc.Views(pkgName, latencyMeasure), &view.View{ ... }, &view.View{ ... })

type Bucket

+ func OpenBucket(ctx context.Context, urlstr string) (*Bucket, error)

+ func (b *Bucket) ErrorAs(err error, i interface{}) bool

+ type BucketURLOpener interface

+ OpenBucketURL func(ctx context.Context, u *url.URL) (*Bucket, error)

+ type URLMux struct

+ func DefaultURLMux() *URLMux

+ func (mux *URLMux) OpenBucket(ctx context.Context, urlstr string) (*Bucket, error)

+ func (mux *URLMux) OpenBucketURL(ctx context.Context, u *url.URL) (*Bucket, error)

+ func (mux *URLMux) RegisterBucket(scheme string, opener BucketURLOpener)

Jan 15, 2019

Changes in this version

type Attributes

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ MD5 []byte

type ListObject

+ MD5 []byte

type WriterOptions

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

Dec 13, 2018

Changes in this version

+ const DefaultSignedURLExpiry

+ func ErrorAs(err error, i interface{}) bool

+ func IsNotExist(err error) bool

+ func IsNotImplemented(err error) bool

+ func Register(scheme string, fn FromURLFunc)

+ type Attributes struct

+ ContentType string

+ Metadata map[string]string

+ ModTime time.Time

+ Size int64

+ func (a *Attributes) As(i interface{}) bool

+ type Bucket struct

+ func NewBucket(b driver.Bucket) *Bucket

+ func Open(ctx context.Context, urlstr string) (*Bucket, error)

+ func (b *Bucket) As(i interface{}) bool

+ func (b *Bucket) Attributes(ctx context.Context, key string) (Attributes, error)

+ func (b *Bucket) Delete(ctx context.Context, key string) error

+ func (b *Bucket) List(opts *ListOptions) *ListIterator

+ func (b *Bucket) NewRangeReader(ctx context.Context, key string, offset, length int64, opts *ReaderOptions) (*Reader, error)

+ func (b *Bucket) NewReader(ctx context.Context, key string, opts *ReaderOptions) (*Reader, error)

+ func (b *Bucket) NewWriter(ctx context.Context, key string, opts *WriterOptions) (*Writer, error)

+ func (b *Bucket) ReadAll(ctx context.Context, key string) ([]byte, error)

+ func (b *Bucket) SignedURL(ctx context.Context, key string, opts *SignedURLOptions) (string, error)

+ func (b *Bucket) WriteAll(ctx context.Context, key string, p []byte, opts *WriterOptions) error

+ type FromURLFunc func(context.Context, *url.URL) (driver.Bucket, error)

+ type ListIterator struct

+ func (i *ListIterator) Next(ctx context.Context) (*ListObject, error)

+ type ListObject struct

+ IsDir bool

+ Key string

+ ModTime time.Time

+ Size int64

+ func (o *ListObject) As(i interface{}) bool

+ type ListOptions struct

+ BeforeList func(asFunc func(interface{}) bool) error

+ Delimiter string

+ Prefix string

+ type Reader struct

+ func (r *Reader) As(i interface{}) bool

+ func (r *Reader) Close() error

+ func (r *Reader) ContentType() string

+ func (r *Reader) ModTime() time.Time

+ func (r *Reader) Read(p []byte) (int, error)

+ func (r *Reader) Size() int64

+ type ReaderOptions struct

+ type SignedURLOptions struct

+ Expiry time.Duration

+ type Writer struct

+ func (w *Writer) Close() error

+ func (w *Writer) Write(p []byte) (n int, err error)

+ type WriterOptions struct

+ BeforeWrite func(asFunc func(interface{}) bool) error

+ BufferSize int

+ ContentMD5 []byte

+ ContentType string

+ Metadata map[string]string