format

package module

Go to main page

Versions in this module

v0

v0.6.4

Jul 7, 2026

v0.6.3

Sep 18, 2025

v0.6.2

Jun 24, 2025

v0.6.1

May 7, 2025

v0.6.0

Aug 28, 2023

v0.5.0

Jun 7, 2023

Changes in this version

+ type Registry struct

+ func (r *Registry) Decode(block blocks.Block) (Node, error)

+ func (r *Registry) Register(codec uint64, decoder DecodeBlockFunc)

v0.4.0

Apr 2, 2022

v0.3.1

Mar 27, 2022

v0.3.0

Mar 18, 2022

Changes in this version

type NavigableNode

+ GetIPLDNode func() Node

v0.2.0

Apr 7, 2020

v0.1.0

Mar 26, 2020

Changes in this version

+ func IsNotFound(err error) bool

type ErrNotFound

+ Cid cid.Cid

+ func (e ErrNotFound) Error() string

+ func (e ErrNotFound) Is(err error) bool

+ func (e ErrNotFound) NotFound() bool

v0.0.2

May 13, 2019

v0.0.1

Mar 1, 2019

Changes in this version

+ var EndOfDag = errors.New("end of DAG")

+ var ErrClosed = errors.New("error: batch closed")

+ var ErrDownNoChild = errors.New("can't go down, the child does not exist")

+ var ErrNextNoChild = errors.New("can't go to the next child, no more child nodes in this parent")

+ var ErrNilVisitor = errors.New("no Visitor function specified")

+ var ErrNotCommited = errors.New("error: batch not commited")

+ var ErrNotFound = fmt.Errorf("merkledag: not found")

+ var ParallelBatchCommits = runtime.NumCPU() * 2

+ func Copy(ctx context.Context, from, to DAGService, root cid.Cid) error

+ func Register(codec uint64, decoder DecodeBlockFunc)

+ type Batch struct

+ func NewBatch(ctx context.Context, na NodeAdder, opts ...BatchOption) *Batch

+ func (t *Batch) Add(ctx context.Context, nd Node) error

+ func (t *Batch) AddMany(ctx context.Context, nodes []Node) error

+ func (t *Batch) Commit() error

+ type BatchOption func(o *batchOptions)

+ func MaxNodesBatchOption(num int) BatchOption

+ func MaxSizeBatchOption(size int) BatchOption

+ type BlockDecoder interface

+ Decode func(blocks.Block) (Node, error)

+ Register func(codec uint64, decoder DecodeBlockFunc)

+ var DefaultBlockDecoder BlockDecoder = &safeBlockDecoder{ ... }

+ type BufferedDAG struct

+ func NewBufferedDAG(ctx context.Context, ds DAGService, opts ...BatchOption) *BufferedDAG

+ func (bd *BufferedDAG) Add(ctx context.Context, n Node) error

+ func (bd *BufferedDAG) AddMany(ctx context.Context, nds []Node) error

+ func (bd *BufferedDAG) Commit() error

+ func (bd *BufferedDAG) Get(ctx context.Context, c cid.Cid) (Node, error)

+ func (bd *BufferedDAG) GetMany(ctx context.Context, cs []cid.Cid) <-chan *NodeOption

+ func (bd *BufferedDAG) Remove(ctx context.Context, c cid.Cid) error

+ func (bd *BufferedDAG) RemoveMany(ctx context.Context, cs []cid.Cid) error

+ type DAGService interface

+ Remove func(context.Context, cid.Cid) error

+ RemoveMany func(context.Context, []cid.Cid) error

+ type DecodeBlockFunc func(block blocks.Block) (Node, error)

+ type Link struct

+ Cid cid.Cid

+ Name string

+ Size uint64

+ func GetLinks(ctx context.Context, ng NodeGetter, c cid.Cid) ([]*Link, error)

+ func MakeLink(n Node) (*Link, error)

+ func (l *Link) GetNode(ctx context.Context, serv NodeGetter) (Node, error)

+ type LinkGetter interface

+ GetLinks func(ctx context.Context, nd cid.Cid) ([]*Link, error)

+ type NavigableIPLDNode struct

+ func NewNavigableIPLDNode(node Node, nodeGetter NodeGetter) *NavigableIPLDNode

+ func (nn *NavigableIPLDNode) ChildTotal() uint

+ func (nn *NavigableIPLDNode) FetchChild(ctx context.Context, childIndex uint) (NavigableNode, error)

+ func (nn *NavigableIPLDNode) GetIPLDNode() Node

+ type NavigableNode interface

+ ChildTotal func() uint

+ FetchChild func(ctx context.Context, childIndex uint) (NavigableNode, error)

+ type Node interface

+ Copy func() Node

+ Links func() []*Link

+ ResolveLink func(path []string) (*Link, []string, error)

+ Size func() (uint64, error)

+ Stat func() (*NodeStat, error)

+ func Decode(block blocks.Block) (Node, error)

+ func ExtractIPLDNode(node NavigableNode) Node

+ type NodeAdder interface

+ Add func(context.Context, Node) error

+ AddMany func(context.Context, []Node) error

+ type NodeGetter interface

+ Get func(context.Context, cid.Cid) (Node, error)

+ GetMany func(context.Context, []cid.Cid) <-chan *NodeOption

+ type NodeOption struct

+ Err error

+ Node Node

+ type NodePromise struct

+ func GetDAG(ctx context.Context, ds NodeGetter, root Node) []*NodePromise

+ func GetNodes(ctx context.Context, ds NodeGetter, keys []cid.Cid) []*NodePromise

+ func NewNodePromise(ctx context.Context) *NodePromise

+ func (np *NodePromise) Fail(err error)

+ func (np *NodePromise) Get(ctx context.Context) (Node, error)

+ func (np *NodePromise) Send(nd Node)

+ type NodeStat struct

+ BlockSize int

+ CumulativeSize int

+ DataSize int

+ Hash string

+ LinksSize int

+ NumLinks int

+ func (ns NodeStat) String() string

+ type Resolver interface

+ Resolve func(path []string) (interface{}, []string, error)

+ Tree func(path string, depth int) []string

+ type Visitor func(node NavigableNode) error

+ type Walker struct

+ func NewWalker(ctx context.Context, root NavigableNode) *Walker

+ func (w *Walker) ActiveChildIndex() uint

+ func (w *Walker) ActiveNode() NavigableNode

+ func (w *Walker) Iterate(visitor Visitor) error

+ func (w *Walker) NextChild() error

+ func (w *Walker) Pause()

+ func (w *Walker) Seek(visitor Visitor) error

+ func (w *Walker) SetContext(ctx context.Context)

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