feat: market: add api DagstoreDestroyShards

filecoin-project · Mar 24, 2023 · 19d5c76 · 19d5c76
1 parent 0c81d3d
commit 19d5c76
Show file tree

Hide file tree

Showing 8 changed files with 78 additions and 0 deletions.
diff --git a/venus-shared/api/market/v0/api.go b/venus-shared/api/market/v0/api.go
@@ -152,6 +152,9 @@ type IMarket interface {
 	// DagstoreGC runs garbage collection on the DAG store.
 	DagstoreGC(ctx context.Context) ([]market.DagstoreShardResult, error) //perm:admin
 
+	// DagstoreDestroyShards destroy shards by keys
+	DagstoreDestroyShards(ctx context.Context, keys []string) error //perm:admin
+
 	MarkDealsAsPacking(ctx context.Context, miner address.Address, deals []abi.DealID) error                                                          //perm:write
 	UpdateDealOnPacking(ctx context.Context, miner address.Address, dealID abi.DealID, sectorid abi.SectorNumber, offset abi.PaddedPieceSize) error   //perm:write
 	UpdateDealStatus(ctx context.Context, miner address.Address, dealID abi.DealID, pieceStatus market.PieceStatus) error                             //perm:write

diff --git a/venus-shared/api/market/v0/method.md b/venus-shared/api/market/v0/method.md
@@ -15,6 +15,7 @@ curl http://<ip>:<port>/rpc/v0 -X POST -H "Content-Type: application/json"  -H "
   * [AddFsPieceStorage](#addfspiecestorage)
   * [AddS3PieceStorage](#adds3piecestorage)
   * [AssignUnPackedDeals](#assignunpackeddeals)
+  * [DagstoreDestroyShards](#dagstoredestroyshards)
   * [DagstoreGC](#dagstoregc)
   * [DagstoreInitializeAll](#dagstoreinitializeall)
   * [DagstoreInitializeShard](#dagstoreinitializeshard)
@@ -272,6 +273,23 @@ Response:
 ]
 ```
 
+### DagstoreDestroyShards
+DagstoreDestroyShards destroy shards by keys
+
+
+Perms: admin
+
+Inputs:
+```json
+[
+  [
+    "string value"
+  ]
+]
+```
+
+Response: `{}`
+
 ### DagstoreGC
 DagstoreGC runs garbage collection on the DAG store.
 

diff --git a/venus-shared/api/market/v0/mock/mock_imarket.go b/venus-shared/api/market/v0/mock/mock_imarket.go
diff --git a/venus-shared/api/market/v0/proxy_gen.go b/venus-shared/api/market/v0/proxy_gen.go
diff --git a/venus-shared/api/market/v1/api.go b/venus-shared/api/market/v1/api.go
@@ -152,6 +152,9 @@ type IMarket interface {
 	// DagstoreGC runs garbage collection on the DAG store.
 	DagstoreGC(ctx context.Context) ([]market.DagstoreShardResult, error) //perm:admin
 
+	// DagstoreDestroyShards destroy shards by keys
+	DagstoreDestroyShards(ctx context.Context, keys []string) error //perm:admin
+
 	MarkDealsAsPacking(ctx context.Context, miner address.Address, deals []abi.DealID) error                                                                          //perm:write
 	UpdateDealOnPacking(ctx context.Context, miner address.Address, dealID abi.DealID, sectorid abi.SectorNumber, offset abi.PaddedPieceSize) error                   //perm:write
 	UpdateDealStatus(ctx context.Context, miner address.Address, dealID abi.DealID, pieceStatus market.PieceStatus, dealStatus storagemarket.StorageDealStatus) error //perm:write

diff --git a/venus-shared/api/market/v1/method.md b/venus-shared/api/market/v1/method.md
@@ -15,6 +15,7 @@ curl http://<ip>:<port>/rpc/v1 -X POST -H "Content-Type: application/json"  -H "
   * [AddFsPieceStorage](#addfspiecestorage)
   * [AddS3PieceStorage](#adds3piecestorage)
   * [AssignUnPackedDeals](#assignunpackeddeals)
+  * [DagstoreDestroyShards](#dagstoredestroyshards)
   * [DagstoreGC](#dagstoregc)
   * [DagstoreInitializeAll](#dagstoreinitializeall)
   * [DagstoreInitializeShard](#dagstoreinitializeshard)
@@ -273,6 +274,23 @@ Response:
 ]
 ```
 
+### DagstoreDestroyShards
+DagstoreDestroyShards destroy shards by keys
+
+
+Perms: admin
+
+Inputs:
+```json
+[
+  [
+    "string value"
+  ]
+]
+```
+
+Response: `{}`
+
 ### DagstoreGC
 DagstoreGC runs garbage collection on the DAG store.
 

diff --git a/venus-shared/api/market/v1/mock/mock_imarket.go b/venus-shared/api/market/v1/mock/mock_imarket.go
diff --git a/venus-shared/api/market/v1/proxy_gen.go b/venus-shared/api/market/v1/proxy_gen.go