tail-volume-uses-the-source-volume-version

2 files changed, 12 insertions, 2 deletions

diff --git a/weed/pb/volume_server.proto b/weed/pb/volume_server.proto
index 616ed01be..79b1ba1d0 100644
--- a/weed/pb/volume_server.proto
+++ b/weed/pb/volume_server.proto
@@ -341,6 +341,7 @@ message VolumeTailSenderResponse {
     bytes needle_header = 1;
     bytes needle_body = 2;
     bool is_last_chunk = 3;
+    uint32 version = 4;
 }
 
 message VolumeTailReceiverRequest {
diff --git a/weed/pb/volume_server_pb/volume_server.pb.go b/weed/pb/volume_server_pb/volume_server.pb.go
index 2eb514824..b4c5ec809 100644
--- a/weed/pb/volume_server_pb/volume_server.pb.go
+++ b/weed/pb/volume_server_pb/volume_server.pb.go
@@ -2535,6 +2535,7 @@ type VolumeTailSenderResponse struct {
 	NeedleHeader  []byte                 `protobuf:"bytes,1,opt,name=needle_header,json=needleHeader,proto3" json:"needle_header,omitempty"`
 	NeedleBody    []byte                 `protobuf:"bytes,2,opt,name=needle_body,json=needleBody,proto3" json:"needle_body,omitempty"`
 	IsLastChunk   bool                   `protobuf:"varint,3,opt,name=is_last_chunk,json=isLastChunk,proto3" json:"is_last_chunk,omitempty"`
+	Version       uint32                 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@@ -2590,6 +2591,13 @@ func (x *VolumeTailSenderResponse) GetIsLastChunk() bool {
 	return false
 }
 
+func (x *VolumeTailSenderResponse) GetVersion() uint32 {
+	if x != nil {
+		return x.Version
+	}
+	return 0
+}
+
 type VolumeTailReceiverRequest struct {
 	state              protoimpl.MessageState `protogen:"open.v1"`
 	VolumeId           uint32                 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
@@ -5887,12 +5895,13 @@ const file_volume_server_proto_rawDesc = "" +
 	"\x17VolumeTailSenderRequest\x12\x1b\n" +
 	"\tvolume_id\x18\x01 \x01(\rR\bvolumeId\x12\x19\n" +
 	"\bsince_ns\x18\x02 \x01(\x04R\asinceNs\x120\n" +
-	"\x14idle_timeout_seconds\x18\x03 \x01(\rR\x12idleTimeoutSeconds\"\x84\x01\n" +
+	"\x14idle_timeout_seconds\x18\x03 \x01(\rR\x12idleTimeoutSeconds\"\x9e\x01\n" +
 	"\x18VolumeTailSenderResponse\x12#\n" +
 	"\rneedle_header\x18\x01 \x01(\fR\fneedleHeader\x12\x1f\n" +
 	"\vneedle_body\x18\x02 \x01(\fR\n" +
 	"needleBody\x12\"\n" +
-	"\ris_last_chunk\x18\x03 \x01(\bR\visLastChunk\"\xb7\x01\n" +
+	"\ris_last_chunk\x18\x03 \x01(\bR\visLastChunk\x12\x18\n" +
+	"\aversion\x18\x04 \x01(\rR\aversion\"\xb7\x01\n" +
 	"\x19VolumeTailReceiverRequest\x12\x1b\n" +
 	"\tvolume_id\x18\x01 \x01(\rR\bvolumeId\x12\x19\n" +
 	"\bsince_ns\x18\x02 \x01(\x04R\asinceNs\x120\n" +