diff --git a/api/v1/log.proto b/api/v1/log.proto index 40e80dd..2cefd6f 100644 --- a/api/v1/log.proto +++ b/api/v1/log.proto @@ -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; +}