mfs

Sep 20, 2016

Changes in this version

type Directory

+ func (d *Directory) Uncache(name string)

Apr 7, 2016

Changes in this version

+ const OpenReadOnly

+ const OpenReadWrite

+ const OpenWriteOnly

+ 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")

+ func FlushPath(rt *Root, pth string) error

+ 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 struct

+ 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) ListNames() []string

+ 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

+ type FSNode interface

+ Flush func() error

+ GetNode func() (*dag.Node, error)

+ Type func() NodeType

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

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

+ type File struct

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

+ func (fi *File) Flush() error

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

+ func (fi *File) Open(flags int, sync bool) (FileDescriptor, error)

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

+ func (fi *File) Sync() error

+ func (fi *File) Type() NodeType

+ type FileDescriptor interface

+ CtxReadFull func(context.Context, []byte) (int, error)

+ Flush func() error

+ Size func() (int64, error)

+ Sync func() error

+ Truncate func(int64) error

+ type NodeListing struct

+ Hash string

+ Name string

+ Size int64

+ Type int

+ type NodeType int

+ const TDir

+ const TFile

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

+ type Republisher struct

+ Publish chan struct{}

+ TimeoutLong time.Duration

+ TimeoutShort time.Duration

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

+ func (np *Republisher) Run()

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

+ func (p *Republisher) Close() error

+ func (p *Republisher) WaitPub()

+ type Root struct

+ Type string

+ 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