feat: add basic streaming data

Signed-off-by: kjuulh <contact@kjuulh.io>
This commit is contained in:
2024-08-15 21:07:22 +02:00
parent cce1400a34
commit 3a2a65dfa7
11 changed files with 330 additions and 76 deletions

View File

@@ -8,6 +8,7 @@ service NoDataService {
rpc PublishEvent(PublishEventRequest) returns (PublishEventResponse) {}
rpc GetTopics(GetTopicsRequest) returns (GetTopicsResponse) {}
rpc GetKeys(GetKeysRequest) returns (GetKeysResponse) {}
rpc Subscribe(SubscribeRequest) returns (stream SubscribeResponse){}
}
message PublishEventRequest {
@@ -32,3 +33,14 @@ message GetKeysRequest {
message GetKeysResponse {
repeated string keys = 1;
}
message SubscribeRequest {
string topic = 1;
string key = 2;
}
message SubscribeResponse{
string id = 1;
google.protobuf.Timestamp published = 2;
uint64 offset = 3;
bytes value = 4;
}