Documentation ¶
Index ¶
- Constants
- func Dup(value []byte) []byte
- func MaxInt(a, b int) int
- func MaxUInt32(a, b uint32) uint32
- func MaxUInt64(a, b uint64) uint64
- func MinInt(a, b int) int
- func MinUInt32(a, b uint32) uint32
- func MinUInt64(a, b uint64) uint64
- func TryUnmount(mountPoint string) (err error)
- type Buffer
- type BufferPool
- type DirHandle
- type DirHandleEntry
- type DirInodeData
- type FileHandle
- type Fusera
- func (fs *Fusera) GetInodeAttributes(ctx context.Context, op *fuseops.GetInodeAttributesOp) (err error)
- func (fs *Fusera) GetXattr(ctx context.Context, op *fuseops.GetXattrOp) (err error)
- func (fs *Fusera) ListXattr(ctx context.Context, op *fuseops.ListXattrOp) (err error)
- func (fs *Fusera) LookUpInode(ctx context.Context, op *fuseops.LookUpInodeOp) (err error)
- func (fs *Fusera) OpenDir(ctx context.Context, op *fuseops.OpenDirOp) (err error)
- func (fs *Fusera) OpenFile(ctx context.Context, op *fuseops.OpenFileOp) (err error)
- func (fs *Fusera) ReadDir(ctx context.Context, op *fuseops.ReadDirOp) (err error)
- func (fs *Fusera) ReadFile(ctx context.Context, op *fuseops.ReadFileOp) (err error)
- func (fs *Fusera) ReleaseDirHandle(ctx context.Context, op *fuseops.ReleaseDirHandleOp) (err error)
- func (fs *Fusera) ReleaseFileHandle(ctx context.Context, op *fuseops.ReleaseFileHandleOp) (err error)
- func (fs *Fusera) SigUsr1()
- func (fs *Fusera) StatFS(ctx context.Context, op *fuseops.StatFSOp) (err error)
- func (fs *Fusera) SyncFile(ctx context.Context, op *fuseops.SyncFileOp) (err error)
- type 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() (fh *FileHandle, err error)
- func (inode *Inode) Ref()
- func (inode *Inode) ToDir()
- type InodeAttributes
- type MBuf
- func (mb *MBuf) Free()
- func (mb *MBuf) Full() bool
- func (mb MBuf) Init(h *BufferPool, size uint64, block bool) *MBuf
- func (mb *MBuf) Read(p []byte) (n int, err error)
- 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)
- type Options
- type ReaderProvider
- type S3ReadBuffer
Constants ¶
View Source
const BUF_SIZE = 5 * 1024 * 1024
View Source
const MAX_READAHEAD = uint32(100 * 1024 * 1024)
View Source
const READAHEAD_CHUNK = uint32(20 * 1024 * 1024)
Variables ¶
This section is empty.
Functions ¶
func TryUnmount ¶
Types ¶
type BufferPool ¶
type BufferPool struct {
// contains filtered or unexported fields
}
func (*BufferPool) Free ¶
func (pool *BufferPool) Free(buf []byte)
func (BufferPool) Init ¶
func (pool BufferPool) Init() *BufferPool
func (*BufferPool) MaybeGC ¶
func (pool *BufferPool) MaybeGC()
func (*BufferPool) RequestBuffer ¶
func (pool *BufferPool) RequestBuffer() (buf []byte)
func (*BufferPool) RequestMultiple ¶
func (pool *BufferPool) RequestMultiple(size uint64, block bool) (buffers [][]byte)
type DirHandle ¶
type DirHandle struct { Entries []*DirHandleEntry Marker *string BaseOffset int // contains filtered or unexported fields }
func NewDirHandle ¶
type DirHandleEntry ¶
type DirHandleEntry struct { Name *string Inode fuseops.InodeID Type fuseutil.DirentType Offset fuseops.DirOffset Attributes *InodeAttributes ETag *string StorageClass *string }
type DirInodeData ¶
type FileHandle ¶
type FileHandle struct {
// contains filtered or unexported fields
}
func NewFileHandle ¶
func NewFileHandle(in *Inode) *FileHandle
func (*FileHandle) ReadFile ¶
func (fh *FileHandle) ReadFile(offset int64, buf []byte) (bytesRead int, err error)
func (*FileHandle) Release ¶
func (fh *FileHandle) Release()
type Fusera ¶
type Fusera struct { fuseutil.NotImplementedFileSystem // contains filtered or unexported fields }
func (*Fusera) GetInodeAttributes ¶
func (*Fusera) LookUpInode ¶
func (*Fusera) ReleaseDirHandle ¶
func (*Fusera) ReleaseFileHandle ¶
type Inode ¶
type Inode struct { Id fuseops.InodeID Name *string Link string Acc string ErrContents string Attributes InodeAttributes KnownSize *uint64 AttrTime time.Time Parent *Inode Invalid bool ImplicitDir bool // contains filtered or unexported fields }
func (*Inode) GetAttributes ¶
func (inode *Inode) GetAttributes() (*fuseops.InodeAttributes, error)
func (*Inode) InflateAttributes ¶
func (inode *Inode) InflateAttributes() (attr fuseops.InodeAttributes)
func (*Inode) OpenFile ¶
func (inode *Inode) OpenFile() (fh *FileHandle, err error)
type InodeAttributes ¶
type MBuf ¶
type MBuf struct {
// contains filtered or unexported fields
}
type Options ¶
type Options struct { Ngc []byte Acc map[string]bool Loc string ApiEndpoint string AwsBatch int GcpBatch int // SRR# has a map of file names that map to urls where the data is Urls map[string]map[string]string // File system MountOptions map[string]string MountPoint string MountPointArg string MountPointCreated string Cache []string DirMode os.FileMode FileMode os.FileMode Uid uint32 Gid uint32 // Tuning StatCacheTTL time.Duration TypeCacheTTL time.Duration // // Debugging Debug bool }
type ReaderProvider ¶
type ReaderProvider func() (io.ReadCloser, error)
type S3ReadBuffer ¶
type S3ReadBuffer struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.