From 2b743da45314c816675c0d9cb1a8dde155d9ada9 Mon Sep 17 00:00:00 2001 From: AYM1607 Date: Mon, 9 Aug 2021 13:49:36 -0500 Subject: [PATCH] Add service definitions in the log proto. --- api/v1/log.proto | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) 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; +}