1 files changed, 15 insertions, 3 deletions
diff --git a/weed/pb/volume_server.proto b/weed/pb/volume_server.proto
index 1edb541b1..9c63c199c 100644
--- a/weed/pb/volume_server.proto
+++ b/weed/pb/volume_server.proto
@@ -42,7 +42,9 @@ service VolumeServer {
     rpc CopyFile (CopyFileRequest) returns (stream CopyFileResponse) {
     }
 
-    rpc VolumeTail (VolumeTailRequest) returns (stream VolumeTailResponse) {
+    rpc VolumeTailSender (VolumeTailSenderRequest) returns (stream VolumeTailSenderResponse) {
+    }
+    rpc VolumeTailReceiver (VolumeTailReceiverRequest) returns (VolumeTailReceiverResponse) {
     }
 
 }
@@ -169,17 +171,26 @@ message CopyFileResponse {
     bytes file_content = 1;
 }
 
-message VolumeTailRequest {
+message VolumeTailSenderRequest {
     uint32 volume_id = 1;
     uint64 since_ns = 2;
     uint32 drainingSeconds = 3;
 }
-message VolumeTailResponse {
+message VolumeTailSenderResponse {
     bytes needle_header = 1;
     bytes needle_body = 2;
     bool is_last_chunk = 3;
 }
 
+message VolumeTailReceiverRequest {
+    uint32 volume_id = 1;
+    uint64 since_ns = 2;
+    uint32 drainingSeconds = 3;
+    string source_volume_server = 4;
+}
+message VolumeTailReceiverResponse {
+}
+
 message ReadVolumeFileStatusRequest {
     uint32 volume_id = 1;
 }
@@ -191,6 +202,7 @@ message ReadVolumeFileStatusResponse {
     uint64 dat_file_size = 5;
     uint64 file_count = 6;
     uint32 compaction_revision = 7;
+    string collection = 8;
 }
 
 message DiskStatus {