lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-12-17 17:51:20 +08:00
Code Issues Actions 32 Packages Projects Releases Wiki Activity

adjust mq proto

Browse Source
This commit is contained in:
chrislu
2023-09-30 13:18:49 -07:00
parent 40888b5612
commit d7c211fe8c
2 changed files with 354 additions and 224 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
weed/pb/mq.proto
View File

@@ -23,13 +23,13 @@ service SeaweedMessaging {
// control plane for balancer
rpc ConnectToBalancer (stream ConnectToBalancerRequest) returns (stream ConnectToBalancerResponse) {
}
rpc DoConfigureTopic (DoConfigureTopicRequest) returns (DoConfigureTopicResponse) {
}
// control plane for topic partitions
rpc LookupTopicBrokers (LookupTopicBrokersRequest) returns (LookupTopicBrokersResponse) {
}
rpc ConfigureTopic (ConfigureTopicRequest) returns (ConfigureTopicResponse) {
}
rpc DoConfigureTopic (DoConfigureTopicRequest) returns (DoConfigureTopicResponse) {
}
rpc ListTopics (ListTopicsRequest) returns (ListTopicsResponse) {
}
// a pub client will call this to get the topic partitions assignment
@@ -219,23 +219,30 @@ message SubscribeRequest {
string consumer_group = 1;
string consumer_id = 2;
string client_id = 3;
Topic topic = 4;
Partition partition = 5;
}
message Cursor {
Topic topic = 1;
Partition partition = 2;
oneof offset {
int64 start_offset = 3;
int64 start_timestamp_ns = 4;
int64 start_offset = 1;
int64 start_timestamp_ns = 2;
}
string filter = 5;
string filter = 3;
}
message AckMessage {
int64 sequence = 1;
}
oneof message {
Consumer consumer = 1;
Cursor cursor = 2;
AckMessage ack = 3;
}
Consumer consumer = 1;
Cursor cursor = 2;
}
message SubscribeResponse {
message CtrlMessage {
string error = 1;
string redirect_to_broker = 2;
bool is_end_of_stream = 2;
bool is_end_of_topic = 3;
}
oneof message {
CtrlMessage ctrl = 1;