diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-30 01:19:33 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-30 01:19:33 -0700 |
| commit | 50a5018b7fb259cee84471ce8d7bb6e554602c61 (patch) | |
| tree | 9c90e316fe1b7b06e3c0319a8723b85b84518a95 /other/java | |
| parent | 9dc0b1df8f3bb19ce01b2d520436dbdc0f2a883e (diff) | |
| download | seaweedfs-50a5018b7fb259cee84471ce8d7bb6e554602c61.tar.xz seaweedfs-50a5018b7fb259cee84471ce8d7bb6e554602c61.zip | |
writing meta logs is working
Diffstat (limited to 'other/java')
| -rw-r--r-- | other/java/client/src/main/proto/filer.proto | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/other/java/client/src/main/proto/filer.proto b/other/java/client/src/main/proto/filer.proto index b998c330c..3975b517d 100644 --- a/other/java/client/src/main/proto/filer.proto +++ b/other/java/client/src/main/proto/filer.proto @@ -42,6 +42,9 @@ service SeaweedFiler { rpc GetFilerConfiguration (GetFilerConfigurationRequest) returns (GetFilerConfigurationResponse) { } + rpc ListenForEvents (ListenForEventsRequest) returns (stream FullEventNotification) { + } + } ////////////////////////////////////////////////// @@ -230,3 +233,19 @@ message GetFilerConfigurationResponse { string dir_queues = 6; bool cipher = 7; } + +message ListenForEventsRequest { + string client_name = 1; + string directory = 2; + int64 since_sec = 3; +} +message FullEventNotification { + string directory = 1; + EventNotification event_notification = 2; +} + +message LogEntry { + int64 ts_ns = 1; + int32 partition_key_hash = 2; + bytes data = 3; +} |
