mfs

Documentation

Overview

package mfs implements an in memory model of a mutable ipfs filesystem.

It consists of four main structs:

1. The Filesystem The filesystem serves as a container and entry point for various mfs filesystems
2. Root Root represents an individual filesystem mounted within the mfs system as a whole
3. Directories
4. Files

Index

• Variables
• func Mkdir(r *Root, pth string, mkparents bool, flush bool) error
• func Mv(r *Root, src, dst string) error
• func PutNode(r *Root, path string, nd *dag.Node) error
• type Directory
  • func NewDirectory(ctx context.Context, name string, node *dag.Node, parent childCloser, ...) *Directory
  • func (d *Directory) AddChild(name string, nd *dag.Node) error
  • func (d *Directory) Child(name string) (FSNode, error)
  • func (d *Directory) Flush() error
  • func (d *Directory) GetNode() (*dag.Node, error)
  • func (d *Directory) List() ([]NodeListing, error)
  • func (d *Directory) Lock()
  • func (d *Directory) Mkdir(name string) (*Directory, error)
  • func (d *Directory) Path() string
  • func (d *Directory) Type() NodeType
  • func (d *Directory) Unlink(name string) error
  • func (d *Directory) Unlock()
• type FSNode
  • func DirLookup(d *Directory, pth string) (FSNode, error)
  • func Lookup(r *Root, path string) (FSNode, error)
• type File
  • func NewFile(name string, node *dag.Node, parent childCloser, dserv dag.DAGService) (*File, error)
  • func (fi *File) Close() error
  • func (fi *File) CtxReadFull(ctx context.Context, b []byte) (int, error)
  • func (fi *File) GetNode() (*dag.Node, error)
  • func (fi *File) Lock()
  • func (fi *File) Read(b []byte) (int, error)
  • func (fi *File) Seek(offset int64, whence int) (int64, error)
  • func (fi *File) Size() (int64, error)
  • func (fi *File) Sync() error
  • func (fi *File) Truncate(size int64) error
  • func (fi *File) Type() NodeType
  • func (fi *File) Unlock()
  • func (fi *File) Write(b []byte) (int, error)
  • func (fi *File) WriteAt(b []byte, at int64) (int, error)
• type NodeListing
• type NodeType
• type PubFunc
• type Republisher
  • func NewRepublisher(ctx context.Context, pf PubFunc, tshort, tlong time.Duration) *Republisher
  • func (p *Republisher) Close() error
  • func (np *Republisher) Run()
  • func (np *Republisher) Update(k key.Key)
• type Root
  • func NewRoot(parent context.Context, ds dag.DAGService, node *dag.Node, pf PubFunc) (*Root, error)
  • func (kr *Root) Close() error
  • func (kr *Root) Flush() error
  • func (kr *Root) GetValue() FSNode

Variables

var ErrDirExists = errors.New("directory already has entry by that name")

var ErrInvalidChild = errors.New("invalid child node")

var ErrIsDirectory = errors.New("error: is a directory")

var ErrNotExist = errors.New("no such rootfs")

var ErrNotYetImplemented = errors.New("not yet implemented")

Functions

func Mkdir

func Mkdir(r *Root, pth string, mkparents bool, flush bool) error

Mkdir creates a directory at 'path' under the directory 'd', creating intermediary directories as needed if 'mkparents' is set to true

func Mv

func Mv(r *Root, src, dst string) error

Mv moves the file or directory at 'src' to 'dst'

func PutNode

func PutNode(r *Root, path string, nd *dag.Node) error

PutNode inserts 'nd' at 'path' in the given mfs

Types

type Directory

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

func NewDirectory

func NewDirectory(ctx context.Context, name string, node *dag.Node, parent childCloser, dserv dag.DAGService) *Directory

func (*Directory) AddChild

func (d *Directory) AddChild(name string, nd *dag.Node) error

AddChild adds the node 'nd' under this directory giving it the name 'name'

func (*Directory) Child

func (d *Directory) Child(name string) (FSNode, error)

Child returns the child of this directory by the given name

func (*Directory) Flush

func (d *Directory) Flush() error

func (*Directory) GetNode

func (d *Directory) GetNode() (*dag.Node, error)

func (*Directory) List

func (d *Directory) List() ([]NodeListing, error)

func (*Directory) Lock

func (d *Directory) Lock()

func (*Directory) Mkdir

func (d *Directory) Mkdir(name string) (*Directory, error)

func (*Directory) Path

func (d *Directory) Path() string

func (*Directory) Type

func (d *Directory) Type() NodeType

func (*Directory) Unlink

func (d *Directory) Unlink(name string) error

func (*Directory) Unlock

func (d *Directory) Unlock()

type FSNode

type FSNode interface {
	GetNode() (*dag.Node, error)
	Type() NodeType
	Lock()
	Unlock()
}

FSNode represents any node (directory, root, or file) in the mfs filesystem

func DirLookup

func DirLookup(d *Directory, pth string) (FSNode, error)

DirLookup will look up a file or directory at the given path under the directory 'd'

func Lookup

func Lookup(r *Root, path string) (FSNode, error)

type File

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

func NewFile

func NewFile(name string, node *dag.Node, parent childCloser, dserv dag.DAGService) (*File, error)

NewFile returns a NewFile object with the given parameters

func (*File) Close

func (fi *File) Close() error

Close flushes, then propogates the modified dag node up the directory structure and signals a republish to occur

func (*File) CtxReadFull

func (fi *File) CtxReadFull(ctx context.Context, b []byte) (int, error)

Read reads into the given buffer from the current offset

func (*File) GetNode

func (fi *File) GetNode() (*dag.Node, error)

GetNode returns the dag node associated with this file

func (*File) Lock

func (fi *File) Lock()

Lock the file

func (*File) Read

func (fi *File) Read(b []byte) (int, error)

Read reads into the given buffer from the current offset

func (*File) Seek

func (fi *File) Seek(offset int64, whence int) (int64, error)

Seek implements io.Seeker

func (*File) Size

func (fi *File) Size() (int64, error)

Size returns the size of this file

func (*File) Sync

func (fi *File) Sync() error

Sync flushes the changes in the file to disk

func (*File) Truncate

func (fi *File) Truncate(size int64) error

Truncate truncates the file to size

func (*File) Type

func (fi *File) Type() NodeType

Type returns the type FSNode this is

func (*File) Unlock

func (fi *File) Unlock()

Unlock the file

func (*File) Write

func (fi *File) Write(b []byte) (int, error)

Write writes the given data to the file at its current offset

func (*File) WriteAt

func (fi *File) WriteAt(b []byte, at int64) (int, error)

Write At writes the given bytes at the offset 'at'

type NodeListing

type NodeListing struct {
	Name string
	Type int
	Size int64
	Hash string
}

type NodeType

type NodeType int

const (
	TFile NodeType = iota
	TDir
)

type PubFunc

type PubFunc func(context.Context, key.Key) error

type Republisher

type Republisher struct {
	TimeoutLong  time.Duration
	TimeoutShort time.Duration
	Publish      chan struct{}
	// contains filtered or unexported fields
}

Republisher manages when to publish a given entry

func NewRepublisher

func NewRepublisher(ctx context.Context, pf PubFunc, tshort, tlong time.Duration) *Republisher

NewRepublisher creates a new Republisher object to republish the given root using the given short and long time intervals

func (*Republisher) Close

func (p *Republisher) Close() error

func (*Republisher) Run

func (np *Republisher) Run()

Run is the main republisher loop

func (*Republisher) Update

func (np *Republisher) Update(k key.Key)

Touch signals that an update has occurred since the last publish. Multiple consecutive touches may extend the time period before the next Publish occurs in order to more efficiently batch updates

type Root

type Root struct {
	Type string
	// contains filtered or unexported fields
}

Root represents the root of a filesystem tree

func NewRoot

func NewRoot(parent context.Context, ds dag.DAGService, node *dag.Node, pf PubFunc) (*Root, error)

newRoot creates a new Root and starts up a republisher routine for it

func (*Root) Close

func (kr *Root) Close() error

func (*Root) Flush

func (kr *Root) Flush() error

func (*Root) GetValue

func (kr *Root) GetValue() FSNode