xblob

type Bucket interface {
	Bucket() *blob.Bucket
	As(i interface{}) bool
	ErrorAs(err error, i interface{}) bool
	ReadAll(ctx context.Context, key string) (_ []byte, err error)
	List(opts *blob.ListOptions) *blob.ListIterator
	ListPage(ctx context.Context, pageToken []byte, pageSize int, opts *blob.ListOptions) (retval []*blob.ListObject, nextPageToken []byte, err error)
	IsAccessible(ctx context.Context) (bool, error)
	Exists(ctx context.Context, key string) (bool, error)
	Attributes(ctx context.Context, key string) (_ *blob.Attributes, err error)
	NewReader(ctx context.Context, key string, opts *blob.ReaderOptions) (Reader, error)
	NewRangeReader(ctx context.Context, key string, offset, length int64, opts *blob.ReaderOptions) (_ Reader, err error)
	WriteAll(ctx context.Context, key string, p []byte, opts *blob.WriterOptions) (err error)
	NewWriter(ctx context.Context, key string, opts *blob.WriterOptions) (_ Writer, err error)
	Copy(ctx context.Context, dstKey, srcKey string, opts *blob.CopyOptions) (err error)
	Delete(ctx context.Context, key string) (err error)
	SignedURL(ctx context.Context, key string, opts *blob.SignedURLOptions) (string, error)
	Close() error
}

type Reader interface {
	Read([]byte) (int, error)
	Close() error
	ContentType() string
	ModTime() time.Time
	Size() int64
	WriteTo(w io.Writer) (int64, error)
}

type Writer interface {
	Write([]byte) (int, error)
	Close() error
	ReadFrom(r io.Reader) (int64, error)
}