implement DagstoreInitializeAll.

api/api_storage.go

@@ -197,8 +197,17 @@ type StorageMiner interface {
 	// error.
 	DagstoreRecoverShard(ctx context.Context, key string) error //perm:write
 
+	// DagstoreInitializeAll initializes all uninitialized shards in bulk,
+	// according to the policy passed in the parameters.
+	//
+	// It is recommended to set a maximum concurrency to avoid extreme
+	// IO pressure if the storage subsystem has a large amount of deals.
+	//
+	// It returns the result for each shard it attempted to initialize.
+	DagstoreInitializeAll(ctx context.Context, params DagstoreInitializeAllParams) (<-chan DagstoreShardResult, error) //perm:write
+
 	// DagstoreGC runs garbage collection on the DAG store.
-	DagstoreGC(ctx context.Context) ([]DagstoreGCResult, error) //perm:admin
+	DagstoreGC(ctx context.Context) ([]DagstoreShardResult, error) //perm:admin
 
 	// RuntimeSubsystems returns the subsystems that are enabled
 	// in this instance.
@@ -380,9 +389,13 @@ type DagstoreShardInfo struct {
 	Error string
 }
 
-// DagstoreGCResult is the serialized form of dagstore.GCResult that we expose
-// through JSON-RPC to avoid clients having to depend on the dagstore lib.
-type DagstoreGCResult struct {
-	Key   string
-	Error string
+// DagstoreShardResult enumerates results per shard.
+type DagstoreShardResult struct {
+	Key     string
+	Success bool
+	Error   string
+}
+
+type DagstoreInitializeAllParams struct {
+	MaxConcurrency int
 }

api/docgen/docgen.go

@@ -276,7 +276,7 @@ func init() {
 		api.SubsystemSectorStorage,
 		api.SubsystemMarkets,
 	})
-	addExample(api.DagstoreGCResult{
+	addExample(api.DagstoreShardResult{
 		Key:   "baga6ea4seaqecmtz7iak33dsfshi627abz4i4665dfuzr3qfs4bmad6dx3iigdq",
 		Error: "<error>",
 	})

api/proxy_gen.go

@@ -603,7 +603,9 @@ type StorageMinerStruct struct {
 
 		CreateBackup func(p0 context.Context, p1 string) error `perm:"admin"`
 
-		DagstoreGC func(p0 context.Context) ([]DagstoreGCResult, error) `perm:"admin"`
+		DagstoreGC func(p0 context.Context) ([]DagstoreShardResult, error) `perm:"admin"`
+
+		DagstoreInitializeAll func(p0 context.Context, p1 DagstoreInitializeAllParams) (<-chan DagstoreShardResult, error) `perm:"write"`
 
 		DagstoreInitializeShard func(p0 context.Context, p1 string) error `perm:"write"`
 
@@ -3577,15 +3579,26 @@ func (s *StorageMinerStub) CreateBackup(p0 context.Context, p1 string) error {
 	return ErrNotSupported
 }
 
-func (s *StorageMinerStruct) DagstoreGC(p0 context.Context) ([]DagstoreGCResult, error) {
+func (s *StorageMinerStruct) DagstoreGC(p0 context.Context) ([]DagstoreShardResult, error) {
 	if s.Internal.DagstoreGC == nil {
-		return *new([]DagstoreGCResult), ErrNotSupported
+		return *new([]DagstoreShardResult), ErrNotSupported
 	}
 	return s.Internal.DagstoreGC(p0)
 }
 
-func (s *StorageMinerStub) DagstoreGC(p0 context.Context) ([]DagstoreGCResult, error) {
-	return *new([]DagstoreGCResult), ErrNotSupported
+func (s *StorageMinerStub) DagstoreGC(p0 context.Context) ([]DagstoreShardResult, error) {
+	return *new([]DagstoreShardResult), ErrNotSupported
+}
+
+func (s *StorageMinerStruct) DagstoreInitializeAll(p0 context.Context, p1 DagstoreInitializeAllParams) (<-chan DagstoreShardResult, error) {
+	if s.Internal.DagstoreInitializeAll == nil {
+		return nil, ErrNotSupported
+	}
+	return s.Internal.DagstoreInitializeAll(p0, p1)
+}
+
+func (s *StorageMinerStub) DagstoreInitializeAll(p0 context.Context, p1 DagstoreInitializeAllParams) (<-chan DagstoreShardResult, error) {
+	return nil, ErrNotSupported
 }
 
 func (s *StorageMinerStruct) DagstoreInitializeShard(p0 context.Context, p1 string) error {