internal

package

Go to main page

Versions in this module

v0

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