You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2021/10/04 14:33:26 UTC
[rocketmq-apis] branch main updated: Feature/api Update protocol
and add apache license (#3)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
The following commit(s) were added to refs/heads/main by this push:
new e94b467 Feature/api Update protocol and add apache license (#3)
e94b467 is described below
commit e94b467271051e4878f6ab5b2aa339639ab201c6
Author: Zhouxiang Zhan <zh...@alibaba-inc.com>
AuthorDate: Mon Oct 4 22:33:20 2021 +0800
Feature/api Update protocol and add apache license (#3)
* Update protocol
* Distinguish producer_group and consumer_group in NotifyClientTerminationRequest
* Add apache license
---
apache/rocketmq/v1/admin.proto | 15 +++++++++++++++
apache/rocketmq/v1/definition.proto | 15 +++++++++++++++
apache/rocketmq/v1/service.proto | 24 +++++++++++++++++++++---
3 files changed, 51 insertions(+), 3 deletions(-)
diff --git a/apache/rocketmq/v1/admin.proto b/apache/rocketmq/v1/admin.proto
index 2d2da19..554207b 100644
--- a/apache/rocketmq/v1/admin.proto
+++ b/apache/rocketmq/v1/admin.proto
@@ -1,3 +1,18 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
syntax = "proto3";
package apache.rocketmq.v1;
diff --git a/apache/rocketmq/v1/definition.proto b/apache/rocketmq/v1/definition.proto
index 336dd51..c92aad3 100644
--- a/apache/rocketmq/v1/definition.proto
+++ b/apache/rocketmq/v1/definition.proto
@@ -1,3 +1,18 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
syntax = "proto3";
import "google/protobuf/timestamp.proto";
diff --git a/apache/rocketmq/v1/service.proto b/apache/rocketmq/v1/service.proto
index beebaf1..1da4883 100644
--- a/apache/rocketmq/v1/service.proto
+++ b/apache/rocketmq/v1/service.proto
@@ -1,3 +1,18 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
syntax = "proto3";
import "google/protobuf/duration.proto";
@@ -323,10 +338,13 @@ message MultiplexingResponse {
}
message NotifyClientTerminationRequest {
- Resource group = 1;
- string client_id = 2;
+ oneof group {
+ Resource producer_group = 1;
+ Resource consumer_group = 2;
+ }
+ string client_id = 3;
- reserved 3 to 64;
+ reserved 4 to 64;
}
message NotifyClientTerminationResponse {