diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-10 12:11:37 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-28 23:24:38 -0700 |
| commit | 94b8c42b2cba40557ab28cd613ab8c19a93fca23 (patch) | |
| tree | b91f02bc735b31e613a862609384e1a7e4b8755f /weed/pb/mq.proto | |
| parent | 8060fdcac56bae36b53764d7ad23a142a865e67d (diff) | |
| download | seaweedfs-94b8c42b2cba40557ab28cd613ab8c19a93fca23.tar.xz seaweedfs-94b8c42b2cba40557ab28cd613ab8c19a93fca23.zip | |
clean up
Diffstat (limited to 'weed/pb/mq.proto')
| -rw-r--r-- | weed/pb/mq.proto | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/weed/pb/mq.proto b/weed/pb/mq.proto index 44291c173..47bd1775e 100644 --- a/weed/pb/mq.proto +++ b/weed/pb/mq.proto @@ -10,19 +10,16 @@ option java_outer_classname = "MessagQueueProto"; service SeaweedMessaging { - rpc FindBroker (FindBrokerRequest) returns (FindBrokerResponse) { + rpc FindBrokerLeader (FindBrokerLeader) returns (FindBrokerLeaderResponse) { } } ////////////////////////////////////////////////// -message FindBrokerRequest { - string namespace = 1; - string topic = 2; - int32 parition = 3; +message FindBrokerLeaderRequest { } -message FindBrokerResponse { +message FindBrokerLeaderResponse { string broker = 1; } |