Update BrokerManagementService & ClusterManagementService IDLs (#66)

* update broker management service idl

add cluster management service idl

* BrokerManagementService IDL: join provided brokers

* cleanup

* fix wording

Author: mostroverkhov

gradle.properties

@@ -1,2 +1,2 @@
 group=io.netifi.proteus
-version=1.6.0
+version=1.6.1

proteus-broker-mgmt-idl/src/main/proto/proteus/broker_mgmt.proto

@@ -30,14 +30,25 @@ message Brokers {
     repeated io.netifi.proteus.broker.info.Broker brokers = 1;
 }
 
+message Connection {
+  io.netifi.proteus.broker.info.Id id = 1;
+  string group = 2;
+}
+
 service BrokerManagementService {
     // Shutdowns down a broker process
     rpc shutdown (google.protobuf.Empty) returns (google.protobuf.Empty) {}
 
+    // Shutdowns down a broker process after draining connections with timeout
+    rpc shutdownGracefully (google.protobuf.Empty) returns (google.protobuf.Empty) {}
+
     // Broker leaves the cluster, but stays running
     rpc leave (google.protobuf.Empty) returns (Ack) {}
 
-    // Rejoins the cluster it  has seed information for
+    // Broker drains connections and leaves the cluster, then joins cluster again
+    rpc restart (google.protobuf.Empty) returns (Ack) {}
+
+    // Broker joins cluster It previously left
     rpc rejoin (google.protobuf.Empty) returns (Ack) {}
 
     // Tells the Broker to join using the provided Brokers
@@ -60,4 +71,7 @@ service BrokerManagementService {
 
     // Closes all connections on the broker including broker to broker connections
     rpc closeAll (google.protobuf.Empty) returns (Ack) {}
+
+    // Closes connection on the broker by its id. Connection group is optional
+    rpc closeConnection(stream Connection) returns (Ack) {}
 }

proteus-broker-mgmt-idl/src/main/proto/proteus/cluster_mgmt.proto

@@ -0,0 +1,33 @@
+//
+//    Copyright 2019 The Proteus Authors
+//
+//    Licensed 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 io.netifi.proteus.broker.info;
+
+import "google/protobuf/empty.proto";
+import "proteus/broker_mgmt.proto";
+import "proteus/broker_info.proto";
+
+option java_package = "io.netifi.proteus.cluster.mgmt";
+option java_outer_classname = "ClusterManagement";
+option java_multiple_files = true;
+
+service ClusterManagementService {
+    // Closes connections to a specific set of destinations across broker cluster
+    rpc closeDestination (stream io.netifi.proteus.broker.info.Destination) returns (Ack) {}
+
+    // Closes all connections to a specific group cluster-wide
+    rpc closeGroup (stream io.netifi.proteus.broker.info.Group) returns (Ack) {}
+}