feat: market: add api DagstoreDestroyShards

filecoin-project · Mar 27, 2023 · 931bc77 · 931bc77
1 parent 0c81d3d
commit 931bc77
Show file tree

Hide file tree

Showing 9 changed files with 85 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
 
+	// DagstoreDestroyShard destroy shard by key
+	DagstoreDestroyShard(ctx context.Context, key 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)
+  * [DagstoreDestroyShard](#dagstoredestroyshard)
   * [DagstoreGC](#dagstoregc)
   * [DagstoreInitializeAll](#dagstoreinitializeall)
   * [DagstoreInitializeShard](#dagstoreinitializeshard)
@@ -272,6 +273,21 @@ Response:
 ]
 ```
 
+### DagstoreDestroyShard
+DagstoreDestroyShard destroy shard by key
+
+
+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
 
+	// DagstoreDestroyShard destroy shard by key
+	DagstoreDestroyShard(ctx context.Context, key 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)
+  * [DagstoreDestroyShard](#dagstoredestroyshard)
   * [DagstoreGC](#dagstoregc)
   * [DagstoreInitializeAll](#dagstoreinitializeall)
   * [DagstoreInitializeShard](#dagstoreinitializeshard)
@@ -273,6 +274,21 @@ Response:
 ]
 ```
 
+### DagstoreDestroyShard
+DagstoreDestroyShard destroy shard by key
+
+
+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
diff --git a/venus-shared/types/market/dagstore.go b/venus-shared/types/market/dagstore.go
@@ -1,5 +1,16 @@
 package market
 
+// refer: https://github.com/filecoin-project/dagstore/blob/master/shard_state.go#L37
+const (
+	ShardStateNew          = "ShardStateNew"
+	ShardStateInitializing = "ShardStateInitializing"
+	ShardStateAvailable    = "ShardStateAvailable"
+	ShardStateServing      = "ShardStateServing"
+	ShardStateRecovering   = "ShardStateRecovering"
+	ShardStateErrored      = "ShardStateErrored"
+	ShardStateUnknown      = "ShardStateUnknown"
+)
+
 // DagstoreShardInfo is the serialized form of dagstore.DagstoreShardInfo that
 // we expose through JSON-RPC to avoid clients having to depend on the
 // dagstore lib.