stofuse

package

v0.0.0-...-ea0be71 Latest Latest Go to latest Published: Apr 10, 2023 License: Apache-2.0 Imports: 39 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/function61/varasto

Links

Open Source Insights

Documentation ¶

Rendered for

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
stofuseclient Client for FUSE server's API	Client for FUSE server's API
stofuseentrypoint This entrypoint is in own package, so we don't need to sprinkle conditional compilation all around the base "stofuse" package because it doesn't compile on Windows	This entrypoint is in own package, so we don't need to sprinkle conditional compilation all around the base "stofuse" package because it doesn't compile on Windows

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL