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(rpc *rpc.Client, opts api.PinOptions, 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) Finalize(ctx context.Context, root cid.Cid) (cid.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(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 (*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) Finalize

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

Finalize pins the last Cid added to this DAGService.