fuse

Documentation

Index

• Constants
• func NewInode() uint64
• type MountInfo
  • func NewMountInfo(mhash, mpoint string, sapi *api.API) *MountInfo
• type SwarmDir
  • func NewSwarmDir(fullpath string, minfo *MountInfo) *SwarmDir
  • func (sd *SwarmDir) Attr(ctx context.Context, a *fuse.Attr) error
  • func (sd *SwarmDir) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)
  • func (sd *SwarmDir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.LookupResponse) (fs.Node, error)
  • func (sd *SwarmDir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error)
  • func (sd *SwarmDir) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)
  • func (sd *SwarmDir) Remove(ctx context.Context, req *fuse.RemoveRequest) error
• type SwarmFS
  • func NewSwarmFS(api *api.API) *SwarmFS
  • func (swarmfs *SwarmFS) Listmounts() []*MountInfo
  • func (swarmfs *SwarmFS) Mount(mhash, mountpoint string) (*MountInfo, error)
  • func (swarmfs *SwarmFS) Stop() bool
  • func (swarmfs *SwarmFS) Unmount(mountpoint string) (*MountInfo, error)
• type SwarmFile
  • func NewSwarmFile(path, fname string, minfo *MountInfo) *SwarmFile
  • func (sf *SwarmFile) Attr(ctx context.Context, a *fuse.Attr) error
  • func (sf *SwarmFile) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error
  • func (sf *SwarmFile) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error
• type SwarmRoot
  • func (filesystem *SwarmRoot) Root() (fs.Node, error)

Constants

const (
	MaxAppendFileSize = 10485760 //10MB
)

const (
	Swarmfs_Version = "0.1"
)

Functions

func NewInode

func NewInode() uint64

inode编号必须是唯一的，它们用于在fuse中缓存

Types

type MountInfo

type MountInfo struct {
	MountPoint     string
	StartManifest  string
	LatestManifest string
	// contains filtered or unexported fields
}

mountinfo包含有关每个活动装载的信息

func NewMountInfo

func NewMountInfo(mhash, mpoint string, sapi *api.API) *MountInfo

type SwarmDir

type SwarmDir struct {
	// contains filtered or unexported fields
}

func NewSwarmDir

func NewSwarmDir(fullpath string, minfo *MountInfo) *SwarmDir

func (*SwarmDir) Attr

func (sd *SwarmDir) Attr(ctx context.Context, a *fuse.Attr) error

func (*SwarmDir) Create

func (sd *SwarmDir) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)

func (*SwarmDir) Lookup

func (sd *SwarmDir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.LookupResponse) (fs.Node, error)

func (*SwarmDir) Mkdir

func (sd *SwarmDir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error)

func (*SwarmDir) ReadDirAll

func (sd *SwarmDir) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)

func (*SwarmDir) Remove

func (sd *SwarmDir) Remove(ctx context.Context, req *fuse.RemoveRequest) error

type SwarmFS

type SwarmFS struct {
	// contains filtered or unexported fields
}

func NewSwarmFS

func NewSwarmFS(api *api.API) *SwarmFS

func (*SwarmFS) Listmounts

func (swarmfs *SwarmFS) Listmounts() []*MountInfo

func (*SwarmFS) Mount

func (swarmfs *SwarmFS) Mount(mhash, mountpoint string) (*MountInfo, error)

func (*SwarmFS) Stop

func (swarmfs *SwarmFS) Stop() bool

func (*SwarmFS) Unmount

func (swarmfs *SwarmFS) Unmount(mountpoint string) (*MountInfo, error)

type SwarmFile

type SwarmFile struct {
	// contains filtered or unexported fields
}

func NewSwarmFile

func NewSwarmFile(path, fname string, minfo *MountInfo) *SwarmFile

func (*SwarmFile) Attr

func (sf *SwarmFile) Attr(ctx context.Context, a *fuse.Attr) error

func (*SwarmFile) Read

func (sf *SwarmFile) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error

func (*SwarmFile) Write

func (sf *SwarmFile) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error

type SwarmRoot

type SwarmRoot struct {
	// contains filtered or unexported fields
}

func (*SwarmRoot) Root

func (filesystem *SwarmRoot) Root() (fs.Node, error)