dagservice

Documentation

Index

• type DagServiceSubmodule
  • func NewDagserviceSubmodule(ctx context.Context, dagCfg dagConfig, network *network.NetworkSubmodule) (*DagServiceSubmodule, error)
  • func (blockService *DagServiceSubmodule) API() IDagService
  • func (blockService *DagServiceSubmodule) V0API() IDagService
• type IDagService

Types

type DagServiceSubmodule

type DagServiceSubmodule struct {
	// dagservice is a higher level interface for fetching data
	Blockservice bserv.BlockService

	Dag *dag.DAG
}

DagServiceSubmodule enhances the `Node` with networked key/value fetching capabilities. - `BlockService` is shared by chain/graphsync and piece/bitswap data

func NewDagserviceSubmodule

func NewDagserviceSubmodule(ctx context.Context, dagCfg dagConfig, network *network.NetworkSubmodule) (*DagServiceSubmodule, error)

NewDagserviceSubmodule creates a new block service submodule.

func (*DagServiceSubmodule) API

func (blockService *DagServiceSubmodule) API() IDagService

func (*DagServiceSubmodule) V0API

func (blockService *DagServiceSubmodule) V0API() IDagService

type IDagService

type IDagService interface {
	DAGGetNode(ctx context.Context, ref string) (interface{}, error)
	DAGGetFileSize(ctx context.Context, c cid.Cid) (uint64, error)
	DAGCat(ctx context.Context, c cid.Cid) (io.Reader, error)
	DAGImportData(ctx context.Context, data io.Reader) (ipld.Node, error)
}