From 1e3e4b3072071341b4bb4b0bb7c611457e927f97 Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Tue, 5 May 2020 02:05:28 -0700
Subject: add broker connects to filer

---
 other/java/client/src/main/proto/filer.proto | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'other/java')

diff --git a/other/java/client/src/main/proto/filer.proto b/other/java/client/src/main/proto/filer.proto
index 6d890861d..3b3b78bbb 100644
--- a/other/java/client/src/main/proto/filer.proto
+++ b/other/java/client/src/main/proto/filer.proto
@@ -48,6 +48,8 @@ service SeaweedFiler {
     rpc SubscribeMetadata (SubscribeMetadataRequest) returns (stream SubscribeMetadataResponse) {
     }
 
+    rpc KeepConnected (stream KeepConnectedRequest) returns (stream KeepConnectedResponse) {
+    }
 }
 
 //////////////////////////////////////////////////
@@ -261,3 +263,10 @@ message LogEntry {
     int32 partition_key_hash = 2;
     bytes data = 3;
 }
+
+message KeepConnectedRequest {
+    string name = 1;
+    uint32 grpc_port = 2;
+}
+message KeepConnectedResponse {
+}
-- 
cgit v1.2.3


From dfccc3c2637693dce141c27a321ba5d3aea1ace9 Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Fri, 8 May 2020 02:47:22 -0700
Subject: able to read chan and write chan

---
 other/java/client/src/main/proto/filer.proto | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

(limited to 'other/java')

diff --git a/other/java/client/src/main/proto/filer.proto b/other/java/client/src/main/proto/filer.proto
index 3b3b78bbb..1fc8ef63d 100644
--- a/other/java/client/src/main/proto/filer.proto
+++ b/other/java/client/src/main/proto/filer.proto
@@ -50,6 +50,10 @@ service SeaweedFiler {
 
     rpc KeepConnected (stream KeepConnectedRequest) returns (stream KeepConnectedResponse) {
     }
+
+    rpc LocateBroker (LocateBrokerRequest) returns (LocateBrokerResponse) {
+    }
+
 }
 
 //////////////////////////////////////////////////
@@ -267,6 +271,21 @@ message LogEntry {
 message KeepConnectedRequest {
     string name = 1;
     uint32 grpc_port = 2;
+    repeated string resources = 3;
 }
 message KeepConnectedResponse {
 }
+
+message LocateBrokerRequest {
+    string resource = 1;
+}
+message LocateBrokerResponse {
+    bool found = 1;
+    // if found, send the exact address
+    // if not found, send the full list of existing brokers
+    message Resource {
+        string grpc_addresses = 1;
+        int32 resource_count = 2;
+    }
+    repeated Resource resources = 2;
+}
-- 
cgit v1.2.3