single

package

v1.0.1 Latest Latest Go to latest Published: May 6, 2022 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(ctx context.Context, rpc *rpc.Client, opts api.AddParams, local bool) *DAGService

New returns a new Adder with the given rpc Client. The client is used to perform calls to IPFS.BlockStream 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) Allocations() []peer.ID

Allocations returns the add destinations decided by the DAGService.

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

Finalize pins the last Cid added to this DAGService.