single

package

v0.0.0-...-a52a6fd Latest Latest Go to latest Published: Dec 1, 2020 License: Apache-2.0, MIT, Apache-2.0, + 1 more Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package single implements a ClusterDAGService that chunks and adds content to cluster without sharding, before pinning it.

This section is empty.

This section is empty.

This section is empty.

type DAGService struct {
	adder.BaseDAGService
	// contains filtered or unexported fields
}

DAGService is an implementation of an adder.ClusterDAGService which puts the added blocks directly in the peers allocated to them (without sharding).

func New(rpc *rpc.Client, opts api.PinOptions, local bool) *DAGService

New returns a new Adder with the given rpc Client. The client is used to perform calls to IPFS.BlockPut and Pin content on Cluster.

func (dgs *DAGService) Add(ctx context.Context, node ipld.Node) error

Add puts the given node in the destination peers.

func (dgs *DAGService) AddMany(ctx context.Context, nodes []ipld.Node) error

AddMany calls Add for every given node.

func (dgs *DAGService) Finalize(ctx context.Context, root cid.Cid) (cid.Cid, error)

Finalize pins the last Cid added to this DAGService.