merkledag

package module

Go to main page

Versions in this module

v0

v0.11.0

Jun 9, 2023

v0.10.0

Feb 17, 2023

v0.9.0

Jan 11, 2023

v0.8.1

Nov 23, 2022

v0.8.0

Oct 4, 2022 GO-2022-1155

GO-2022-1155: Panic in github.com/ipfs/go-merkledag

v0.7.0

Aug 25, 2022 GO-2022-1155

GO-2022-1155: Panic in github.com/ipfs/go-merkledag

v0.6.0

Mar 18, 2022 GO-2022-1155

GO-2022-1155: Panic in github.com/ipfs/go-merkledag

v0.5.1

Nov 18, 2021 GO-2022-1155

GO-2022-1155: Panic in github.com/ipfs/go-merkledag

v0.5.0

Nov 10, 2021 GO-2022-1155

GO-2022-1155: Panic in github.com/ipfs/go-merkledag

Changes in this version

+ func WrapSession(s *bserv.Session) format.NodeGetter

v0.4.1

Sep 23, 2021 GO-2022-1155

GO-2022-1155: Panic in github.com/ipfs/go-merkledag

v0.4.0

Aug 12, 2021 GO-2022-1155

GO-2022-1155: Panic in github.com/ipfs/go-merkledag

Changes in this version

+ var ErrNotRawNode = fmt.Errorf("expected raw bytes node")

+ func ProtoNodeConverter(b blocks.Block, nd ipld.Node) (legacy.UniversalNode, error)

+ func RawNodeConverter(b blocks.Block, nd ipld.Node) (legacy.UniversalNode, error)

type ProtoNode

+ func (n *ProtoNode) AsBool() (bool, error)

+ func (n *ProtoNode) AsBytes() ([]byte, error)

+ func (n *ProtoNode) AsFloat() (float64, error)

+ func (n *ProtoNode) AsInt() (int64, error)

+ func (n *ProtoNode) AsLink() (ipld.Link, error)

+ func (n *ProtoNode) AsString() (string, error)

+ func (n *ProtoNode) IsAbsent() bool

+ func (n *ProtoNode) IsNull() bool

+ func (n *ProtoNode) Kind() ipld.Kind

+ func (n *ProtoNode) Length() int64

+ func (n *ProtoNode) ListIterator() ipld.ListIterator

+ func (n *ProtoNode) LookupByIndex(idx int64) (ipld.Node, error)

+ func (n *ProtoNode) LookupByNode(key ipld.Node) (ipld.Node, error)

+ func (n *ProtoNode) LookupBySegment(seg ipld.PathSegment) (ipld.Node, error)

+ func (n *ProtoNode) LookupByString(key string) (ipld.Node, error)

+ func (n *ProtoNode) MapIterator() ipld.MapIterator

+ func (n *ProtoNode) Prototype() ipld.NodePrototype

v0.3.2

Apr 23, 2020

v0.3.1

Dec 7, 2019

v0.3.0

Dec 2, 2019

v0.2.4

Oct 1, 2019

Changes in this version

type ProtoNode

+ func (n *ProtoNode) GetPBNode() *pb.PBNode

v0.2.3

Jul 26, 2019

v0.2.2

Jul 24, 2019

Changes in this version

type WalkOption

+ func SkipRoot() WalkOption

v0.2.1

Jul 22, 2019

Changes in this version

+ type WalkOption func(*walkOptions)

+ func Concurrency(worker int) WalkOption

+ func Concurrent() WalkOption

+ func IgnoreErrors() WalkOption

+ func IgnoreMissing() WalkOption

+ func OnError(handler func(c cid.Cid, err error) error) WalkOption

+ func OnMissing(callback func(c cid.Cid)) WalkOption

+ func WithRoot() WalkOption

v0.2.0

Jul 11, 2019

Changes in this version

+ func Walk(ctx context.Context, getLinks GetLinks, root cid.Cid, visit func(cid.Cid) bool) error

+ func WalkDepth(ctx context.Context, getLinks GetLinks, root cid.Cid, depth int, ...) error

+ func WalkParallel(ctx context.Context, getLinks GetLinks, c cid.Cid, visit func(cid.Cid) bool) error

+ func WalkParallelDepth(ctx context.Context, getLinks GetLinks, c cid.Cid, startDepth int, ...) error

v0.1.0

Jun 1, 2019

v0.0.6

May 24, 2019

v0.0.5

May 24, 2019

v0.0.4

May 24, 2019

v0.0.3

Mar 20, 2019

v0.0.2

Mar 16, 2019

Changes in this version

type RawNode

+ func (rn *RawNode) MarshalJSON() ([]byte, error)

v0.0.1

Mar 2, 2019

Changes in this version

+ var ErrLinkNotFound = fmt.Errorf("no link by that name")

+ var ErrNotProtobuf = fmt.Errorf("expected protobuf dag node")

+ var ErrReadOnly = fmt.Errorf("cannot write to readonly DAGService")

+ var FetchGraphConcurrency = 32

+ func DecodeProtobufBlock(b blocks.Block) (ipld.Node, error)

+ func DecodeRawBlock(block blocks.Block) (ipld.Node, error)

+ func EnumerateChildren(ctx context.Context, getLinks GetLinks, root cid.Cid, visit func(cid.Cid) bool) error

+ func EnumerateChildrenAsync(ctx context.Context, getLinks GetLinks, c cid.Cid, visit func(cid.Cid) bool) error

+ func EnumerateChildrenAsyncDepth(ctx context.Context, getLinks GetLinks, c cid.Cid, startDepth int, ...) error

+ func EnumerateChildrenDepth(ctx context.Context, getLinks GetLinks, root cid.Cid, depth int, ...) error

+ func FetchGraph(ctx context.Context, root cid.Cid, serv ipld.DAGService) error

+ func FetchGraphWithDepthLimit(ctx context.Context, root cid.Cid, depthLim int, serv ipld.DAGService) error

+ func NewDAGService(bs bserv.BlockService) *dagService

+ func NewReadOnlyDagService(ng ipld.NodeGetter) ipld.DAGService

+ func NewSession(ctx context.Context, g ipld.NodeGetter) ipld.NodeGetter

+ func PrefixForCidVersion(version int) (cid.Prefix, error)

+ func V0CidPrefix() cid.Prefix

+ func V1CidPrefix() cid.Prefix

+ type ComboService struct

+ Read ipld.NodeGetter

+ Write ipld.DAGService

+ func (cs *ComboService) Add(ctx context.Context, nd ipld.Node) error

+ func (cs *ComboService) AddMany(ctx context.Context, nds []ipld.Node) error

+ func (cs *ComboService) Get(ctx context.Context, c cid.Cid) (ipld.Node, error)

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

+ func (cs *ComboService) Remove(ctx context.Context, c cid.Cid) error

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

+ type ErrorService struct

+ Err error

+ func (cs *ErrorService) Add(ctx context.Context, nd ipld.Node) error

+ func (cs *ErrorService) AddMany(ctx context.Context, nds []ipld.Node) error

+ func (cs *ErrorService) Get(ctx context.Context, c cid.Cid) (ipld.Node, error)

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

+ func (cs *ErrorService) Remove(ctx context.Context, c cid.Cid) error

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

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

+ func GetLinksDirect(serv ipld.NodeGetter) GetLinks

+ func GetLinksWithDAG(ng ipld.NodeGetter) GetLinks

+ type LinkSlice []*ipld.Link

+ func (ls LinkSlice) Len() int

+ func (ls LinkSlice) Less(a, b int) bool

+ func (ls LinkSlice) Swap(a, b int)

+ type ProgressTracker struct

+ Total int

+ func (p *ProgressTracker) DeriveContext(ctx context.Context) context.Context

+ func (p *ProgressTracker) Increment()

+ func (p *ProgressTracker) Value() int

+ type ProtoNode struct

+ func DecodeProtobuf(encoded []byte) (*ProtoNode, error)

+ func NodeWithData(d []byte) *ProtoNode

+ func (n *ProtoNode) AddNodeLink(name string, that ipld.Node) error

+ func (n *ProtoNode) AddRawLink(name string, l *ipld.Link) error

+ func (n *ProtoNode) Cid() cid.Cid

+ func (n *ProtoNode) CidBuilder() cid.Builder

+ func (n *ProtoNode) Copy() ipld.Node

+ func (n *ProtoNode) Data() []byte

+ func (n *ProtoNode) EncodeProtobuf(force bool) ([]byte, error)

+ func (n *ProtoNode) GetLinkedNode(ctx context.Context, ds ipld.DAGService, name string) (ipld.Node, error)

+ func (n *ProtoNode) GetLinkedProtoNode(ctx context.Context, ds ipld.DAGService, name string) (*ProtoNode, error)

+ func (n *ProtoNode) GetNodeLink(name string) (*ipld.Link, error)

+ func (n *ProtoNode) Links() []*ipld.Link

+ func (n *ProtoNode) Loggable() map[string]interface{}

+ func (n *ProtoNode) Marshal() ([]byte, error)

+ func (n *ProtoNode) MarshalJSON() ([]byte, error)

+ func (n *ProtoNode) Multihash() mh.Multihash

+ func (n *ProtoNode) RawData() []byte

+ func (n *ProtoNode) RemoveNodeLink(name string) error

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

+ func (n *ProtoNode) ResolveLink(path []string) (*ipld.Link, []string, error)

+ func (n *ProtoNode) SetCidBuilder(builder cid.Builder)

+ func (n *ProtoNode) SetData(d []byte)

+ func (n *ProtoNode) SetLinks(links []*ipld.Link)

+ func (n *ProtoNode) Size() (uint64, error)

+ func (n *ProtoNode) Stat() (*ipld.NodeStat, error)

+ func (n *ProtoNode) String() string

+ func (n *ProtoNode) Tree(p string, depth int) []string

+ func (n *ProtoNode) UnmarshalJSON(b []byte) error

+ func (n *ProtoNode) UpdateNodeLink(name string, that *ProtoNode) (*ProtoNode, error)

+ type RawNode struct

+ func NewRawNode(data []byte) *RawNode

+ func NewRawNodeWPrefix(data []byte, builder cid.Builder) (*RawNode, error)

+ func (rn *RawNode) Copy() ipld.Node

+ func (rn *RawNode) Links() []*ipld.Link

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

+ func (rn *RawNode) ResolveLink(path []string) (*ipld.Link, []string, error)

+ func (rn *RawNode) Size() (uint64, error)

+ func (rn *RawNode) Stat() (*ipld.NodeStat, error)

+ func (rn *RawNode) Tree(p string, depth int) []string

+ type SessionMaker interface

+ Session func(context.Context) ipld.NodeGetter

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