fuse

Documentation

Index

• func Server(mountpoint string, opt fuse.MountOptions) (*fuse.Server, error)
• type PFS
  • func NewPaddleFlowFileSystem(debug bool) *PFS
  • func (fs *PFS) Access(cancel <-chan struct{}, input *fuse.AccessIn) fuse.Status
  • func (fs *PFS) CopyFileRange(cancel <-chan struct{}, input *fuse.CopyFileRangeIn) (written uint32, code fuse.Status)
  • func (fs *PFS) Create(cancel <-chan struct{}, input *fuse.CreateIn, name string, out *fuse.CreateOut) fuse.Status
  • func (fs *PFS) Fallocate(cancel <-chan struct{}, input *fuse.FallocateIn) fuse.Status
  • func (fs *PFS) Flush(cancel <-chan struct{}, input *fuse.FlushIn) fuse.Status
  • func (fs *PFS) Fsync(cancel <-chan struct{}, input *fuse.FsyncIn) fuse.Status
  • func (fs *PFS) GetAttr(cancel <-chan struct{}, input *fuse.GetAttrIn, out *fuse.AttrOut) fuse.Status
  • func (fs *PFS) GetLk(cancel <-chan struct{}, input *fuse.LkIn, out *fuse.LkOut) (code fuse.Status)
  • func (fs *PFS) GetXAttr(cancel <-chan struct{}, header *fuse.InHeader, attr string, dest []byte) (uint32, fuse.Status)
  • func (fs *PFS) Link(cancel <-chan struct{}, input *fuse.LinkIn, filename string, ...) fuse.Status
  • func (fs *PFS) ListXAttr(cancel <-chan struct{}, header *fuse.InHeader, dest []byte) (uint32, fuse.Status)
  • func (fs *PFS) Lookup(cancel <-chan struct{}, header *fuse.InHeader, name string, out *fuse.EntryOut) fuse.Status
  • func (fs *PFS) Mkdir(cancel <-chan struct{}, input *fuse.MkdirIn, name string, out *fuse.EntryOut) fuse.Status
  • func (fs *PFS) Mknod(cancel <-chan struct{}, input *fuse.MknodIn, name string, out *fuse.EntryOut) fuse.Status
  • func (fs *PFS) Open(cancel <-chan struct{}, input *fuse.OpenIn, out *fuse.OpenOut) fuse.Status
  • func (fs *PFS) OpenDir(cancel <-chan struct{}, input *fuse.OpenIn, out *fuse.OpenOut) fuse.Status
  • func (fs *PFS) Read(cancel <-chan struct{}, input *fuse.ReadIn, buf []byte) (fuse.ReadResult, fuse.Status)
  • func (fs *PFS) ReadDir(cancel <-chan struct{}, input *fuse.ReadIn, out *fuse.DirEntryList) fuse.Status
  • func (fs *PFS) ReadDirPlus(cancel <-chan struct{}, input *fuse.ReadIn, out *fuse.DirEntryList) fuse.Status
  • func (fs *PFS) Readlink(cancel <-chan struct{}, header *fuse.InHeader) (out []byte, code fuse.Status)
  • func (fs *PFS) Release(cancel <-chan struct{}, input *fuse.ReleaseIn)
  • func (fs *PFS) ReleaseDir(input *fuse.ReleaseIn)
  • func (fs *PFS) RemoveXAttr(cancel <-chan struct{}, header *fuse.InHeader, attr string) fuse.Status
  • func (fs *PFS) Rename(cancel <-chan struct{}, input *fuse.RenameIn, oldName string, newName string) fuse.Status
  • func (fs *PFS) Rmdir(cancel <-chan struct{}, header *fuse.InHeader, name string) fuse.Status
  • func (fs *PFS) SetAttr(cancel <-chan struct{}, input *fuse.SetAttrIn, out *fuse.AttrOut) fuse.Status
  • func (fs *PFS) SetDebug(debug bool)
  • func (fs *PFS) SetLk(cancel <-chan struct{}, input *fuse.LkIn) (code fuse.Status)
  • func (fs *PFS) SetLkw(cancel <-chan struct{}, input *fuse.LkIn) (code fuse.Status)
  • func (fs *PFS) SetXAttr(cancel <-chan struct{}, input *fuse.SetXAttrIn, attr string, data []byte) fuse.Status
  • func (fs *PFS) StatFs(cancel <-chan struct{}, input *fuse.InHeader, out *fuse.StatfsOut) fuse.Status
  • func (fs *PFS) String() string
  • func (fs *PFS) Symlink(cancel <-chan struct{}, header *fuse.InHeader, pointedTo string, ...) fuse.Status
  • func (fs *PFS) Unlink(cancel <-chan struct{}, header *fuse.InHeader, name string) fuse.Status
  • func (fs *PFS) Write(cancel <-chan struct{}, input *fuse.WriteIn, data []byte) (uint32, fuse.Status)

Functions

func Server

func Server(mountpoint string, opt fuse.MountOptions) (*fuse.Server, error)

Types

type PFS

type PFS struct {
	fuse.RawFileSystem
	// contains filtered or unexported fields
}

func NewPaddleFlowFileSystem

func NewPaddleFlowFileSystem(debug bool) *PFS

func (*PFS) Access

func (fs *PFS) Access(cancel <-chan struct{}, input *fuse.AccessIn) fuse.Status

func (*PFS) CopyFileRange

func (fs *PFS) CopyFileRange(cancel <-chan struct{}, input *fuse.CopyFileRangeIn) (written uint32, code fuse.Status)

func (*PFS) Create

func (fs *PFS) Create(cancel <-chan struct{}, input *fuse.CreateIn, name string, out *fuse.CreateOut) fuse.Status

File handling.

func (*PFS) Fallocate

func (fs *PFS) Fallocate(cancel <-chan struct{}, input *fuse.FallocateIn) fuse.Status

func (*PFS) Flush

func (fs *PFS) Flush(cancel <-chan struct{}, input *fuse.FlushIn) fuse.Status

func (*PFS) Fsync

func (fs *PFS) Fsync(cancel <-chan struct{}, input *fuse.FsyncIn) fuse.Status

func (*PFS) GetAttr

func (fs *PFS) GetAttr(cancel <-chan struct{}, input *fuse.GetAttrIn, out *fuse.AttrOut) fuse.Status

Attributes.

func (*PFS) GetLk

func (fs *PFS) GetLk(cancel <-chan struct{}, input *fuse.LkIn, out *fuse.LkOut) (code fuse.Status)

File locking

func (*PFS) GetXAttr

func (fs *PFS) GetXAttr(cancel <-chan struct{}, header *fuse.InHeader, attr string, dest []byte) (uint32, fuse.Status)

GetXAttr reads an extended attribute, and should return the number of bytes. If the buffer is too small, return ERANGE, with the required buffer size.

func (*PFS) Link

func (fs *PFS) Link(cancel <-chan struct{}, input *fuse.LinkIn, filename string, out *fuse.EntryOut) fuse.Status

func (*PFS) ListXAttr

func (fs *PFS) ListXAttr(cancel <-chan struct{}, header *fuse.InHeader, dest []byte) (uint32, fuse.Status)

ListXAttr lists extended attributes as '\0' delimited byte slice, and return the number of bytes. If the buffer is too small, return ERANGE, with the required buffer size.

func (*PFS) Lookup

func (fs *PFS) Lookup(cancel <-chan struct{}, header *fuse.InHeader, name string, out *fuse.EntryOut) fuse.Status

Lookup is called by the kernel when the VFS wants to know about a file inside a directory. Many lookup calls can occur in parallel, but only one call happens for each (dir, name) pair.

func (*PFS) Mkdir

func (fs *PFS) Mkdir(cancel <-chan struct{}, input *fuse.MkdirIn, name string, out *fuse.EntryOut) fuse.Status

func (*PFS) Mknod

func (fs *PFS) Mknod(cancel <-chan struct{}, input *fuse.MknodIn, name string, out *fuse.EntryOut) fuse.Status

Modifying structure.

func (*PFS) Open

func (fs *PFS) Open(cancel <-chan struct{}, input *fuse.OpenIn, out *fuse.OpenOut) fuse.Status

func (*PFS) OpenDir

func (fs *PFS) OpenDir(cancel <-chan struct{}, input *fuse.OpenIn, out *fuse.OpenOut) fuse.Status

Directory handling

func (*PFS) Read

func (fs *PFS) Read(cancel <-chan struct{}, input *fuse.ReadIn, buf []byte) (fuse.ReadResult, fuse.Status)

func (*PFS) ReadDir

func (fs *PFS) ReadDir(cancel <-chan struct{}, input *fuse.ReadIn, out *fuse.DirEntryList) fuse.Status

func (*PFS) ReadDirPlus

func (fs *PFS) ReadDirPlus(cancel <-chan struct{}, input *fuse.ReadIn, out *fuse.DirEntryList) fuse.Status

func (*PFS) Readlink

func (fs *PFS) Readlink(cancel <-chan struct{}, header *fuse.InHeader) (out []byte, code fuse.Status)

func (*PFS) Release

func (fs *PFS) Release(cancel <-chan struct{}, input *fuse.ReleaseIn)

func (*PFS) ReleaseDir

func (fs *PFS) ReleaseDir(input *fuse.ReleaseIn)

func (*PFS) RemoveXAttr

func (fs *PFS) RemoveXAttr(cancel <-chan struct{}, header *fuse.InHeader, attr string) fuse.Status

RemoveXAttr removes an extended attribute.

func (*PFS) Rename

func (fs *PFS) Rename(cancel <-chan struct{}, input *fuse.RenameIn, oldName string, newName string) fuse.Status

func (*PFS) Rmdir

func (fs *PFS) Rmdir(cancel <-chan struct{}, header *fuse.InHeader, name string) fuse.Status

func (*PFS) SetAttr

func (fs *PFS) SetAttr(cancel <-chan struct{}, input *fuse.SetAttrIn, out *fuse.AttrOut) fuse.Status

func (*PFS) SetDebug

func (fs *PFS) SetDebug(debug bool)

If called, provide debug output through the log package.

func (*PFS) SetLk

func (fs *PFS) SetLk(cancel <-chan struct{}, input *fuse.LkIn) (code fuse.Status)

func (*PFS) SetLkw

func (fs *PFS) SetLkw(cancel <-chan struct{}, input *fuse.LkIn) (code fuse.Status)

func (*PFS) SetXAttr

func (fs *PFS) SetXAttr(cancel <-chan struct{}, input *fuse.SetXAttrIn, attr string, data []byte) fuse.Status

SetAttr writes an extended attribute.

func (*PFS) StatFs

func (fs *PFS) StatFs(cancel <-chan struct{}, input *fuse.InHeader, out *fuse.StatfsOut) fuse.Status

func (*PFS) String

func (fs *PFS) String() string

func (*PFS) Symlink

func (fs *PFS) Symlink(cancel <-chan struct{}, header *fuse.InHeader, pointedTo string, linkName string, out *fuse.EntryOut) fuse.Status

func (*PFS) Unlink

func (fs *PFS) Unlink(cancel <-chan struct{}, header *fuse.InHeader, name string) fuse.Status

func (*PFS) Write

func (fs *PFS) Write(cancel <-chan struct{}, input *fuse.WriteIn, data []byte) (uint32, fuse.Status)