internal

Jan 9, 2018

Changes in this version

type MBuf

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

Oct 25, 2017

Changes in this version

+ func TryUnmount(mountPoint string) (err error)

type Goofys

+ func (fs *Goofys) SigUsr1()

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

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{})

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

Jun 28, 2017

Changes in this version

+ var VersionHash string

May 18, 2017

Changes in this version

+ func MaxUInt32(a, b uint32) uint32

+ func MinUInt32(a, b uint32) uint32

Feb 16, 2017

Changes in this version

type FlagStorage

+ Cheap bool

type Inode

+ Invalid bool

+ KnownSize *uint64

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

Sep 15, 2016

Changes in this version

+ func RandStringBytesMaskImprSrc(n int) string

type FlagStorage

+ KMSKeyID string

+ UseKMS bool

+ UseSSE bool

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

Jun 1, 2016

Changes in this version

type BufferPool

+ func (pool *BufferPool) MaybeGC()

type FlagStorage

+ UseContentType bool

Feb 27, 2016

Changes in this version

type BufferPoolHandle

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

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

Nov 19, 2015

Changes in this version

+ func InitLoggers(logToSyslog bool)

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

type FlagStorage

+ Foreground bool

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)