fs

Documentation

Index

• type Volume
  • func Open(db *db.DB, chunkStore chunks.Store, volumeID *db.VolumeID, ...) (*Volume, error)
  • func (*Volume) GenerateInode(parent uint64, name string) uint64
  • func (v *Volume) Root() (fs.Node, error)
  • func (v *Volume) SetFUSE(srv *fs.Server)
  • func (v *Volume) Snapshot(ctx context.Context, tx *db.Tx) (*wiresnap.Snapshot, error)
  • func (v *Volume) SyncReceive(ctx context.Context, dirPath string, peers map[uint32][]byte, ...) error
  • func (v *Volume) SyncSend(ctx context.Context, dirPath string, ...) error

Types

type Volume

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

func Open

func Open(db *db.DB, chunkStore chunks.Store, volumeID *db.VolumeID, pubKey *peer.PublicKey) (*Volume, error)

Open returns a FUSE filesystem instance serving content from the given volume. The result can be passed to bazil.org/fuse/fs#Serve to start serving file access requests from the kernel.

Caller guarantees volume ID exists at least as long as requests are served for this file system.

func (*Volume) GenerateInode

func (*Volume) GenerateInode(parent uint64, name string) uint64

func (*Volume) Root

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

func (*Volume) SetFUSE

func (v *Volume) SetFUSE(srv *fs.Server)

func (*Volume) Snapshot

func (v *Volume) Snapshot(ctx context.Context, tx *db.Tx) (*wiresnap.Snapshot, error)

Snapshot records a snapshot of the volume. The Snapshot message itself has not been persisted yet.

func (*Volume) SyncReceive

func (v *Volume) SyncReceive(ctx context.Context, dirPath string, peers map[uint32][]byte, dirClockBuf []byte, recv func() ([]*wirepeer.Dirent, error)) error

func (*Volume) SyncSend

func (v *Volume) SyncSend(ctx context.Context, dirPath string, send func(*wirepeer.VolumeSyncPullItem) error) error