public

package
v0.0.0-...-01c881c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2021 License: GPL-3.0 Imports: 25 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AllKeys 

func AllKeys(ctx context.Context, bs blockstore.Blockstore) ([]cid.Cid, error)

func CopyBlocks 

func CopyBlocks(ctx context.Context, id cid.Cid, src, dst Store) error

Copy blocks from src to dst

func Merge 

func Merge(ctx context.Context, a, b base.Node) (result base.MergeResult, err error)

func WrapFileMetadata 

func WrapFileMetadata(f fs.File, meta interface{}) (wrapped fs.File)

Types

type File 

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

func LoadFile 

func LoadFile(ctx context.Context, store Store, name string, id cid.Cid) (*File, error)

func NewFile 

func NewFile(store Store, name string, content io.ReadCloser) (*File, error)

func NewFileMetadata 

func NewFileMetadata(store Store, name string, content io.ReadCloser, meta interface{}) (*File, error)

func (*File) AsHistoryEntry 

func (f *File) AsHistoryEntry() base.HistoryEntry

func (*File) Cid 

func (f *File) Cid() cid.Cid

func (*File) Close 

func (f *File) Close() error

func (*File) History 

func (f *File) History(ctx context.Context, maxRevs int) ([]base.HistoryEntry, error)

func (*File) IsDir 

func (f *File) IsDir() bool
func (f *File) Links() base.Links

func (*File) Metadata 

func (f *File) Metadata() (res base.LDFile, err error)

func (*File) ModTime 

func (f *File) ModTime() time.Time

func (*File) Mode 

func (f *File) Mode() fs.FileMode

func (*File) Name 

func (f *File) Name() string

func (*File) Put 

func (f *File) Put() (base.PutResult, error)

func (*File) Read 

func (f *File) Read(p []byte) (n int, err error)

func (*File) SetFile 

func (f *File) SetFile(r io.ReadCloser)

func (*File) SetMetadata 

func (f *File) SetMetadata(v interface{}) error

func (*File) Size 

func (f *File) Size() int64

func (*File) Stat 

func (f *File) Stat() (fs.FileInfo, error)

func (*File) Sys 

func (f *File) Sys() interface{}

func (*File) Type 

func (f *File) Type() base.NodeType

type FileGetter 

type FileGetter interface {
	GetFile(context.Context, cid.Cid) (io.ReadCloser, error)
}
type Header struct {
	Info     *Info
	Previous *cid.Cid // historical backpointer
	Merge    *cid.Cid // if this version is a merge, will be populated
	Metadata *cid.Cid
	Skeleton *cid.Cid // only present on directories
	Userland *cid.Cid
}

type Info 

type Info struct {
	WNFS  base.SemVer   `json:"wnfs"`
	Type  base.NodeType `json:"type"`
	Mode  uint32        `json:"mode"`
	Ctime int64         `json:"ctime"`
	Mtime int64         `json:"mtime"`
	Size  int64         `json:"size"`
}

func InfoFromMap 

func InfoFromMap(m map[string]interface{}) *Info

func NewInfo 

func NewInfo(t base.NodeType) *Info

func (*Info) Map 

func (i *Info) Map() map[string]interface{}

type LDFile 

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

func LoadLDFile 

func LoadLDFile(ctx context.Context, store Store, name string, id cid.Cid) (*LDFile, error)

func NewBareLDFile 

func NewBareLDFile(store Store, name string, content interface{}) *LDFile

func NewLDFile 

func NewLDFile(store Store, name string, content interface{}) *LDFile

func (*LDFile) AsHistoryEntry 

func (df *LDFile) AsHistoryEntry() base.HistoryEntry

func (*LDFile) Cid 

func (df *LDFile) Cid() cid.Cid

func (*LDFile) Close 

func (df *LDFile) Close() error

func (*LDFile) Data 

func (df *LDFile) Data() (interface{}, error)

func (*LDFile) History 

func (df *LDFile) History(ctx context.Context, maxRevs int) ([]base.HistoryEntry, error)

func (*LDFile) IsBare 

func (df *LDFile) IsBare() bool

func (*LDFile) IsDir 

func (df *LDFile) IsDir() bool
func (df *LDFile) Links() base.Links

func (*LDFile) Metadata 

func (df *LDFile) Metadata() (base.LDFile, error)

func (*LDFile) ModTime 

func (df *LDFile) ModTime() time.Time

func (*LDFile) Mode 

func (df *LDFile) Mode() fs.FileMode

func (*LDFile) Name 

func (df *LDFile) Name() string

func (*LDFile) Put 

func (df *LDFile) Put() (result base.PutResult, err error)

func (*LDFile) Read 

func (df *LDFile) Read(p []byte) (n int, err error)

func (*LDFile) ReadDir 

func (df *LDFile) ReadDir(n int) ([]fs.DirEntry, error)

func (*LDFile) SetFile 

func (df *LDFile) SetFile(data interface{})

func (*LDFile) SetMetadata 

func (df *LDFile) SetMetadata(m interface{}) error

func (*LDFile) Size 

func (df *LDFile) Size() int64

func (*LDFile) Stat 

func (df *LDFile) Stat() (fs.FileInfo, error)

func (*LDFile) Sys 

func (df *LDFile) Sys() interface{}

func (*LDFile) Type 

func (df *LDFile) Type() base.NodeType

type PutResult 

type PutResult struct {
	Cid      cid.Cid
	Size     int64
	Type     base.NodeType
	Userland cid.Cid
	Metadata cid.Cid
	Skeleton Skeleton
}

func (PutResult) CID 

func (r PutResult) CID() cid.Cid
func (r PutResult) ToLink(name string) base.Link

func (PutResult) ToSkeletonInfo 

func (r PutResult) ToSkeletonInfo() SkeletonInfo

type Skeleton 

type Skeleton map[string]SkeletonInfo

func LoadSkeleton 

func LoadSkeleton(ctx context.Context, store FileGetter, id cid.Cid) (Skeleton, error)

func (Skeleton) CBORFile 

func (s Skeleton) CBORFile() (fs.File, error)

func (Skeleton) PathInfo 

func (s Skeleton) PathInfo(path base.Path) (SkeletonInfo, error)

type SkeletonInfo 

type SkeletonInfo struct {
	Cid         cid.Cid  `json:"cid,omitempty"`
	Userland    cid.Cid  `json:"userland,omitempty"`
	Metadata    cid.Cid  `json:"metadata,omitempty"`
	SubSkeleton Skeleton `json:"subSkeleton,omitempty"`
	IsFile      bool     `json:"isFile"`
}

type SkeletonSource 

type SkeletonSource interface {
	Skeleton() (Skeleton, error)
}

type Store 

type Store interface {
	Context() context.Context
	Blockservice() blockservice.BlockService
	GetFile(ctx context.Context, root cid.Cid) (io.ReadCloser, error)
	PutFile(f fs.File) (PutResult, error)
}

Store is a store of Content-Addressed block data indexed by merkle proofs. It's an abstraction over IPFS that defines the required feature set to run wnfs

func NewStore 

func NewStore(ctx context.Context, bserv blockservice.BlockService) Store

func NodeStore 

func NodeStore(n base.Node) (Store, error)

type Tree 

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

func LoadTree 

func LoadTree(ctx context.Context, st Store, name string, id cid.Cid) (*Tree, error)

func NewEmptyTree 

func NewEmptyTree(store Store, name string) *Tree

func (*Tree) Add 

func (t *Tree) Add(path base.Path, f fs.File) (res base.PutResult, err error)

func (*Tree) AsHistoryEntry 

func (t *Tree) AsHistoryEntry() base.HistoryEntry

func (*Tree) Cid 

func (t *Tree) Cid() cid.Cid

func (*Tree) Close 

func (t *Tree) Close() error

func (*Tree) Copy 

func (t *Tree) Copy(path base.Path, srcPathStr string, srcFS fs.FS) (res base.PutResult, err error)

func (*Tree) Get 

func (t *Tree) Get(path base.Path) (fs.File, error)

func (*Tree) History 

func (t *Tree) History(ctx context.Context, max int) ([]base.HistoryEntry, error)

func (*Tree) IsDir 

func (t *Tree) IsDir() bool
func (t *Tree) Links() base.Links

func (*Tree) Metadata 

func (t *Tree) Metadata() (f base.LDFile, err error)

func (*Tree) Mkdir 

func (t *Tree) Mkdir(path base.Path) (res base.PutResult, err error)

func (*Tree) ModTime 

func (t *Tree) ModTime() time.Time

func (*Tree) Mode 

func (t *Tree) Mode() fs.FileMode

func (*Tree) Name 

func (t *Tree) Name() string

func (*Tree) Put 

func (t *Tree) Put() (base.PutResult, error)

func (*Tree) Raw 

func (t *Tree) Raw() []byte

func (*Tree) Read 

func (t *Tree) Read(p []byte) (n int, err error)

func (*Tree) ReadDir 

func (t *Tree) ReadDir(n int) ([]fs.DirEntry, error)

func (*Tree) Rm 

func (t *Tree) Rm(path base.Path) (base.PutResult, error)

func (*Tree) SetMetadata 

func (t *Tree) SetMetadata(md interface{}) error

func (*Tree) Size 

func (t *Tree) Size() int64

func (*Tree) Skeleton 

func (t *Tree) Skeleton() (Skeleton, error)

func (*Tree) Stat 

func (t *Tree) Stat() (fs.FileInfo, error)

func (*Tree) Sys 

func (t *Tree) Sys() interface{}

func (*Tree) Type 

func (t *Tree) Type() base.NodeType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.