You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/09/13 11:35:10 UTC
[incubator-inlong] branch master updated: [INLONG-1541] Add replica
node request and response define in the BrokerService.proto (#1543)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new a45f109 [INLONG-1541] Add replica node request and response define in the BrokerService.proto (#1543)
a45f109 is described below
commit a45f10903dd64687d37152a15f4537a0f4234ca8
Author: gosonzhang <46...@qq.com>
AuthorDate: Mon Sep 13 19:35:03 2021 +0800
[INLONG-1541] Add replica node request and response define in the BrokerService.proto (#1543)
---
.../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;
+}