adder

Sep 16, 2022

Changes in this version

type ClusterDAGService

+ Close func() error

Jul 6, 2022

Changes in this version

+ var ErrBlockAdder = errors.New("failed to put block on all destinations")

+ func IpldNodeToNodeWithMeta(n ipld.Node) api.NodeWithMeta

+ type BlockStreamer struct

+ func NewBlockStreamer(ctx context.Context, rpcClient *rpc.Client, dests []peer.ID, ...) *BlockStreamer

+ func (bs *BlockStreamer) Done() <-chan struct{}

+ func (bs *BlockStreamer) Err() error

type ClusterDAGService

+ Allocations func() []peer.ID

Aug 24, 2018

Changes in this version

+ var ErrDAGNotFound = errors.New("dagservice: block not found")

+ func BlockAllocate(ctx context.Context, rpc *rpc.Client, pinOpts api.PinOptions) ([]peer.ID, error)

+ func Pin(ctx context.Context, rpc *rpc.Client, pin api.Pin) error

+ func PutBlock(ctx context.Context, rpc *rpc.Client, n *api.NodeWithMeta, dests []peer.ID) error

+ type Adder struct

+ func New(ds ClusterDAGService, p *api.AddParams, out chan *api.AddedOutput) *Adder

+ func (a *Adder) FromFiles(ctx context.Context, f files.File) (*cid.Cid, error)

+ func (a *Adder) FromMultipart(ctx context.Context, r *multipart.Reader) (*cid.Cid, error)

+ type BaseDAGService struct

+ func (dag BaseDAGService) Get(ctx context.Context, key *cid.Cid) (ipld.Node, error)

+ func (dag BaseDAGService) GetMany(ctx context.Context, keys []*cid.Cid) <-chan *ipld.NodeOption

+ func (dag BaseDAGService) Remove(ctx context.Context, key *cid.Cid) error

+ func (dag BaseDAGService) RemoveMany(ctx context.Context, keys []*cid.Cid) error

+ type ClusterDAGService interface

+ Finalize func(ctx context.Context, ipfsRoot *cid.Cid) (*cid.Cid, error)