Documentation ¶
Index ¶
- func BalanceNode(f io.Reader, bufDs ipld.DAGService, cidBuilder cid.Builder) (node ipld.Node, err error)
- func BuildDataCidByLinks(ctx context.Context, dagServ ipld.DAGService, cidBuilder cid.Builder, ...) (cid.Cid, error)
- func NewBlockService(blkstore blockstore.Blockstore) blockservice.BlockService
- func NewPoolClient(addr, user, password string, enablePin bool) (*dagPoolClient, error)
- func NewPoolClusterClient(addr string) (*dagPoolClusterClient, error)
- func NewUnixfsNodeFromDag(nd *dag.ProtoNode) (*unixfsNode, error)
- func RemoveDAG(ctx context.Context, dagServ ipld.DAGService, root cid.Cid) error
- type LinkInfo
- type PoolClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BalanceNode ¶
func BalanceNode(f io.Reader, bufDs ipld.DAGService, cidBuilder cid.Builder) (node ipld.Node, err error)
BalanceNode split the file and store it in DAGService as node
func BuildDataCidByLinks ¶ added in v0.2.0
func NewBlockService ¶ added in v0.2.0
func NewBlockService(blkstore blockstore.Blockstore) blockservice.BlockService
func NewPoolClient ¶
NewPoolClient new a dagPoolClient
func NewPoolClusterClient ¶ added in v0.4.0
NewPoolClusterClient new a dagPoolClusterClient
func NewUnixfsNodeFromDag ¶ added in v0.2.0
Types ¶
type LinkInfo ¶ added in v0.2.0
func CreateLinkInfo ¶ added in v0.2.0
type PoolClient ¶
type PoolClient interface { blockstore.Blockstore Close(ctx context.Context) }
PoolClient is a DAGService interface
func NewMockPoolClient ¶ added in v0.2.0
func NewMockPoolClient(t *testing.T) (PoolClient, func())
NewMockPoolClient creates a mock of PoolClient
Source Files ¶
Click to show internal directories.
Click to hide internal directories.