aboutsummaryrefslogtreecommitdiff
path: root/other/java
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-08-28 23:48:48 -0700
committerChris Lu <chris.lu@gmail.com>2020-08-28 23:48:48 -0700
commitca658a97c5248ba099356b006f0b341af53b0816 (patch)
tree8b59defed9a417c4fa2e9346a23cd8a64e851852 /other/java
parent63ad1abccec691d2204b8dc63109ffeead0b0eed (diff)
downloadseaweedfs-ca658a97c5248ba099356b006f0b341af53b0816.tar.xz
seaweedfs-ca658a97c5248ba099356b006f0b341af53b0816.zip
add signatures to messages to avoid double processing
Diffstat (limited to 'other/java')
-rw-r--r--other/java/client/src/main/proto/filer.proto5
1 files changed, 5 insertions, 0 deletions
diff --git a/other/java/client/src/main/proto/filer.proto b/other/java/client/src/main/proto/filer.proto
index dcc18f2a5..65947e674 100644
--- a/other/java/client/src/main/proto/filer.proto
+++ b/other/java/client/src/main/proto/filer.proto
@@ -102,6 +102,7 @@ message EventNotification {
bool delete_chunks = 3;
string new_parent_path = 4;
bool is_from_other_cluster = 5;
+ repeated int32 signatures = 6;
}
message FileChunk {
@@ -150,6 +151,7 @@ message CreateEntryRequest {
Entry entry = 2;
bool o_excl = 3;
bool is_from_other_cluster = 4;
+ repeated int32 signatures = 5;
}
message CreateEntryResponse {
@@ -160,6 +162,7 @@ message UpdateEntryRequest {
string directory = 1;
Entry entry = 2;
bool is_from_other_cluster = 3;
+ repeated int32 signatures = 4;
}
message UpdateEntryResponse {
}
@@ -180,6 +183,7 @@ message DeleteEntryRequest {
bool is_recursive = 5;
bool ignore_recursive_error = 6;
bool is_from_other_cluster = 7;
+ repeated int32 signatures = 8;
}
message DeleteEntryResponse {
@@ -268,6 +272,7 @@ message SubscribeMetadataRequest {
string client_name = 1;
string path_prefix = 2;
int64 since_ns = 3;
+ int32 signature = 4;
}
message SubscribeMetadataResponse {
string directory = 1;