format

Jan 20, 2018

Changes in this version

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

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

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

+ var ParallelBatchCommits = runtime.NumCPU() * 2

+ type Batch struct

+ MaxNodes int

+ MaxSize int

+ func NewBatch(ctx context.Context, ds DAGService) *Batch

+ func (t *Batch) Add(nd Node) error

+ func (t *Batch) Commit() error

+ type DAGService interface

+ Add func(context.Context, Node) error

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

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

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

type Link

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

+ type LinkGetter interface

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

type NodeGetter

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

Jul 11, 2017

Changes in this version

+ func Register(codec uint64, decoder DecodeBlockFunc)

type BlockDecoder

+ Register func(codec uint64, decoder DecodeBlockFunc)

Jun 18, 2017

Changes in this version

+ type BlockDecoder map[uint64]DecodeBlockFunc

+ var DefaultBlockDecoder BlockDecoder = map[uint64]DecodeBlockFunc{}

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

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

type Node

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

Mar 25, 2017

Changes in this version

+ type Resolver interface

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

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

Nov 10, 2016

Changes in this version

type Node

+ Copy func() Node

Oct 20, 2016

Changes in this version

type Node

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

Oct 14, 2016

Changes in this version

+ type Link struct

+ Cid *cid.Cid

+ Name string

+ Size uint64

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

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

+ type Node interface

+ Cid func() *cid.Cid

+ Links func() []*Link

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

+ RawData func() []byte

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

+ Size func() (uint64, error)

+ Stat func() (*NodeStat, error)

+ String func() string

+ Tree func() []string

+ type NodeGetter interface

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

+ type NodeStat struct

+ BlockSize int

+ CumulativeSize int

+ DataSize int

+ Hash string

+ LinksSize int

+ NumLinks int

+ func (ns NodeStat) String() string