1 files changed, 16 insertions, 4 deletions
diff --git a/weed/pb/volume_server.proto b/weed/pb/volume_server.proto
index 0f21c8ba5..e8d4ae61e 100644
--- a/weed/pb/volume_server.proto
+++ b/weed/pb/volume_server.proto
@@ -58,6 +58,8 @@ service VolumeServer {
     }
     rpc VolumeEcShardsUnmount (VolumeEcShardsUnmountRequest) returns (VolumeEcShardsUnmountResponse) {
     }
+    rpc VolumeEcShardRead (VolumeEcShardReadRequest) returns (stream VolumeEcShardReadResponse) {
+    }
 
 
 }
@@ -213,7 +215,7 @@ message VolumeEcShardsGenerateResponse {
 message VolumeEcShardsCopyRequest {
     uint32 volume_id = 1;
     string collection = 2;
-    repeated uint32 ec_indexes = 3;
+    repeated uint32 shard_ids = 3;
     string source_data_node = 5;
 }
 message VolumeEcShardsCopyResponse {
@@ -222,7 +224,7 @@ message VolumeEcShardsCopyResponse {
 message VolumeEcShardsDeleteRequest {
     uint32 volume_id = 1;
     bool should_delete_ecx = 2;
-    repeated uint32 ec_indexes = 3;
+    repeated uint32 shard_ids = 3;
 }
 message VolumeEcShardsDeleteResponse {
 }
@@ -230,18 +232,28 @@ message VolumeEcShardsDeleteResponse {
 message VolumeEcShardsMountRequest {
     uint32 volume_id = 1;
     string collection = 2;
-    repeated uint32 ec_indexes = 3;
+    repeated uint32 shard_ids = 3;
 }
 message VolumeEcShardsMountResponse {
 }
 
 message VolumeEcShardsUnmountRequest {
     uint32 volume_id = 1;
-    repeated uint32 ec_indexes = 3;
+    repeated uint32 shard_ids = 3;
 }
 message VolumeEcShardsUnmountResponse {
 }
 
+message VolumeEcShardReadRequest {
+    uint32 volume_id = 1;
+    uint32 shard_id = 2;
+    int64 offset = 3;
+    int64 size = 4;
+}
+message VolumeEcShardReadResponse {
+    bytes data = 1;
+}
+
 message ReadVolumeFileStatusRequest {
     uint32 volume_id = 1;
 }