Versions in this module Expand all Collapse all v0 v0.24.0 Apr 4, 2020 Changes in this version + const ADL1_REQUEST_ID + const ADL2_CLIENT_REQUEST_ID + const ADL2_REQUEST_ID + const AzureBlobMetaDataHeaderPrefix + const AzureDirBlobMetadataKey + const AzuriteEndpoint + const BUF_SIZE + const CGROUP_FOLDER_PREFIX + const CGROUP_PATH + const INIT_ERR_BLOB + const MAX_READAHEAD + const MEM_LIMIT_FILE_SUFFIX + const MEM_USAGE_FILE_SUFFIX + const READAHEAD_CHUNK + var SmallActionsGate = Ticket{Total: 100}.Init() + var TIME_MAX = time.Unix(1<<63 - 62135596801, 999999999) + var VersionHash string + func Dup(value []byte) []byte + func GetTgid(pid uint32) (tgid *int32, err error) + func IsADLv1Endpoint(endpoint string) bool + func IsADLv2Endpoint(endpoint string) bool + func MassageMountFlags(args []string) (ret []string) + func MaxInt(a, b int) int + func MaxInt64(a, b int64) int64 + func MaxUInt32(a, b uint32) uint32 + func MaxUInt64(a, b uint64) uint64 + func MinInt(a, b int) int + func MinInt64(a, b int64) int64 + func MinUInt32(a, b uint32) uint32 + func MinUInt64(a, b uint64) uint64 + func MyUserAndGroup() (int, int) + func NewApp() (app *cli.App) + func PBool(v bool) *bool + func PInt32(v int32) *int32 + func PInt64(v int64) *int64 + func PString(v string) *string + func PTime(v time.Time) *time.Time + func PUInt32(v uint32) *uint32 + func PUInt64(v uint64) *uint64 + func PopulateFlags(c *cli.Context) (ret *FlagStorage) + func RandStringBytesMaskImprSrc(n int) string + func SignV2(req *request.Request) + func TryUnmount(mountPoint string) (err error) + type ADL2Error struct + func (e ADL2Error) Error() string + type ADLv1 struct + func NewADLv1(bucket string, flags *FlagStorage, config *ADLv1Config) (*ADLv1, error) + func (b *ADLv1) Bucket() string + func (b *ADLv1) Capabilities() *Capabilities + func (b *ADLv1) CopyBlob(param *CopyBlobInput) (*CopyBlobOutput, error) + func (b *ADLv1) Delegate() interface{} + func (b *ADLv1) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error) + func (b *ADLv1) DeleteBlobs(param *DeleteBlobsInput) (*DeleteBlobsOutput, error) + func (b *ADLv1) GetBlob(param *GetBlobInput) (*GetBlobOutput, error) + func (b *ADLv1) HeadBlob(param *HeadBlobInput) (*HeadBlobOutput, error) + func (b *ADLv1) Init(key string) error + func (b *ADLv1) ListBlobs(param *ListBlobsInput) (*ListBlobsOutput, error) + func (b *ADLv1) MakeBucket(param *MakeBucketInput) (*MakeBucketOutput, error) + func (b *ADLv1) MultipartBlobAbort(param *MultipartBlobCommitInput) (*MultipartBlobAbortOutput, error) + func (b *ADLv1) MultipartBlobAdd(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + func (b *ADLv1) MultipartBlobBegin(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + func (b *ADLv1) MultipartBlobCommit(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + func (b *ADLv1) MultipartExpire(param *MultipartExpireInput) (*MultipartExpireOutput, error) + func (b *ADLv1) PutBlob(param *PutBlobInput) (*PutBlobOutput, error) + func (b *ADLv1) RemoveBucket(param *RemoveBucketInput) (*RemoveBucketOutput, error) + func (b *ADLv1) RenameBlob(param *RenameBlobInput) (*RenameBlobOutput, error) + type ADLv1Err struct + RemoteException struct{ ... } + func (err ADLv1Err) Error() string + type ADLv1MultipartBlobCommitInput struct + Size uint64 + type ADLv2 struct + func NewADLv2(bucket string, flags *FlagStorage, config *ADLv2Config) (*ADLv2, error) + func (b *ADLv2) Bucket() string + func (b *ADLv2) Capabilities() *Capabilities + func (b *ADLv2) CopyBlob(param *CopyBlobInput) (*CopyBlobOutput, error) + func (b *ADLv2) Delegate() interface{} + func (b *ADLv2) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error) + func (b *ADLv2) DeleteBlobs(param *DeleteBlobsInput) (*DeleteBlobsOutput, error) + func (b *ADLv2) GetBlob(param *GetBlobInput) (*GetBlobOutput, error) + func (b *ADLv2) HeadBlob(param *HeadBlobInput) (*HeadBlobOutput, error) + func (b *ADLv2) Init(key string) (err error) + func (b *ADLv2) ListBlobs(param *ListBlobsInput) (*ListBlobsOutput, error) + func (b *ADLv2) MakeBucket(param *MakeBucketInput) (*MakeBucketOutput, error) + func (b *ADLv2) MultipartBlobAbort(param *MultipartBlobCommitInput) (*MultipartBlobAbortOutput, error) + func (b *ADLv2) MultipartBlobAdd(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + func (b *ADLv2) MultipartBlobBegin(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + func (b *ADLv2) MultipartBlobCommit(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + func (b *ADLv2) MultipartExpire(param *MultipartExpireInput) (*MultipartExpireOutput, error) + func (b *ADLv2) PutBlob(param *PutBlobInput) (*PutBlobOutput, error) + func (b *ADLv2) RemoveBucket(param *RemoveBucketInput) (*RemoveBucketOutput, error) + func (b *ADLv2) RenameBlob(param *RenameBlobInput) (*RenameBlobOutput, error) + type ADLv2MultipartBlobCommitInput struct + ContentType string + RenewLeaseStop chan bool + Size uint64 + type AZBlob struct + func NewAZBlob(container string, config *AZBlobConfig) (*AZBlob, error) + func (b *AZBlob) Bucket() string + func (b *AZBlob) Capabilities() *Capabilities + func (b *AZBlob) CopyBlob(param *CopyBlobInput) (*CopyBlobOutput, error) + func (b *AZBlob) Delegate() interface{} + func (b *AZBlob) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error) + func (b *AZBlob) DeleteBlobs(param *DeleteBlobsInput) (ret *DeleteBlobsOutput, deleteError error) + func (b *AZBlob) GetBlob(param *GetBlobInput) (*GetBlobOutput, error) + func (b *AZBlob) HeadBlob(param *HeadBlobInput) (*HeadBlobOutput, error) + func (b *AZBlob) Init(key string) error + func (b *AZBlob) ListBlobs(param *ListBlobsInput) (*ListBlobsOutput, error) + func (b *AZBlob) MakeBucket(param *MakeBucketInput) (*MakeBucketOutput, error) + func (b *AZBlob) MultipartBlobAbort(param *MultipartBlobCommitInput) (*MultipartBlobAbortOutput, error) + func (b *AZBlob) MultipartBlobAdd(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + func (b *AZBlob) MultipartBlobBegin(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + func (b *AZBlob) MultipartBlobCommit(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + func (b *AZBlob) MultipartExpire(param *MultipartExpireInput) (*MultipartExpireOutput, error) + func (b *AZBlob) PutBlob(param *PutBlobInput) (*PutBlobOutput, error) + func (b *AZBlob) RemoveBucket(param *RemoveBucketInput) (*RemoveBucketOutput, error) + func (b *AZBlob) RenameBlob(param *RenameBlobInput) (*RenameBlobOutput, error) + type BlobItemOutput struct + ETag *string + Key *string + LastModified *time.Time + Size uint64 + StorageClass *string + func (b BlobItemOutput) String() string + type BlobPrefixOutput struct + Prefix *string + func (b BlobPrefixOutput) String() string + type BucketSpec struct + Bucket string + Prefix string + Scheme string + func ParseBucketSpec(bucket string) (spec BucketSpec, err error) + type Buffer struct + func (b *Buffer) Close() (err error) + func (b *Buffer) ReInit(r ReaderProvider) + func (b *Buffer) Read(p []byte) (n int, err error) + func (b Buffer) Init(buf *MBuf, r ReaderProvider) *Buffer + type BufferPool struct + func NewBufferPool(maxSizeGlobal uint64) *BufferPool + func (pool *BufferPool) Free(buf []byte) + func (pool *BufferPool) MaybeGC() + func (pool *BufferPool) RequestBuffer() (buf []byte) + func (pool *BufferPool) RequestMultiple(size uint64, block bool) (buffers [][]byte) + func (pool BufferPool) Init() *BufferPool + type Capabilities struct + DirBlob bool + MaxMultipartSize uint64 + Name string + NoParallelMultipart bool + type CopyBlobInput struct + Destination string + ETag *string + Metadata map[string]*string + Size *uint64 + Source string + StorageClass *string + type CopyBlobOutput struct + RequestId string + type Delegator interface + Delegate func() interface{} + type DeleteBlobInput struct + Key string + type DeleteBlobOutput struct + RequestId string + type DeleteBlobsInput struct + Items []string + type DeleteBlobsOutput struct + RequestId string + type DirHandle struct + Marker *string + func NewDirHandle(inode *Inode) (dh *DirHandle) + func (dh *DirHandle) CloseDir() error + func (dh *DirHandle) ReadDir(offset fuseops.DirOffset) (en *DirHandleEntry, err error) + type DirHandleEntry struct + Inode fuseops.InodeID + Name string + Offset fuseops.DirOffset + Type fuseutil.DirentType + type DirInodeData struct + Children []*Inode + DirTime time.Time + type FileHandle struct + Tgid *int32 + func NewFileHandle(inode *Inode, opMetadata fuseops.OpMetadata) *FileHandle + func (fh *FileHandle) FlushFile() (err error) + func (fh *FileHandle) ReadFile(offset int64, buf []byte) (bytesRead int, err error) + func (fh *FileHandle) Release() + func (fh *FileHandle) WriteFile(offset int64, data []byte) (err error) + type GCS3 struct + func NewGCS3(bucket string, flags *FlagStorage, config *S3Config) (*GCS3, error) + func (s *GCS3) Delegate() interface{} + func (s *GCS3) DeleteBlobs(param *DeleteBlobsInput) (*DeleteBlobsOutput, error) + func (s *GCS3) MultipartBlobAdd(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + func (s *GCS3) MultipartBlobBegin(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + func (s *GCS3) MultipartBlobCommit(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + type GCSMultipartBlobCommitInput struct + ETag *string + Prev *MultipartBlobAddInput + Size uint64 + type GetBlobInput struct + Count uint64 + IfMatch *string + Key string + Start uint64 + type GetBlobOutput struct + Body io.ReadCloser + RequestId string + type Goofys struct + func NewGoofys(ctx context.Context, bucket string, flags *FlagStorage) *Goofys + func (fs *Goofys) CreateFile(ctx context.Context, op *fuseops.CreateFileOp) (err error) + func (fs *Goofys) FlushFile(ctx context.Context, op *fuseops.FlushFileOp) (err error) + func (fs *Goofys) ForgetInode(ctx context.Context, op *fuseops.ForgetInodeOp) (err error) + func (fs *Goofys) GetInodeAttributes(ctx context.Context, op *fuseops.GetInodeAttributesOp) (err error) + func (fs *Goofys) GetXattr(ctx context.Context, op *fuseops.GetXattrOp) (err error) + func (fs *Goofys) ListXattr(ctx context.Context, op *fuseops.ListXattrOp) (err error) + func (fs *Goofys) LookUpInode(ctx context.Context, op *fuseops.LookUpInodeOp) (err error) + func (fs *Goofys) MkDir(ctx context.Context, op *fuseops.MkDirOp) (err error) + func (fs *Goofys) Mount(mount *Mount) + func (fs *Goofys) MountAll(mounts []*Mount) + func (fs *Goofys) OpenDir(ctx context.Context, op *fuseops.OpenDirOp) (err error) + func (fs *Goofys) OpenFile(ctx context.Context, op *fuseops.OpenFileOp) (err error) + func (fs *Goofys) ReadDir(ctx context.Context, op *fuseops.ReadDirOp) (err error) + func (fs *Goofys) ReadFile(ctx context.Context, op *fuseops.ReadFileOp) (err error) + func (fs *Goofys) ReleaseDirHandle(ctx context.Context, op *fuseops.ReleaseDirHandleOp) (err error) + func (fs *Goofys) ReleaseFileHandle(ctx context.Context, op *fuseops.ReleaseFileHandleOp) (err error) + func (fs *Goofys) RemoveXattr(ctx context.Context, op *fuseops.RemoveXattrOp) (err error) + func (fs *Goofys) Rename(ctx context.Context, op *fuseops.RenameOp) (err error) + func (fs *Goofys) RmDir(ctx context.Context, op *fuseops.RmDirOp) (err error) + func (fs *Goofys) SetInodeAttributes(ctx context.Context, op *fuseops.SetInodeAttributesOp) (err error) + func (fs *Goofys) SetXattr(ctx context.Context, op *fuseops.SetXattrOp) (err error) + func (fs *Goofys) SigUsr1() + func (fs *Goofys) StatFS(ctx context.Context, op *fuseops.StatFSOp) (err error) + func (fs *Goofys) SyncFile(ctx context.Context, op *fuseops.SyncFileOp) (err error) + func (fs *Goofys) Unlink(ctx context.Context, op *fuseops.UnlinkOp) (err error) + func (fs *Goofys) Unmount(mountPoint string) + func (fs *Goofys) WriteFile(ctx context.Context, op *fuseops.WriteFileOp) (err error) + type HeadBlobInput struct + Key string + type HeadBlobOutput struct + ContentType *string + IsDirBlob bool + Metadata map[string]*string + RequestId string + type Inode struct + AttrTime time.Time + Attributes InodeAttributes + Id fuseops.InodeID + ImplicitDir bool + Invalid bool + KnownSize *uint64 + Name *string + Parent *Inode + func NewInode(fs *Goofys, parent *Inode, name *string) (inode *Inode) + func (inode *Inode) DeRef(n uint64) (stale bool) + func (inode *Inode) FullName() *string + func (inode *Inode) GetAttributes() (*fuseops.InodeAttributes, error) + func (inode *Inode) GetXattr(name string) ([]byte, error) + func (inode *Inode) InflateAttributes() (attr fuseops.InodeAttributes) + func (inode *Inode) ListXattr() ([]string, error) + func (inode *Inode) OpenDir() (dh *DirHandle) + func (inode *Inode) OpenFile(metadata fuseops.OpMetadata) (fh *FileHandle, err error) + func (inode *Inode) Ref() + func (inode *Inode) RemoveXattr(name string) error + func (inode *Inode) ResetForUnmount() + func (inode *Inode) SetFromBlobItem(item *BlobItemOutput) + func (inode *Inode) SetXattr(name string, value []byte, flags uint32) error + func (inode *Inode) ToDir() + func (parent *Inode) Create(name string, metadata fuseops.OpMetadata) (inode *Inode, fh *FileHandle) + func (parent *Inode) LookUp(name string) (inode *Inode, err error) + func (parent *Inode) LookUpInodeDir(name string, c chan ListBlobsOutput, errc chan error) + func (parent *Inode) LookUpInodeMaybeDir(name string, fullName string) (inode *Inode, err error) + func (parent *Inode) LookUpInodeNotDir(name string, c chan HeadBlobOutput, errc chan error) + func (parent *Inode) MkDir(name string) (inode *Inode, err error) + func (parent *Inode) Rename(from string, newParent *Inode, to string) (err error) + func (parent *Inode) RmDir(name string) (err error) + func (parent *Inode) Unlink(name string) (err error) + type InodeAttributes struct + Mtime time.Time + Size uint64 + func (i InodeAttributes) Equal(other InodeAttributes) bool + type ListBlobsInput struct + ContinuationToken *string + Delimiter *string + MaxKeys *uint32 + Prefix *string + StartAfter *string + type ListBlobsOutput struct + IsTruncated bool + Items []BlobItemOutput + NextContinuationToken *string + Prefixes []BlobPrefixOutput + RequestId string + type MBuf struct + func (mb *MBuf) Close() error + func (mb *MBuf) Free() + func (mb *MBuf) Full() bool + func (mb *MBuf) Len() (length int) + func (mb *MBuf) Read(p []byte) (n int, err error) + func (mb *MBuf) Reset() + func (mb *MBuf) Seek(offset int64, whence int) (int64, error) + func (mb *MBuf) Write(p []byte) (n int, err error) + func (mb *MBuf) WriteFrom(r io.Reader) (n int, err error) + func (mb MBuf) Init(h *BufferPool, size uint64, block bool) *MBuf + type MakeBucketInput struct + type MakeBucketOutput struct + RequestId string + type Mount struct + type MultipartBlobAbortOutput struct + RequestId string + type MultipartBlobAddInput struct + Body io.ReadSeeker + Commit *MultipartBlobCommitInput + Last bool + Offset uint64 + PartNumber uint32 + Size uint64 + type MultipartBlobAddOutput struct + RequestId string + type MultipartBlobBeginInput struct + ContentType *string + Key string + Metadata map[string]*string + type MultipartBlobCommitInput struct + Key *string + Metadata map[string]*string + NumParts uint32 + Parts []*string + UploadId *string + type MultipartBlobCommitOutput struct + ETag *string + LastModified *time.Time + RequestId string + StorageClass *string + type MultipartExpireInput struct + type MultipartExpireOutput struct + RequestId string + type PutBlobInput struct + Body io.ReadSeeker + ContentType *string + DirBlob bool + Key string + Metadata map[string]*string + Size *uint64 + type PutBlobOutput struct + ETag *string + LastModified *time.Time + RequestId string + StorageClass *string + type ReadSeekerCloser struct + func (r *ReadSeekerCloser) Close() error + type ReaderProvider func() (io.ReadCloser, error) + type RemoveBucketInput struct + type RemoveBucketOutput struct + RequestId string + type RenameBlobInput struct + Destination string + Source string + type RenameBlobOutput struct + RequestId string + type S3Backend struct + func NewS3(bucket string, flags *FlagStorage, config *S3Config) (*S3Backend, error) + func (s *S3Backend) Bucket() string + func (s *S3Backend) Capabilities() *Capabilities + func (s *S3Backend) CopyBlob(param *CopyBlobInput) (*CopyBlobOutput, error) + func (s *S3Backend) Delegate() interface{} + func (s *S3Backend) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error) + func (s *S3Backend) DeleteBlobs(param *DeleteBlobsInput) (*DeleteBlobsOutput, error) + func (s *S3Backend) GetBlob(param *GetBlobInput) (*GetBlobOutput, error) + func (s *S3Backend) HeadBlob(param *HeadBlobInput) (*HeadBlobOutput, error) + func (s *S3Backend) Init(key string) error + func (s *S3Backend) ListBlobs(param *ListBlobsInput) (*ListBlobsOutput, error) + func (s *S3Backend) ListObjectsV2(params *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, string, error) + func (s *S3Backend) MakeBucket(param *MakeBucketInput) (*MakeBucketOutput, error) + func (s *S3Backend) MultipartBlobAbort(param *MultipartBlobCommitInput) (*MultipartBlobAbortOutput, error) + func (s *S3Backend) MultipartBlobAdd(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + func (s *S3Backend) MultipartBlobBegin(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + func (s *S3Backend) MultipartBlobCommit(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + func (s *S3Backend) MultipartExpire(param *MultipartExpireInput) (*MultipartExpireOutput, error) + func (s *S3Backend) PutBlob(param *PutBlobInput) (*PutBlobOutput, error) + func (s *S3Backend) RemoveBucket(param *RemoveBucketInput) (*RemoveBucketOutput, error) + func (s *S3Backend) RenameBlob(param *RenameBlobInput) (*RenameBlobOutput, error) + type S3ReadBuffer struct + func (b *S3ReadBuffer) Read(offset uint64, p []byte) (n int, err error) + func (b S3ReadBuffer) Init(fh *FileHandle, offset uint64, size uint32) *S3ReadBuffer + type StorageBackend interface + Bucket func() string + Capabilities func() *Capabilities + CopyBlob func(param *CopyBlobInput) (*CopyBlobOutput, error) + Delegate func() interface{} + DeleteBlob func(param *DeleteBlobInput) (*DeleteBlobOutput, error) + DeleteBlobs func(param *DeleteBlobsInput) (*DeleteBlobsOutput, error) + GetBlob func(param *GetBlobInput) (*GetBlobOutput, error) + HeadBlob func(param *HeadBlobInput) (*HeadBlobOutput, error) + Init func(key string) error + ListBlobs func(param *ListBlobsInput) (*ListBlobsOutput, error) + MakeBucket func(param *MakeBucketInput) (*MakeBucketOutput, error) + MultipartBlobAbort func(param *MultipartBlobCommitInput) (*MultipartBlobAbortOutput, error) + MultipartBlobAdd func(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + MultipartBlobBegin func(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + MultipartBlobCommit func(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + MultipartExpire func(param *MultipartExpireInput) (*MultipartExpireOutput, error) + PutBlob func(param *PutBlobInput) (*PutBlobOutput, error) + RemoveBucket func(param *RemoveBucketInput) (*RemoveBucketOutput, error) + RenameBlob func(param *RenameBlobInput) (*RenameBlobOutput, error) + func NewBackend(bucket string, flags *FlagStorage) (cloud StorageBackend, err error) + type StorageBackendInitError struct + func (e StorageBackendInitError) Capabilities() *Capabilities + func (e StorageBackendInitError) CopyBlob(param *CopyBlobInput) (*CopyBlobOutput, error) + func (e StorageBackendInitError) Delegate() interface{} + func (e StorageBackendInitError) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error) + func (e StorageBackendInitError) DeleteBlobs(param *DeleteBlobsInput) (*DeleteBlobsOutput, error) + func (e StorageBackendInitError) GetBlob(param *GetBlobInput) (*GetBlobOutput, error) + func (e StorageBackendInitError) HeadBlob(param *HeadBlobInput) (*HeadBlobOutput, error) + func (e StorageBackendInitError) Init(key string) error + func (e StorageBackendInitError) ListBlobs(param *ListBlobsInput) (*ListBlobsOutput, error) + func (e StorageBackendInitError) MakeBucket(param *MakeBucketInput) (*MakeBucketOutput, error) + func (e StorageBackendInitError) MultipartBlobAbort(param *MultipartBlobCommitInput) (*MultipartBlobAbortOutput, error) + func (e StorageBackendInitError) MultipartBlobAdd(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + func (e StorageBackendInitError) MultipartBlobBegin(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + func (e StorageBackendInitError) MultipartBlobCommit(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + func (e StorageBackendInitError) MultipartExpire(param *MultipartExpireInput) (*MultipartExpireOutput, error) + func (e StorageBackendInitError) PutBlob(param *PutBlobInput) (*PutBlobOutput, error) + func (e StorageBackendInitError) RemoveBucket(param *RemoveBucketInput) (*RemoveBucketOutput, error) + func (e StorageBackendInitError) RenameBlob(param *RenameBlobInput) (*RenameBlobOutput, error) + func (s StorageBackendInitError) Bucket() string + type StorageBackendInitWrapper struct + func (s *StorageBackendInitWrapper) Bucket() string + func (s *StorageBackendInitWrapper) Capabilities() *Capabilities + func (s *StorageBackendInitWrapper) CopyBlob(param *CopyBlobInput) (*CopyBlobOutput, error) + func (s *StorageBackendInitWrapper) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error) + func (s *StorageBackendInitWrapper) DeleteBlobs(param *DeleteBlobsInput) (*DeleteBlobsOutput, error) + func (s *StorageBackendInitWrapper) GetBlob(param *GetBlobInput) (*GetBlobOutput, error) + func (s *StorageBackendInitWrapper) HeadBlob(param *HeadBlobInput) (*HeadBlobOutput, error) + func (s *StorageBackendInitWrapper) Init(key string) error + func (s *StorageBackendInitWrapper) ListBlobs(param *ListBlobsInput) (*ListBlobsOutput, error) + func (s *StorageBackendInitWrapper) MakeBucket(param *MakeBucketInput) (*MakeBucketOutput, error) + func (s *StorageBackendInitWrapper) MultipartBlobAbort(param *MultipartBlobCommitInput) (*MultipartBlobAbortOutput, error) + func (s *StorageBackendInitWrapper) MultipartBlobAdd(param *MultipartBlobAddInput) (*MultipartBlobAddOutput, error) + func (s *StorageBackendInitWrapper) MultipartBlobBegin(param *MultipartBlobBeginInput) (*MultipartBlobCommitInput, error) + func (s *StorageBackendInitWrapper) MultipartBlobCommit(param *MultipartBlobCommitInput) (*MultipartBlobCommitOutput, error) + func (s *StorageBackendInitWrapper) MultipartExpire(param *MultipartExpireInput) (*MultipartExpireOutput, error) + func (s *StorageBackendInitWrapper) PutBlob(param *PutBlobInput) (*PutBlobOutput, error) + func (s *StorageBackendInitWrapper) RemoveBucket(param *RemoveBucketInput) (*RemoveBucketOutput, error) + func (s *StorageBackendInitWrapper) RenameBlob(param *RenameBlobInput) (*RenameBlobOutput, error) + type Ticket struct + Total uint32 + func (ticket *Ticket) Return(howmany uint32) + func (ticket *Ticket) Take(howmany uint32, block bool) (took bool) + func (ticket Ticket) Init() *Ticket
Go to main page