single

Documentation

Overview

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

Index

• type DAGService
  • func New(ctx context.Context, rpc *rpc.Client, opts api.AddParams, local bool) *DAGService
  • func (dgs *DAGService) Add(ctx context.Context, node ipld.Node) error
  • func (dgs *DAGService) AddMany(ctx context.Context, nodes []ipld.Node) error
  • func (dgs *DAGService) Allocations() []peer.ID
  • func (dgs *DAGService) Close() error
  • func (dgs *DAGService) Finalize(ctx context.Context, root api.Cid) (api.Cid, error)

Types

type DAGService

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

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 (*DAGService) Add

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

Add puts the given node in the destination peers.

func (*DAGService) AddMany

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

AddMany calls Add for every given node.

func (*DAGService) Allocations

func (dgs *DAGService) Allocations() []peer.ID

Allocations returns the add destinations decided by the DAGService.

func (*DAGService) Close

func (dgs *DAGService) Close() error

Close cleans up the DAGService.

func (*DAGService) Finalize

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

Finalize pins the last Cid added to this DAGService.