Add service definitions in the log proto.

This commit is contained in:
Mariano Uvalle 2021-08-09 13:49:36 -05:00
parent 298bfaceee
commit 2b743da453

View file

@ -8,3 +8,26 @@ message Record {
bytes value = 1;
uint64 offset = 2;
}
service Log {
rpc Produce(ProduceRequest) returns (ProduceResponse) {}
rpc Consume(ConsumeRequest) returns (ConsumeResponse) {}
rpc ProduceStream(stream ProduceRequest) returns (stream ProduceResponse) {}
rpc ConsumeStream(ConsumeRequest) returns (stream ConsumeResponse) {}
}
message ProduceRequest {
Record record = 1;
}
message ProduceResponse {
uint64 offset = 1;
}
message ConsumeRequest {
uint64 offset = 1;
}
message ConsumeResponse {
Record record = 1;
}