Documentation
¶
Overview ¶
Package sharding implements a sharding ClusterDAGService places content in different shards while it's being added, creating a final Cluster DAG and pinning it.
Index ¶
Constants ¶
const MaxLinks = 5984
MaxLinks is the max number of links that, when serialized fit into a block
Variables ¶
This section is empty.
Functions ¶
func CborDataToNode ¶
CborDataToNode parses cbor data into a clusterDAG node while making a few checks
func VerifyShards ¶
func VerifyShards(t *testing.T, rootCid api.Cid, pins MockPinStore, ipfs MockBlockStore, expectedShards int) (map[string]struct{}, error)
VerifyShards checks that a sharded CID has been correctly formed and stored. This is a helper function for testing. It returns a map with all the blocks from all shards.
Types ¶
type DAGService ¶
type DAGService struct {
adder.BaseDAGService
// contains filtered or unexported fields
}
DAGService is an implementation of a ClusterDAGService which shards content while adding among several IPFS Cluster peers, creating a Cluster DAG to track and pin that content selectively in the IPFS daemons allocated to it.
func New ¶
func New(ctx context.Context, rpc *rpc.Client, opts api.AddParams, out chan<- api.AddedOutput) *DAGService
New returns a new ClusterDAGService, which uses the given rpc client to perform Allocate, IPFSStream and Pin requests to other cluster components.
func (*DAGService) Add ¶
Add puts the given node in its corresponding shard and sends it to the destination peers.
func (*DAGService) Allocations ¶ added in v1.0.0
func (dgs *DAGService) Allocations() []peer.ID
Allocations returns the current allocations for the current shard.
Source Files