From bae0ff5455675a2ee6cf27208c8f850ae4e65805 Mon Sep 17 00:00:00 2001 From: w-h-a Date: Sat, 13 Jul 2024 10:40:18 -0700 Subject: [PATCH] docs: update comments --- proto/streams/streams.pb.go | 4 ++-- proto/streams/streams.proto | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/proto/streams/streams.pb.go b/proto/streams/streams.pb.go index 82b050d..e3951dd 100644 --- a/proto/streams/streams.pb.go +++ b/proto/streams/streams.pb.go @@ -320,7 +320,7 @@ func (*UnsubscribeResponse) Descriptor() ([]byte, []int) { return file_proto_streams_streams_proto_rawDescGZIP(), []int{4} } -// consume request (stream Event response) +// consume request type ConsumeRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -368,7 +368,7 @@ func (x *ConsumeRequest) GetId() string { return "" } -// ack request (no response) +// ack request type AckRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache diff --git a/proto/streams/streams.proto b/proto/streams/streams.proto index d9fac99..6e9df77 100644 --- a/proto/streams/streams.proto +++ b/proto/streams/streams.proto @@ -33,12 +33,12 @@ message UnsubscribeRequest { message UnsubscribeResponse {} -// consume request (stream Event response) +// consume request message ConsumeRequest { string id = 1; } -// ack request (no response) +// ack request message AckRequest { string id = 1; bool success = 2;