From c88e12abb62084a73788581908f6ae96f5773e57 Mon Sep 17 00:00:00 2001
From: Martin Sumner <martin.sumner@adaptip.co.uk>
Date: Mon, 28 Feb 2022 10:21:28 +0000
Subject: [PATCH] Add Cluster membership request/response message

Request to know about other members known by this member.  Option to add a queue name, although initially this may be ignored.

Implementation may not be responsive, should be used sparingly, rather than as a regular pre-cursor to requests.
---
 src/riak_kv.proto        | 15 +++++++++++++++
 src/riak_pb_messages.csv |  2 ++
 2 files changed, 17 insertions(+)

diff --git a/src/riak_kv.proto b/src/riak_kv.proto
index 259f323..a4c69fd 100644
--- a/src/riak_kv.proto
+++ b/src/riak_kv.proto
@@ -384,6 +384,21 @@ message RpbPushResp{
     optional uint32 realt_length = 12;
 }
 
+// Request a member of a cluster return the API addresses of other members
+message RpbMembershipReq{
+    optional bytes queuename = 1;
+}
+
+// An IP Port representing the API address of a cluster member 
+message RpbClusterMemberEntry {
+    required bytes ip = 1;
+    required uint32 port = 2;
+}
+
+message RpbMembershipResp{
+    repeated RpbClusterMemberEntry up_nodes = 1;
+}
+
 // AAE Fold requests
 message RpbAaeFoldMergeRootNValReq{
     required uint32 n_val = 1;
diff --git a/src/riak_pb_messages.csv b/src/riak_pb_messages.csv
index 38d5ea6..b41d66f 100644
--- a/src/riak_pb_messages.csv
+++ b/src/riak_pb_messages.csv
@@ -77,6 +77,8 @@
 203,RpbFetchResp,riak_kv
 204,RpbPushReq,riak_kv
 205,RpbPushResp,riak_kv
+206,RpbMembershipReq,riak_kv
+207,RpbMembershipResp,riak_kv
 210,RpbAaeFoldMergeRootNValReq,riak_kv
 211,RpbAaeFoldMergeBranchNValReq,riak_kv
 212,RpbAaeFoldFetchClocksNValReq,riak_kv