internal

package

Go to main page

Versions in this module

v0

v0.24.0

Apr 4, 2020

Changes in this version

type InodeAttributes

+ func (i InodeAttributes) Equal(other InodeAttributes) bool

type MultipartBlobCommitOutput

+ LastModified *time.Time

+ StorageClass *string

type PutBlobOutput

+ LastModified *time.Time

v0.23.1

Nov 17, 2019

v0.23.0

Nov 13, 2019

Changes in this version

type ADLv1

+ func (b *ADLv1) Delegate() interface{}

type ADLv2

+ func (b *ADLv2) Delegate() interface{}

type AZBlob

+ func (b *AZBlob) Delegate() interface{}

type Buffer

+ func (b *Buffer) ReInit(r ReaderProvider)

+ type Delegator interface

+ Delegate func() interface{}

type GCS3

+ func (s *GCS3) Delegate() interface{}

type MBuf

+ func (mb *MBuf) Reset()

type S3Backend

+ func (s *S3Backend) Delegate() interface{}

type StorageBackend

+ Delegate func() interface{}

type StorageBackendInitError

+ func (e StorageBackendInitError) Delegate() interface{}

v0.22.0

Nov 2, 2019

Changes in this version

+ const AzureBlobMetaDataHeaderPrefix

+ func GetTgid(pid uint32) (tgid *int32, err error)

type FileHandle

+ Tgid *int32

v0.21.0

Aug 21, 2019

Changes in this version

+ const ADL1_REQUEST_ID

+ const ADL2_CLIENT_REQUEST_ID

+ const ADL2_REQUEST_ID

+ const AzureDirBlobMetadataKey

+ const AzuriteEndpoint

+ const INIT_ERR_BLOB

+ var SmallActionsGate = Ticket{Total: 100}.Init()

+ var TIME_MAX = time.Unix(1<<63 - 62135596801, 999999999)

+ func IsADLv1Endpoint(endpoint string) bool

+ func IsADLv2Endpoint(endpoint string) bool

+ func MaxInt64(a, b int64) int64

+ func MinInt64(a, b int64) int64

+ 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

+ 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) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error)

+ func (b *ADLv1) DeleteBlobs(param *DeleteBlobsInput) (ret *DeleteBlobsOutput, err 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) DeleteBlob(param *DeleteBlobInput) (*DeleteBlobOutput, error)

+ func (b *ADLv2) DeleteBlobs(param *DeleteBlobsInput) (ret *DeleteBlobsOutput, err 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) 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 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 DeleteBlobInput struct

+ Key string

+ type DeleteBlobOutput struct

+ RequestId string

+ type DeleteBlobsInput struct

+ Items []string

+ type DeleteBlobsOutput struct

+ RequestId string

+ type GCS3 struct

+ func NewGCS3(bucket string, flags *FlagStorage, config *S3Config) (*GCS3, error)

+ 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

+ func (fs *Goofys) Mount(mount *Mount)

+ func (fs *Goofys) MountAll(mounts []*Mount)

+ func (fs *Goofys) Unmount(mountPoint string)

+ type HeadBlobInput struct

+ Key string

+ type HeadBlobOutput struct

+ ContentType *string

+ IsDirBlob bool

+ Metadata map[string]*string

+ RequestId string

type Inode

+ func (inode *Inode) ResetForUnmount()

+ func (inode *Inode) SetFromBlobItem(item *BlobItemOutput)

+ type ListBlobsInput struct

+ ContinuationToken *string

+ Delimiter *string

+ MaxKeys *uint32

+ Prefix *string

+ StartAfter *string

+ type ListBlobsOutput struct

+ ContinuationToken *string

+ IsTruncated bool

+ Items []BlobItemOutput

+ NextContinuationToken *string

+ Prefixes []BlobPrefixOutput

+ RequestId string

type MBuf

+ func (mb *MBuf) Close() error

+ 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

+ RequestId 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

+ RequestId string

+ StorageClass *string

+ type ReadSeekerCloser struct

+ func (r *ReadSeekerCloser) Close() error

+ type RemoveBucketInput struct

+ type RemoveBucketOutput struct

+ RequestId string

+ type RenameBlobInput struct

+ Destination string

+ Source string

+ type RenameBlobOutput struct

+ RequestId string

type S3Backend

+ 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) 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) 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 StorageBackend interface

+ Bucket func() string

+ Capabilities func() *Capabilities

+ CopyBlob func(param *CopyBlobInput) (*CopyBlobOutput, error)

+ 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) 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)

v0.20.0

Jun 10, 2019

Changes in this version

+ const CGROUP_FOLDER_PREFIX

+ const CGROUP_PATH

+ const MEM_LIMIT_FILE_SUFFIX

+ const MEM_USAGE_FILE_SUFFIX

type FlagStorage

+ HTTPTimeout time.Duration

+ Subdomain bool

type Goofys

+ func (fs *Goofys) GetFullName(id fuseops.InodeID) *string

+ type S3Backend struct

+ func (s *S3Backend) ListObjectsV2(params *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)

v0.19.0

Jan 9, 2018

Changes in this version

type MBuf

+ func (mb *MBuf) Len() (length int)

v0.0.18

Oct 25, 2017

Changes in this version

+ func TryUnmount(mountPoint string) (err error)

type Goofys

+ func (fs *Goofys) SigUsr1()

v0.0.17

Sep 5, 2017

Changes in this version

+ type DirInodeData struct

+ Children []*Inode

+ DirTime time.Time

type Inode

+ func (inode *Inode) InflateAttributes() (attr fuseops.InodeAttributes)

+ func (inode *Inode) ToDir()

+ func (parent *Inode) LookUpInodeDir(name string, c chan s3.ListObjectsOutput, errc chan error)

+ func (parent *Inode) LookUpInodeMaybeDir(name string, fullName string) (inode *Inode, err error)

+ func (parent *Inode) LookUpInodeNotDir(name string, c chan s3.HeadObjectOutput, errc chan error)

+ type InodeAttributes struct

+ Mtime time.Time

+ Size uint64

v0.0.16

Aug 17, 2017

Changes in this version

type FlagStorage

+ Cache []string

+ MountPoint string

+ MountPointArg string

+ MountPointCreated string

+ func (flags *FlagStorage) Cleanup()

+ type LogHandle struct

+ Lvl *logrus.Level

+ func (l *LogHandle) Format(e *logrus.Entry) ([]byte, error)

+ func (l *LogHandle) Log(args ...interface{})

v0.0.15

Aug 10, 2017

v0.0.14

Aug 8, 2017

Changes in this version

+ func Dup(value []byte) []byte

+ type DirHandleEntry struct

+ Attributes *fuseops.InodeAttributes

+ ETag *string

+ Inode fuseops.InodeID

+ Name *string

+ Offset fuseops.DirOffset

+ StorageClass *string

+ Type fuseutil.DirentType

+ func (entry DirHandleEntry) Init(name *string, t fuseutil.DirentType, attr *fuseops.InodeAttributes) *DirHandleEntry

type FlagStorage

+ ExplicitDir bool

type Goofys

+ 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) RemoveXattr(ctx context.Context, op *fuseops.RemoveXattrOp) (err error)

+ func (fs *Goofys) SetXattr(ctx context.Context, op *fuseops.SetXattrOp) (err error)

type Inode

+ Children []*Inode

+ DirTime time.Time

+ ImplicitDir bool

+ Parent *Inode

+ func (inode *Inode) GetXattr(fs *Goofys, name string) ([]byte, error)

+ func (inode *Inode) ListXattr(fs *Goofys) ([]string, error)

+ func (inode *Inode) RemoveXattr(fs *Goofys, name string) error

+ func (inode *Inode) SetXattr(fs *Goofys, name string, value []byte, flags uint32) error

v0.0.13

Jun 28, 2017

Changes in this version

+ var VersionHash string

v0.0.12

Jun 4, 2017

v0.0.11

May 18, 2017

Changes in this version

+ func MaxUInt32(a, b uint32) uint32

+ func MinUInt32(a, b uint32) uint32

v0.0.10

Feb 16, 2017

Changes in this version

type FlagStorage

+ Cheap bool

type Inode

+ Invalid bool

+ KnownSize *uint64

v0.0.9

Nov 3, 2016

Changes in this version

+ const MAX_READAHEAD

+ const READAHEAD_CHUNK

type FlagStorage

+ ACL string

+ RegionSet bool

type Inode

+ Metadata map[string]*string

v0.0.8

Sep 15, 2016

Changes in this version

+ func RandStringBytesMaskImprSrc(n int) string

type FlagStorage

+ KMSKeyID string

+ UseKMS bool

+ UseSSE bool

v0.0.7

Aug 25, 2016

Changes in this version

type BufferPool

+ func (pool *BufferPool) Free(buf []byte)

+ func (pool *BufferPool) RequestBuffer() (buf []byte)

+ func (pool *BufferPool) RequestMultiple(size uint64, block bool) (buffers [][]byte)

type MBuf

+ func (mb *MBuf) Full() bool

+ func (mb *MBuf) Seek(offset int64, whence int) (int64, error)

+ func (mb *MBuf) Write(p []byte) (n int, err 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

v0.0.6

Jun 1, 2016

Changes in this version

type BufferPool

+ func (pool *BufferPool) MaybeGC()

type FlagStorage

+ UseContentType bool

v0.0.5

Feb 27, 2016

Changes in this version

type BufferPoolHandle

+ func (h *BufferPoolHandle) RequestNonBlock() []byte

v0.0.4

Feb 10, 2016

Changes in this version

+ func MaxInt(a, b int) int

+ func MaxUInt64(a, b uint64) uint64

+ func MinInt(a, b int) int

+ func MinUInt64(a, b uint64) uint64

+ func SignV2(req *request.Request)

+ type Buffer struct

+ func (b *Buffer) Close() (err error)

+ func (b *Buffer) Read(p []byte) (n int, err error)

+ func (b Buffer) Init(buf *MBuf, r ReaderProvider) *Buffer

type BufferPool

+ func (pool BufferPool) Init() *BufferPool

type FileHandle

+ func (fh *FileHandle) Release()

type FlagStorage

+ Profile string

+ Region string

type Inode

+ AttrTime time.Time

+ type MBuf struct

+ func (mb *MBuf) Free()

+ func (mb *MBuf) Read(p []byte) (n int, err error)

+ func (mb *MBuf) WriteFrom(r io.Reader) (n int, err error)

+ func (mb MBuf) Init(h *BufferPoolHandle, size uint64) *MBuf

+ type ReaderProvider func() (io.ReadCloser, error)

+ type S3ReadBuffer struct

+ func (b *S3ReadBuffer) Read(offset int64, p []byte) (n int, err error)

+ func (b S3ReadBuffer) Init(fs *Goofys, fh *FileHandle, offset int64, size int) *S3ReadBuffer

v0.0.3

Nov 19, 2015

Changes in this version

+ func InitLoggers(logToSyslog bool)

+ func MassageMountFlags(args []string) (ret []string)

type FlagStorage

+ Foreground bool

v0.0.2

Oct 30, 2015

Changes in this version

+ const BUF_SIZE

+ const REGION_ERROR_MSG

+ func GetLogger(name string) *logHandle

+ func GetStdLogger(l *logHandle, lvl logrus.Level) *glog.Logger

+ func MyUserAndGroup() (uid uint32, gid uint32, err error)

+ func NewApp() (app *cli.App)

+ func NewLogger(name string) *logHandle

+ type BufferPool struct

+ func NewBufferPool(maxSizeGlobal int64, maxSizePerHandle int64) *BufferPool

+ func (pool *BufferPool) NewPoolHandle() *BufferPoolHandle

+ type BufferPoolHandle struct

+ func (h *BufferPoolHandle) Copy(to *[]byte, from []byte) (nCopied int)

+ func (h *BufferPoolHandle) Free(buf []byte)

+ func (h *BufferPoolHandle) Request() []byte

+ type DirHandle struct

+ BaseOffset int

+ Entries []fuseutil.Dirent

+ Marker *string

+ NameToEntry map[string]fuseops.InodeAttributes

+ func NewDirHandle(inode *Inode) (dh *DirHandle)

+ func (dh *DirHandle) CloseDir() error

+ func (dh *DirHandle) ReadDir(fs *Goofys, offset fuseops.DirOffset) (*fuseutil.Dirent, error)

+ type FileHandle struct

+ func NewFileHandle(in *Inode) *FileHandle

+ func (fh *FileHandle) FlushFile(fs *Goofys) (err error)

+ func (fh *FileHandle) ReadFile(fs *Goofys, offset int64, buf []byte) (bytesRead int, err error)

+ func (fh *FileHandle) WriteFile(fs *Goofys, offset int64, data []byte) (err error)

+ type FlagStorage struct

+ DebugFuse bool

+ DebugS3 bool

+ DirMode os.FileMode

+ Endpoint string

+ FileMode os.FileMode

+ Gid uint32

+ MountOptions map[string]string

+ StatCacheTTL time.Duration

+ StorageClass string

+ TypeCacheTTL time.Duration

+ Uid uint32

+ UsePathRequest bool

+ func PopulateFlags(c *cli.Context) (flags *FlagStorage)

+ type Goofys struct

+ func NewGoofys(bucket string, awsConfig *aws.Config, 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) LookUpInode(ctx context.Context, op *fuseops.LookUpInodeOp) (err error)

+ func (fs *Goofys) LookUpInodeDir(name string, c chan s3.ListObjectsOutput, errc chan error)

+ func (fs *Goofys) LookUpInodeMaybeDir(name string, fullName string) (inode *Inode, err error)

+ func (fs *Goofys) LookUpInodeNotDir(name string, c chan s3.HeadObjectOutput, errc chan error)

+ func (fs *Goofys) MkDir(ctx context.Context, op *fuseops.MkDirOp) (err error)

+ 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) 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) 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) WriteFile(ctx context.Context, op *fuseops.WriteFileOp) (err error)

+ type Inode struct

+ Attributes *fuseops.InodeAttributes

+ FullName *string

+ Id fuseops.InodeID

+ Name *string

+ func NewInode(name *string, fullName *string, flags *FlagStorage) (inode *Inode)

+ func (inode *Inode) DeRef(n uint64) (stale bool)

+ func (inode *Inode) GetAttributes(fs *Goofys) (*fuseops.InodeAttributes, error)

+ func (inode *Inode) OpenDir() (dh *DirHandle)

+ func (inode *Inode) OpenFile(fs *Goofys) *FileHandle

+ func (inode *Inode) Ref()

+ func (parent *Inode) Create(fs *Goofys, name string) (inode *Inode, fh *FileHandle)

+ func (parent *Inode) LookUp(fs *Goofys, name string) (inode *Inode, err error)

+ func (parent *Inode) MkDir(fs *Goofys, name string) (inode *Inode, err error)

+ func (parent *Inode) Rename(fs *Goofys, from string, newParent *Inode, to string) (err error)

+ func (parent *Inode) RmDir(fs *Goofys, name string) (err error)

+ func (parent *Inode) Unlink(fs *Goofys, name string) (err error)

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