Versions in this module Expand all Collapse all v1 v1.0.0 Sep 27, 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") + func DecodeProtobufBlock(b blocks.Block) (ipld.Node, error) + func DecodeRawBlock(block blocks.Block) (ipld.Node, 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 + func Walk(ctx context.Context, getLinks GetLinks, c cid.Cid, visit func(cid.Cid) bool, ...) error + func WalkDepth(ctx context.Context, getLinks GetLinks, c cid.Cid, ...) error + 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) GetPBNode() *pb.PBNode + 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) MarshalJSON() ([]byte, error) + 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 + 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 SkipRoot() WalkOption