stofuse

Documentation

Overview

FUSE adapter for interfacing with Varasto from filesystem

Index

• func Entrypoint() *cobra.Command
• func NewByIdDir(srv *FsServer) *byIdDir
• func NewDirAdapter(dirID string, srv *FsServer) *dirAdapter
• func NewDirByIDQuery(srv *FsServer) *dirByIDQuery
• type BlobCache
  • func NewBlobCache(clientConfig stoclient.ClientConfig, logl *logex.Leveled) *BlobCache
  • func (b *BlobCache) Get(ctx context.Context, ref stotypes.BlobRef, collectionId string) (*BlobData, error)
• type BlobData
• type CollectionDirNode
  • func NewCollectionDirNode(collection *stotypes.Collection, fullPathFromRoot string, inode uint64, ...) *CollectionDirNode
  • func (d *CollectionDirNode) Attr(_ context.Context, a *fuse.Attr) error
  • func (d *CollectionDirNode) Create(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse) (fs.Node, fs.Handle, error)
  • func (d *CollectionDirNode) Lookup(ctx context.Context, name string) (fs.Node, error)
  • func (d *CollectionDirNode) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error)
  • func (d *CollectionDirNode) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)
  • func (d *CollectionDirNode) Remove(ctx context.Context, req *fuse.RemoveRequest) error
  • func (d *CollectionDirNode) Rename(ctx context.Context, req *fuse.RenameRequest, newDir fs.Node) error
• type CollectionDirNodeFile
  • func NewCollectionDirNodeFile(name string, inode uint64, file stotypes.File, collectionId string, ...) *CollectionDirNodeFile
  • func (f CollectionDirNodeFile) Attr(ctx context.Context, attrs *fuse.Attr) error
  • func (f CollectionDirNodeFile) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error
• type FsServer
  • func NewFsServer(client *stoclient.Client, fuseMountPath string, logl *logex.Leveled) *FsServer
  • func (f *FsServer) AbsoluteSymlinkUnderFUSEMount(component0 string, components ...string) string
• type VarastoFSRoot
  • func NewVarastoFSRoot(entries []stoEntry, srv *FsServer) (*VarastoFSRoot, error)
  • func (v *VarastoFSRoot) Attr(ctx context.Context, a *fuse.Attr) error
  • func (v *VarastoFSRoot) Lookup(ctx context.Context, name string) (fs.Node, error)
  • func (v *VarastoFSRoot) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)
  • func (v *VarastoFSRoot) Root() (fs.Node, error)

Functions

func Entrypoint

func Entrypoint() *cobra.Command

func NewByIdDir

func NewByIdDir(srv *FsServer) *byIdDir

func NewDirAdapter

func NewDirAdapter(dirID string, srv *FsServer) *dirAdapter

func NewDirByIDQuery

func NewDirByIDQuery(srv *FsServer) *dirByIDQuery

Types

type BlobCache

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

func NewBlobCache

func NewBlobCache(clientConfig stoclient.ClientConfig, logl *logex.Leveled) *BlobCache

func (*BlobCache) Get

func (b *BlobCache) Get(ctx context.Context, ref stotypes.BlobRef, collectionId string) (*BlobData, error)

type BlobData

type BlobData struct {
	Ref  stotypes.BlobRef
	Data []byte
}

type CollectionDirNode

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

func NewCollectionDirNode

func NewCollectionDirNode(
	collection *stotypes.Collection,
	fullPathFromRoot string,
	inode uint64,
	filesCommitted []*CollectionDirNodeFile,
	subdirsCommitted []*CollectionDirNode,
) *CollectionDirNode

func (*CollectionDirNode) Attr

func (d *CollectionDirNode) Attr(_ context.Context, a *fuse.Attr) error

func (*CollectionDirNode) Create

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

creates a file (mkdir has separate func)

func (*CollectionDirNode) Lookup

func (d *CollectionDirNode) Lookup(ctx context.Context, name string) (fs.Node, error)

func (*CollectionDirNode) Mkdir

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

func (*CollectionDirNode) ReadDirAll

func (d *CollectionDirNode) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)

func (*CollectionDirNode) Remove

func (d *CollectionDirNode) Remove(ctx context.Context, req *fuse.RemoveRequest) error

func (*CollectionDirNode) Rename

func (d *CollectionDirNode) Rename(ctx context.Context, req *fuse.RenameRequest, newDir fs.Node) error

type CollectionDirNodeFile

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

func NewCollectionDirNodeFile

func NewCollectionDirNodeFile(
	name string,
	inode uint64,
	file stotypes.File,
	collectionId string,
	srv *FsServer,
) *CollectionDirNodeFile

func (CollectionDirNodeFile) Attr

func (f CollectionDirNodeFile) Attr(ctx context.Context, attrs *fuse.Attr) error

func (CollectionDirNodeFile) Read

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

type FsServer

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

func NewFsServer

func NewFsServer(client *stoclient.Client, fuseMountPath string, logl *logex.Leveled) *FsServer

func (*FsServer) AbsoluteSymlinkUnderFUSEMount

func (f *FsServer) AbsoluteSymlinkUnderFUSEMount(component0 string, components ...string) string

absolute paths are better because relative ones don't seem to work over multiple symlink levels (or something else level-dependent breaks on them..)

type VarastoFSRoot

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

TODO: make the root return "backup exclude" xattr

func NewVarastoFSRoot

func NewVarastoFSRoot(entries []stoEntry, srv *FsServer) (*VarastoFSRoot, error)

func (*VarastoFSRoot) Attr

func (v *VarastoFSRoot) Attr(ctx context.Context, a *fuse.Attr) error

func (*VarastoFSRoot) Lookup

func (v *VarastoFSRoot) Lookup(ctx context.Context, name string) (fs.Node, error)

func (*VarastoFSRoot) ReadDirAll

func (v *VarastoFSRoot) ReadDirAll(ctx context.Context) ([]fuse.Dirent, error)

func (*VarastoFSRoot) Root

func (v *VarastoFSRoot) Root() (fs.Node, error)

implements fs.FS