[incubator-inlong] branch INLONG-1524 updated: [INLONG-1541] Add replica node request and response define in the BrokerService.proto (#1548)

[do...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch INLONG-1524
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/INLONG-1524 by this push:
     new b53d09e  [INLONG-1541] Add replica node request and response define in the BrokerService.proto (#1548)
b53d09e is described below

commit b53d09ec75b552b62325ac0cae8841a08202510d
Author: gosonzhang <46...@qq.com>
AuthorDate: Tue Sep 14 09:42:43 2021 +0800

    [INLONG-1541] Add replica node request and response define in the BrokerService.proto (#1548)
---
 .../tubemq-core/src/main/proto/BrokerService.proto | 96 ++++++++++++++++++++++
 1 file changed, 96 insertions(+)

diff --git a/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto b/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto
index 87de27e..2c7a430 100644
--- a/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto
+++ b/inlong-tubemq/tubemq-core/src/main/proto/BrokerService.proto
@@ -27,6 +27,10 @@ message TransferedMessage {
     required int32 checkSum = 2;
     required bytes payLoadData = 3;
     required int32 flag = 4;
+    optional int32 partitionId = 5;
+    optional int32 indexKeyCode = 6;
+    optional int32 reportAddr = 7;
+    optional int64 recvTimeInMs = 8;
 }
 
 message AuthorizedInfo {
@@ -140,3 +144,95 @@ message CommitOffsetResponseB2C {
     optional int64 currOffset=4;
     optional int64 maxOffset = 5;
 }
+
+message OffsetViewInfo{
+    required int64 indexStartOffset = 1;
+    required int64 indexEndOffset = 2;
+    required int64 dataStartOffset = 3;
+    required int64 dataEndOffset = 4;
+}
+
+message RegisterRequestF2L {
+    required string replicaId = 1;
+    required string groupName = 2;
+    required string topicName = 3;
+    required int32 storeId = 4;
+    required OffsetViewInfo offsetViewInfo = 5;
+    optional int64 reqOffset = 6;
+    optional AuthorizedInfo authInfo = 7;
+}
+
+message RegisterResponseL2F {
+    required bool success = 1;
+    required int32 errCode = 2;
+    required string errMsg = 3;
+    required OffsetViewInfo offsetViewInfo = 4;
+    optional int64 readOffset = 5;
+}
+
+message HeartBeatRequestF2L {
+    required string replicaId = 1;
+    required string groupName = 2;
+    repeated string storeHBInfo = 3;
+    optional AuthorizedInfo authInfo = 4;
+}
+
+message HeartBeatResponseL2F {
+    required bool success = 1;
+    required int32 errCode = 2;
+    required string errMsg = 3;
+    optional bool hasPartFailure = 4;
+    repeated string storeHBInfo = 5;
+    optional bool requireAuth = 6;
+}
+
+message CloseRequestF2L{
+	required string replicaId = 1;
+    required string groupName = 2;
+    required string topicName = 3;
+    required int32 storeId = 4;
+	optional AuthorizedInfo authInfo = 5;
+}
+
+message CloseResponseL2F{
+    required bool success = 1;
+    required int32 errCode = 2;
+    required string errMsg = 3;
+}
+
+message GetMessageRequestF2L {
+    required string replicaId = 1;
+    required string groupName = 2;
+    required string topicName = 3;
+    required int32 storeId = 4;
+    optional bool lastPackConsumed = 5;
+}
+
+message GetMessageResponseL2F {
+    required bool success = 1;
+    required int32 errCode = 2;
+    optional string errMsg = 3;
+    repeated TransferedMessage messages = 4;
+    optional int64 currReadOffset = 5;
+    optional int64 currDataDlt = 6;
+    optional int64 maxIndexOffset = 7;
+    optional int64 maxDataOffset = 8;
+}
+
+message CommitOffsetRequestF2L {
+    required string replicaId = 1;
+    required string groupName = 2;
+    required string topicName = 3;
+    required int32 storeId = 4;
+    required bool lastPackConsumed = 5;
+}
+
+message CommitOffsetResponseL2F {
+    required bool success = 1;
+    required int32 errCode = 2;
+    required string errMsg = 3;
+    optional int64 currReadOffset = 4;
+    optional int64 currDataDlt = 5;
+    optional int64 maxIndexOffset = 6;
+    optional int64 maxDataOffset = 7;
+}