From 8d764498844170b0752f17903fc587a32c877168 Mon Sep 17 00:00:00 2001 From: Zbynek Roubalik Date: Tue, 12 Oct 2021 13:32:49 +0200 Subject: [PATCH 1/2] update liiklus protobuf generation Signed-off-by: Zbynek Roubalik --- Makefile | 2 +- hack/LiiklusService.proto | 2 +- pkg/scalers/liiklus/LiiklusService.pb.go | 1787 +++++++++-------- pkg/scalers/liiklus/LiiklusService_grpc.pb.go | 408 ++++ 4 files changed, 1382 insertions(+), 817 deletions(-) create mode 100644 pkg/scalers/liiklus/LiiklusService_grpc.pb.go diff --git a/Makefile b/Makefile index 5088bff4090..8fc105384ef 100644 --- a/Makefile +++ b/Makefile @@ -121,7 +121,7 @@ clientset-generate: ## Generate client-go clientset, listers and informers. # Generate Liiklus proto pkg/scalers/liiklus/LiiklusService.pb.go: hack/LiiklusService.proto - protoc -I hack/ hack/LiiklusService.proto --go_out=plugins=grpc:pkg/scalers/liiklus + protoc -I hack/ hack/LiiklusService.proto --go_out=pkg/scalers/liiklus --go-grpc_out=pkg/scalers/liiklus .PHONY: mockgen-gen mockgen-gen: mockgen pkg/mock/mock_scaling/mock_interface.go pkg/mock/mock_scaler/mock_scaler.go pkg/mock/mock_scale/mock_interfaces.go pkg/mock/mock_client/mock_interfaces.go pkg/scalers/liiklus/mocks/mock_liiklus.go diff --git a/hack/LiiklusService.proto b/hack/LiiklusService.proto index 2754abbba8a..822bc9ce34d 100644 --- a/hack/LiiklusService.proto +++ b/hack/LiiklusService.proto @@ -9,7 +9,7 @@ option java_package = "com.github.bsideup.liiklus.protocol"; option optimize_for = SPEED; option java_multiple_files = true; -option go_package = "liiklus"; +option go_package = "./;liiklus"; service LiiklusService { rpc Publish (PublishRequest) returns (PublishReply) { diff --git a/pkg/scalers/liiklus/LiiklusService.pb.go b/pkg/scalers/liiklus/LiiklusService.pb.go index 4afb5ceb315..ba0eebf525d 100644 --- a/pkg/scalers/liiklus/LiiklusService.pb.go +++ b/pkg/scalers/liiklus/LiiklusService.pb.go @@ -1,28 +1,26 @@ // Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.27.1 +// protoc v3.17.3 // source: LiiklusService.proto package liiklus import ( - context "context" - fmt "fmt" - proto "github.com/golang/protobuf/proto" - empty "github.com/golang/protobuf/ptypes/empty" - timestamp "github.com/golang/protobuf/ptypes/timestamp" - grpc "google.golang.org/grpc" - math "math" + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + emptypb "google.golang.org/protobuf/types/known/emptypb" + timestamppb "google.golang.org/protobuf/types/known/timestamppb" + reflect "reflect" + sync "sync" ) -// Reference imports to suppress errors if they are not otherwise used. -var _ = proto.Marshal -var _ = fmt.Errorf -var _ = math.Inf - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the proto package it is being compiled against. -// A compilation error at this line likely means your copy of the -// proto package needs to be updated. -const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) type SubscribeRequest_AutoOffsetReset int32 @@ -31,288 +29,339 @@ const ( SubscribeRequest_LATEST SubscribeRequest_AutoOffsetReset = 1 ) -var SubscribeRequest_AutoOffsetReset_name = map[int32]string{ - 0: "EARLIEST", - 1: "LATEST", -} +// Enum value maps for SubscribeRequest_AutoOffsetReset. +var ( + SubscribeRequest_AutoOffsetReset_name = map[int32]string{ + 0: "EARLIEST", + 1: "LATEST", + } + SubscribeRequest_AutoOffsetReset_value = map[string]int32{ + "EARLIEST": 0, + "LATEST": 1, + } +) -var SubscribeRequest_AutoOffsetReset_value = map[string]int32{ - "EARLIEST": 0, - "LATEST": 1, +func (x SubscribeRequest_AutoOffsetReset) Enum() *SubscribeRequest_AutoOffsetReset { + p := new(SubscribeRequest_AutoOffsetReset) + *p = x + return p } func (x SubscribeRequest_AutoOffsetReset) String() string { - return proto.EnumName(SubscribeRequest_AutoOffsetReset_name, int32(x)) + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } -func (SubscribeRequest_AutoOffsetReset) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{2, 0} +func (SubscribeRequest_AutoOffsetReset) Descriptor() protoreflect.EnumDescriptor { + return file_LiiklusService_proto_enumTypes[0].Descriptor() } -type PublishRequest struct { - Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` - Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` - Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` +func (SubscribeRequest_AutoOffsetReset) Type() protoreflect.EnumType { + return &file_LiiklusService_proto_enumTypes[0] } -func (m *PublishRequest) Reset() { *m = PublishRequest{} } -func (m *PublishRequest) String() string { return proto.CompactTextString(m) } -func (*PublishRequest) ProtoMessage() {} -func (*PublishRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{0} +func (x SubscribeRequest_AutoOffsetReset) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) } -func (m *PublishRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_PublishRequest.Unmarshal(m, b) +// Deprecated: Use SubscribeRequest_AutoOffsetReset.Descriptor instead. +func (SubscribeRequest_AutoOffsetReset) EnumDescriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{2, 0} } -func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_PublishRequest.Marshal(b, m, deterministic) + +type PublishRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` + Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` + Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` } -func (m *PublishRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_PublishRequest.Merge(m, src) + +func (x *PublishRequest) Reset() { + *x = PublishRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *PublishRequest) XXX_Size() int { - return xxx_messageInfo_PublishRequest.Size(m) + +func (x *PublishRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *PublishRequest) XXX_DiscardUnknown() { - xxx_messageInfo_PublishRequest.DiscardUnknown(m) + +func (*PublishRequest) ProtoMessage() {} + +func (x *PublishRequest) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_PublishRequest proto.InternalMessageInfo +// Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead. +func (*PublishRequest) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{0} +} -func (m *PublishRequest) GetTopic() string { - if m != nil { - return m.Topic +func (x *PublishRequest) GetTopic() string { + if x != nil { + return x.Topic } return "" } -func (m *PublishRequest) GetKey() []byte { - if m != nil { - return m.Key +func (x *PublishRequest) GetKey() []byte { + if x != nil { + return x.Key } return nil } -func (m *PublishRequest) GetValue() []byte { - if m != nil { - return m.Value +func (x *PublishRequest) GetValue() []byte { + if x != nil { + return x.Value } return nil } type PublishReply struct { - Partition uint32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"` - Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` - Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *PublishReply) Reset() { *m = PublishReply{} } -func (m *PublishReply) String() string { return proto.CompactTextString(m) } -func (*PublishReply) ProtoMessage() {} -func (*PublishReply) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{1} + Partition uint32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"` + Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` + Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` } -func (m *PublishReply) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_PublishReply.Unmarshal(m, b) -} -func (m *PublishReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_PublishReply.Marshal(b, m, deterministic) -} -func (m *PublishReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_PublishReply.Merge(m, src) +func (x *PublishReply) Reset() { + *x = PublishReply{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *PublishReply) XXX_Size() int { - return xxx_messageInfo_PublishReply.Size(m) + +func (x *PublishReply) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *PublishReply) XXX_DiscardUnknown() { - xxx_messageInfo_PublishReply.DiscardUnknown(m) + +func (*PublishReply) ProtoMessage() {} + +func (x *PublishReply) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_PublishReply proto.InternalMessageInfo +// Deprecated: Use PublishReply.ProtoReflect.Descriptor instead. +func (*PublishReply) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{1} +} -func (m *PublishReply) GetPartition() uint32 { - if m != nil { - return m.Partition +func (x *PublishReply) GetPartition() uint32 { + if x != nil { + return x.Partition } return 0 } -func (m *PublishReply) GetOffset() uint64 { - if m != nil { - return m.Offset +func (x *PublishReply) GetOffset() uint64 { + if x != nil { + return x.Offset } return 0 } -func (m *PublishReply) GetTopic() string { - if m != nil { - return m.Topic +func (x *PublishReply) GetTopic() string { + if x != nil { + return x.Topic } return "" } type SubscribeRequest struct { - Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` - Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` - GroupVersion uint32 `protobuf:"varint,4,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` - AutoOffsetReset SubscribeRequest_AutoOffsetReset `protobuf:"varint,3,opt,name=autoOffsetReset,proto3,enum=com.github.bsideup.liiklus.SubscribeRequest_AutoOffsetReset" json:"autoOffsetReset,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *SubscribeRequest) Reset() { *m = SubscribeRequest{} } -func (m *SubscribeRequest) String() string { return proto.CompactTextString(m) } -func (*SubscribeRequest) ProtoMessage() {} -func (*SubscribeRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{2} -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_SubscribeRequest.Unmarshal(m, b) + Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` + Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` + GroupVersion uint32 `protobuf:"varint,4,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` + AutoOffsetReset SubscribeRequest_AutoOffsetReset `protobuf:"varint,3,opt,name=autoOffsetReset,proto3,enum=com.github.bsideup.liiklus.SubscribeRequest_AutoOffsetReset" json:"autoOffsetReset,omitempty"` } -func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_SubscribeRequest.Marshal(b, m, deterministic) -} -func (m *SubscribeRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_SubscribeRequest.Merge(m, src) + +func (x *SubscribeRequest) Reset() { + *x = SubscribeRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *SubscribeRequest) XXX_Size() int { - return xxx_messageInfo_SubscribeRequest.Size(m) + +func (x *SubscribeRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *SubscribeRequest) XXX_DiscardUnknown() { - xxx_messageInfo_SubscribeRequest.DiscardUnknown(m) + +func (*SubscribeRequest) ProtoMessage() {} + +func (x *SubscribeRequest) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_SubscribeRequest proto.InternalMessageInfo +// Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead. +func (*SubscribeRequest) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{2} +} -func (m *SubscribeRequest) GetTopic() string { - if m != nil { - return m.Topic +func (x *SubscribeRequest) GetTopic() string { + if x != nil { + return x.Topic } return "" } -func (m *SubscribeRequest) GetGroup() string { - if m != nil { - return m.Group +func (x *SubscribeRequest) GetGroup() string { + if x != nil { + return x.Group } return "" } -func (m *SubscribeRequest) GetGroupVersion() uint32 { - if m != nil { - return m.GroupVersion +func (x *SubscribeRequest) GetGroupVersion() uint32 { + if x != nil { + return x.GroupVersion } return 0 } -func (m *SubscribeRequest) GetAutoOffsetReset() SubscribeRequest_AutoOffsetReset { - if m != nil { - return m.AutoOffsetReset +func (x *SubscribeRequest) GetAutoOffsetReset() SubscribeRequest_AutoOffsetReset { + if x != nil { + return x.AutoOffsetReset } return SubscribeRequest_EARLIEST } type Assignment struct { - SessionId string `protobuf:"bytes,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` - Partition uint32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *Assignment) Reset() { *m = Assignment{} } -func (m *Assignment) String() string { return proto.CompactTextString(m) } -func (*Assignment) ProtoMessage() {} -func (*Assignment) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{3} + SessionId string `protobuf:"bytes,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` + Partition uint32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` } -func (m *Assignment) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_Assignment.Unmarshal(m, b) -} -func (m *Assignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_Assignment.Marshal(b, m, deterministic) -} -func (m *Assignment) XXX_Merge(src proto.Message) { - xxx_messageInfo_Assignment.Merge(m, src) +func (x *Assignment) Reset() { + *x = Assignment{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *Assignment) XXX_Size() int { - return xxx_messageInfo_Assignment.Size(m) + +func (x *Assignment) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *Assignment) XXX_DiscardUnknown() { - xxx_messageInfo_Assignment.DiscardUnknown(m) + +func (*Assignment) ProtoMessage() {} + +func (x *Assignment) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_Assignment proto.InternalMessageInfo +// Deprecated: Use Assignment.ProtoReflect.Descriptor instead. +func (*Assignment) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{3} +} -func (m *Assignment) GetSessionId() string { - if m != nil { - return m.SessionId +func (x *Assignment) GetSessionId() string { + if x != nil { + return x.SessionId } return "" } -func (m *Assignment) GetPartition() uint32 { - if m != nil { - return m.Partition +func (x *Assignment) GetPartition() uint32 { + if x != nil { + return x.Partition } return 0 } type SubscribeReply struct { - // Types that are valid to be assigned to Reply: + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // Types that are assignable to Reply: // *SubscribeReply_Assignment - Reply isSubscribeReply_Reply `protobuf_oneof:"reply"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + Reply isSubscribeReply_Reply `protobuf_oneof:"reply"` } -func (m *SubscribeReply) Reset() { *m = SubscribeReply{} } -func (m *SubscribeReply) String() string { return proto.CompactTextString(m) } -func (*SubscribeReply) ProtoMessage() {} -func (*SubscribeReply) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{4} +func (x *SubscribeReply) Reset() { + *x = SubscribeReply{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *SubscribeReply) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_SubscribeReply.Unmarshal(m, b) -} -func (m *SubscribeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_SubscribeReply.Marshal(b, m, deterministic) -} -func (m *SubscribeReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_SubscribeReply.Merge(m, src) -} -func (m *SubscribeReply) XXX_Size() int { - return xxx_messageInfo_SubscribeReply.Size(m) -} -func (m *SubscribeReply) XXX_DiscardUnknown() { - xxx_messageInfo_SubscribeReply.DiscardUnknown(m) +func (x *SubscribeReply) String() string { + return protoimpl.X.MessageStringOf(x) } -var xxx_messageInfo_SubscribeReply proto.InternalMessageInfo +func (*SubscribeReply) ProtoMessage() {} -type isSubscribeReply_Reply interface { - isSubscribeReply_Reply() +func (x *SubscribeReply) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[4] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -type SubscribeReply_Assignment struct { - Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3,oneof"` +// Deprecated: Use SubscribeReply.ProtoReflect.Descriptor instead. +func (*SubscribeReply) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{4} } -func (*SubscribeReply_Assignment) isSubscribeReply_Reply() {} - func (m *SubscribeReply) GetReply() isSubscribeReply_Reply { if m != nil { return m.Reply @@ -320,191 +369,209 @@ func (m *SubscribeReply) GetReply() isSubscribeReply_Reply { return nil } -func (m *SubscribeReply) GetAssignment() *Assignment { - if x, ok := m.GetReply().(*SubscribeReply_Assignment); ok { +func (x *SubscribeReply) GetAssignment() *Assignment { + if x, ok := x.GetReply().(*SubscribeReply_Assignment); ok { return x.Assignment } return nil } -// XXX_OneofWrappers is for the internal use of the proto package. -func (*SubscribeReply) XXX_OneofWrappers() []interface{} { - return []interface{}{ - (*SubscribeReply_Assignment)(nil), - } +type isSubscribeReply_Reply interface { + isSubscribeReply_Reply() } -type AckRequest struct { - Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"` // Deprecated: Do not use. - Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` - Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` - GroupVersion uint32 `protobuf:"varint,5,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` - Partition uint32 `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"` - Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *AckRequest) Reset() { *m = AckRequest{} } -func (m *AckRequest) String() string { return proto.CompactTextString(m) } -func (*AckRequest) ProtoMessage() {} -func (*AckRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{5} +type SubscribeReply_Assignment struct { + Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3,oneof"` } -func (m *AckRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_AckRequest.Unmarshal(m, b) -} -func (m *AckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_AckRequest.Marshal(b, m, deterministic) +func (*SubscribeReply_Assignment) isSubscribeReply_Reply() {} + +type AckRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // Deprecated: Do not use. + Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"` + Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` + Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` + GroupVersion uint32 `protobuf:"varint,5,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` + Partition uint32 `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"` + Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` } -func (m *AckRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_AckRequest.Merge(m, src) + +func (x *AckRequest) Reset() { + *x = AckRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *AckRequest) XXX_Size() int { - return xxx_messageInfo_AckRequest.Size(m) + +func (x *AckRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *AckRequest) XXX_DiscardUnknown() { - xxx_messageInfo_AckRequest.DiscardUnknown(m) + +func (*AckRequest) ProtoMessage() {} + +func (x *AckRequest) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[5] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_AckRequest proto.InternalMessageInfo +// Deprecated: Use AckRequest.ProtoReflect.Descriptor instead. +func (*AckRequest) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{5} +} // Deprecated: Do not use. -func (m *AckRequest) GetAssignment() *Assignment { - if m != nil { - return m.Assignment +func (x *AckRequest) GetAssignment() *Assignment { + if x != nil { + return x.Assignment } return nil } -func (m *AckRequest) GetTopic() string { - if m != nil { - return m.Topic +func (x *AckRequest) GetTopic() string { + if x != nil { + return x.Topic } return "" } -func (m *AckRequest) GetGroup() string { - if m != nil { - return m.Group +func (x *AckRequest) GetGroup() string { + if x != nil { + return x.Group } return "" } -func (m *AckRequest) GetGroupVersion() uint32 { - if m != nil { - return m.GroupVersion +func (x *AckRequest) GetGroupVersion() uint32 { + if x != nil { + return x.GroupVersion } return 0 } -func (m *AckRequest) GetPartition() uint32 { - if m != nil { - return m.Partition +func (x *AckRequest) GetPartition() uint32 { + if x != nil { + return x.Partition } return 0 } -func (m *AckRequest) GetOffset() uint64 { - if m != nil { - return m.Offset +func (x *AckRequest) GetOffset() uint64 { + if x != nil { + return x.Offset } return 0 } type ReceiveRequest struct { - Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"` - LastKnownOffset uint64 `protobuf:"varint,2,opt,name=lastKnownOffset,proto3" json:"lastKnownOffset,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *ReceiveRequest) Reset() { *m = ReceiveRequest{} } -func (m *ReceiveRequest) String() string { return proto.CompactTextString(m) } -func (*ReceiveRequest) ProtoMessage() {} -func (*ReceiveRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{6} + Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"` + LastKnownOffset uint64 `protobuf:"varint,2,opt,name=lastKnownOffset,proto3" json:"lastKnownOffset,omitempty"` } -func (m *ReceiveRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_ReceiveRequest.Unmarshal(m, b) -} -func (m *ReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_ReceiveRequest.Marshal(b, m, deterministic) -} -func (m *ReceiveRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_ReceiveRequest.Merge(m, src) +func (x *ReceiveRequest) Reset() { + *x = ReceiveRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *ReceiveRequest) XXX_Size() int { - return xxx_messageInfo_ReceiveRequest.Size(m) + +func (x *ReceiveRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *ReceiveRequest) XXX_DiscardUnknown() { - xxx_messageInfo_ReceiveRequest.DiscardUnknown(m) + +func (*ReceiveRequest) ProtoMessage() {} + +func (x *ReceiveRequest) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[6] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_ReceiveRequest proto.InternalMessageInfo +// Deprecated: Use ReceiveRequest.ProtoReflect.Descriptor instead. +func (*ReceiveRequest) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{6} +} -func (m *ReceiveRequest) GetAssignment() *Assignment { - if m != nil { - return m.Assignment +func (x *ReceiveRequest) GetAssignment() *Assignment { + if x != nil { + return x.Assignment } return nil } -func (m *ReceiveRequest) GetLastKnownOffset() uint64 { - if m != nil { - return m.LastKnownOffset +func (x *ReceiveRequest) GetLastKnownOffset() uint64 { + if x != nil { + return x.LastKnownOffset } return 0 } type ReceiveReply struct { - // Types that are valid to be assigned to Reply: + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // Types that are assignable to Reply: // *ReceiveReply_Record_ - Reply isReceiveReply_Reply `protobuf_oneof:"reply"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + Reply isReceiveReply_Reply `protobuf_oneof:"reply"` } -func (m *ReceiveReply) Reset() { *m = ReceiveReply{} } -func (m *ReceiveReply) String() string { return proto.CompactTextString(m) } -func (*ReceiveReply) ProtoMessage() {} -func (*ReceiveReply) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{7} +func (x *ReceiveReply) Reset() { + *x = ReceiveReply{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *ReceiveReply) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_ReceiveReply.Unmarshal(m, b) -} -func (m *ReceiveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_ReceiveReply.Marshal(b, m, deterministic) -} -func (m *ReceiveReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_ReceiveReply.Merge(m, src) -} -func (m *ReceiveReply) XXX_Size() int { - return xxx_messageInfo_ReceiveReply.Size(m) -} -func (m *ReceiveReply) XXX_DiscardUnknown() { - xxx_messageInfo_ReceiveReply.DiscardUnknown(m) +func (x *ReceiveReply) String() string { + return protoimpl.X.MessageStringOf(x) } -var xxx_messageInfo_ReceiveReply proto.InternalMessageInfo +func (*ReceiveReply) ProtoMessage() {} -type isReceiveReply_Reply interface { - isReceiveReply_Reply() +func (x *ReceiveReply) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[7] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -type ReceiveReply_Record_ struct { - Record *ReceiveReply_Record `protobuf:"bytes,1,opt,name=record,proto3,oneof"` +// Deprecated: Use ReceiveReply.ProtoReflect.Descriptor instead. +func (*ReceiveReply) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{7} } -func (*ReceiveReply_Record_) isReceiveReply_Reply() {} - func (m *ReceiveReply) GetReply() isReceiveReply_Reply { if m != nil { return m.Reply @@ -512,625 +579,715 @@ func (m *ReceiveReply) GetReply() isReceiveReply_Reply { return nil } -func (m *ReceiveReply) GetRecord() *ReceiveReply_Record { - if x, ok := m.GetReply().(*ReceiveReply_Record_); ok { +func (x *ReceiveReply) GetRecord() *ReceiveReply_Record { + if x, ok := x.GetReply().(*ReceiveReply_Record_); ok { return x.Record } return nil } -// XXX_OneofWrappers is for the internal use of the proto package. -func (*ReceiveReply) XXX_OneofWrappers() []interface{} { - return []interface{}{ - (*ReceiveReply_Record_)(nil), - } +type isReceiveReply_Reply interface { + isReceiveReply_Reply() } -type ReceiveReply_Record struct { - Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` - Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` - Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` - Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` - Replay bool `protobuf:"varint,5,opt,name=replay,proto3" json:"replay,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *ReceiveReply_Record) Reset() { *m = ReceiveReply_Record{} } -func (m *ReceiveReply_Record) String() string { return proto.CompactTextString(m) } -func (*ReceiveReply_Record) ProtoMessage() {} -func (*ReceiveReply_Record) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{7, 0} +type ReceiveReply_Record_ struct { + Record *ReceiveReply_Record `protobuf:"bytes,1,opt,name=record,proto3,oneof"` } -func (m *ReceiveReply_Record) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_ReceiveReply_Record.Unmarshal(m, b) -} -func (m *ReceiveReply_Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_ReceiveReply_Record.Marshal(b, m, deterministic) -} -func (m *ReceiveReply_Record) XXX_Merge(src proto.Message) { - xxx_messageInfo_ReceiveReply_Record.Merge(m, src) -} -func (m *ReceiveReply_Record) XXX_Size() int { - return xxx_messageInfo_ReceiveReply_Record.Size(m) -} -func (m *ReceiveReply_Record) XXX_DiscardUnknown() { - xxx_messageInfo_ReceiveReply_Record.DiscardUnknown(m) -} +func (*ReceiveReply_Record_) isReceiveReply_Reply() {} -var xxx_messageInfo_ReceiveReply_Record proto.InternalMessageInfo +type GetOffsetsRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *ReceiveReply_Record) GetOffset() uint64 { - if m != nil { - return m.Offset - } - return 0 + Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` + Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` + GroupVersion uint32 `protobuf:"varint,3,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` } -func (m *ReceiveReply_Record) GetKey() []byte { - if m != nil { - return m.Key +func (x *GetOffsetsRequest) Reset() { + *x = GetOffsetsRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } - return nil } -func (m *ReceiveReply_Record) GetValue() []byte { - if m != nil { - return m.Value - } - return nil +func (x *GetOffsetsRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *ReceiveReply_Record) GetTimestamp() *timestamp.Timestamp { - if m != nil { - return m.Timestamp - } - return nil -} +func (*GetOffsetsRequest) ProtoMessage() {} -func (m *ReceiveReply_Record) GetReplay() bool { - if m != nil { - return m.Replay +func (x *GetOffsetsRequest) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[8] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms } - return false -} - -type GetOffsetsRequest struct { - Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` - Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` - GroupVersion uint32 `protobuf:"varint,3,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + return mi.MessageOf(x) } -func (m *GetOffsetsRequest) Reset() { *m = GetOffsetsRequest{} } -func (m *GetOffsetsRequest) String() string { return proto.CompactTextString(m) } -func (*GetOffsetsRequest) ProtoMessage() {} +// Deprecated: Use GetOffsetsRequest.ProtoReflect.Descriptor instead. func (*GetOffsetsRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{8} + return file_LiiklusService_proto_rawDescGZIP(), []int{8} } -func (m *GetOffsetsRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_GetOffsetsRequest.Unmarshal(m, b) -} -func (m *GetOffsetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_GetOffsetsRequest.Marshal(b, m, deterministic) -} -func (m *GetOffsetsRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_GetOffsetsRequest.Merge(m, src) -} -func (m *GetOffsetsRequest) XXX_Size() int { - return xxx_messageInfo_GetOffsetsRequest.Size(m) -} -func (m *GetOffsetsRequest) XXX_DiscardUnknown() { - xxx_messageInfo_GetOffsetsRequest.DiscardUnknown(m) -} - -var xxx_messageInfo_GetOffsetsRequest proto.InternalMessageInfo - -func (m *GetOffsetsRequest) GetTopic() string { - if m != nil { - return m.Topic +func (x *GetOffsetsRequest) GetTopic() string { + if x != nil { + return x.Topic } return "" } -func (m *GetOffsetsRequest) GetGroup() string { - if m != nil { - return m.Group +func (x *GetOffsetsRequest) GetGroup() string { + if x != nil { + return x.Group } return "" } -func (m *GetOffsetsRequest) GetGroupVersion() uint32 { - if m != nil { - return m.GroupVersion +func (x *GetOffsetsRequest) GetGroupVersion() uint32 { + if x != nil { + return x.GroupVersion } return 0 } type GetOffsetsReply struct { - Offsets map[uint32]uint64 `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *GetOffsetsReply) Reset() { *m = GetOffsetsReply{} } -func (m *GetOffsetsReply) String() string { return proto.CompactTextString(m) } -func (*GetOffsetsReply) ProtoMessage() {} -func (*GetOffsetsReply) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{9} -} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *GetOffsetsReply) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_GetOffsetsReply.Unmarshal(m, b) -} -func (m *GetOffsetsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_GetOffsetsReply.Marshal(b, m, deterministic) -} -func (m *GetOffsetsReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_GetOffsetsReply.Merge(m, src) + Offsets map[uint32]uint64 `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` } -func (m *GetOffsetsReply) XXX_Size() int { - return xxx_messageInfo_GetOffsetsReply.Size(m) -} -func (m *GetOffsetsReply) XXX_DiscardUnknown() { - xxx_messageInfo_GetOffsetsReply.DiscardUnknown(m) -} - -var xxx_messageInfo_GetOffsetsReply proto.InternalMessageInfo -func (m *GetOffsetsReply) GetOffsets() map[uint32]uint64 { - if m != nil { - return m.Offsets +func (x *GetOffsetsReply) Reset() { + *x = GetOffsetsReply{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } - return nil } -type GetEndOffsetsRequest struct { - Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` +func (x *GetOffsetsReply) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *GetEndOffsetsRequest) Reset() { *m = GetEndOffsetsRequest{} } -func (m *GetEndOffsetsRequest) String() string { return proto.CompactTextString(m) } -func (*GetEndOffsetsRequest) ProtoMessage() {} -func (*GetEndOffsetsRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{10} -} +func (*GetOffsetsReply) ProtoMessage() {} -func (m *GetEndOffsetsRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_GetEndOffsetsRequest.Unmarshal(m, b) -} -func (m *GetEndOffsetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_GetEndOffsetsRequest.Marshal(b, m, deterministic) -} -func (m *GetEndOffsetsRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_GetEndOffsetsRequest.Merge(m, src) -} -func (m *GetEndOffsetsRequest) XXX_Size() int { - return xxx_messageInfo_GetEndOffsetsRequest.Size(m) -} -func (m *GetEndOffsetsRequest) XXX_DiscardUnknown() { - xxx_messageInfo_GetEndOffsetsRequest.DiscardUnknown(m) +func (x *GetOffsetsReply) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[9] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_GetEndOffsetsRequest proto.InternalMessageInfo +// Deprecated: Use GetOffsetsReply.ProtoReflect.Descriptor instead. +func (*GetOffsetsReply) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{9} +} -func (m *GetEndOffsetsRequest) GetTopic() string { - if m != nil { - return m.Topic +func (x *GetOffsetsReply) GetOffsets() map[uint32]uint64 { + if x != nil { + return x.Offsets } - return "" + return nil } -type GetEndOffsetsReply struct { - Offsets map[uint32]uint64 `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} +type GetEndOffsetsRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (m *GetEndOffsetsReply) Reset() { *m = GetEndOffsetsReply{} } -func (m *GetEndOffsetsReply) String() string { return proto.CompactTextString(m) } -func (*GetEndOffsetsReply) ProtoMessage() {} -func (*GetEndOffsetsReply) Descriptor() ([]byte, []int) { - return fileDescriptor_e2e285182f4dc03a, []int{11} + Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` } -func (m *GetEndOffsetsReply) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_GetEndOffsetsReply.Unmarshal(m, b) -} -func (m *GetEndOffsetsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_GetEndOffsetsReply.Marshal(b, m, deterministic) -} -func (m *GetEndOffsetsReply) XXX_Merge(src proto.Message) { - xxx_messageInfo_GetEndOffsetsReply.Merge(m, src) -} -func (m *GetEndOffsetsReply) XXX_Size() int { - return xxx_messageInfo_GetEndOffsetsReply.Size(m) +func (x *GetEndOffsetsRequest) Reset() { + *x = GetEndOffsetsRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *GetEndOffsetsReply) XXX_DiscardUnknown() { - xxx_messageInfo_GetEndOffsetsReply.DiscardUnknown(m) + +func (x *GetEndOffsetsRequest) String() string { + return protoimpl.X.MessageStringOf(x) } -var xxx_messageInfo_GetEndOffsetsReply proto.InternalMessageInfo +func (*GetEndOffsetsRequest) ProtoMessage() {} -func (m *GetEndOffsetsReply) GetOffsets() map[uint32]uint64 { - if m != nil { - return m.Offsets +func (x *GetEndOffsetsRequest) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[10] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms } - return nil + return mi.MessageOf(x) } -func init() { - proto.RegisterEnum("com.github.bsideup.liiklus.SubscribeRequest_AutoOffsetReset", SubscribeRequest_AutoOffsetReset_name, SubscribeRequest_AutoOffsetReset_value) - proto.RegisterType((*PublishRequest)(nil), "com.github.bsideup.liiklus.PublishRequest") - proto.RegisterType((*PublishReply)(nil), "com.github.bsideup.liiklus.PublishReply") - proto.RegisterType((*SubscribeRequest)(nil), "com.github.bsideup.liiklus.SubscribeRequest") - proto.RegisterType((*Assignment)(nil), "com.github.bsideup.liiklus.Assignment") - proto.RegisterType((*SubscribeReply)(nil), "com.github.bsideup.liiklus.SubscribeReply") - proto.RegisterType((*AckRequest)(nil), "com.github.bsideup.liiklus.AckRequest") - proto.RegisterType((*ReceiveRequest)(nil), "com.github.bsideup.liiklus.ReceiveRequest") - proto.RegisterType((*ReceiveReply)(nil), "com.github.bsideup.liiklus.ReceiveReply") - proto.RegisterType((*ReceiveReply_Record)(nil), "com.github.bsideup.liiklus.ReceiveReply.Record") - proto.RegisterType((*GetOffsetsRequest)(nil), "com.github.bsideup.liiklus.GetOffsetsRequest") - proto.RegisterType((*GetOffsetsReply)(nil), "com.github.bsideup.liiklus.GetOffsetsReply") - proto.RegisterMapType((map[uint32]uint64)(nil), "com.github.bsideup.liiklus.GetOffsetsReply.OffsetsEntry") - proto.RegisterType((*GetEndOffsetsRequest)(nil), "com.github.bsideup.liiklus.GetEndOffsetsRequest") - proto.RegisterType((*GetEndOffsetsReply)(nil), "com.github.bsideup.liiklus.GetEndOffsetsReply") - proto.RegisterMapType((map[uint32]uint64)(nil), "com.github.bsideup.liiklus.GetEndOffsetsReply.OffsetsEntry") -} - -func init() { proto.RegisterFile("LiiklusService.proto", fileDescriptor_e2e285182f4dc03a) } - -var fileDescriptor_e2e285182f4dc03a = []byte{ - // 778 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xcd, 0x4e, 0x1b, 0x49, - 0x10, 0x76, 0xfb, 0x17, 0x17, 0xc6, 0x66, 0x5b, 0x16, 0xb2, 0x66, 0x57, 0x5a, 0xd4, 0x2b, 0xad, - 0x2c, 0x60, 0x07, 0xe4, 0xbd, 0x20, 0x76, 0x2f, 0x46, 0xf2, 0x62, 0x36, 0x28, 0xa0, 0x86, 0xe4, - 0xc0, 0x6d, 0x3c, 0x6e, 0x9b, 0x89, 0xc7, 0x9e, 0xc9, 0x74, 0x0f, 0x91, 0xaf, 0x79, 0x8c, 0xdc, - 0x72, 0xca, 0x5b, 0xe5, 0x0d, 0x72, 0xce, 0x31, 0x51, 0x4f, 0x8f, 0x3d, 0x3f, 0x90, 0x89, 0x8d, - 0xb8, 0x4d, 0x95, 0xab, 0xab, 0xbe, 0xfa, 0xea, 0xeb, 0x6a, 0x43, 0xf3, 0xc2, 0xb2, 0x26, 0xb6, - 0xcf, 0xaf, 0x99, 0x77, 0x6f, 0x99, 0x4c, 0x77, 0x3d, 0x47, 0x38, 0x58, 0x33, 0x9d, 0xa9, 0x3e, - 0xb6, 0xc4, 0x9d, 0x3f, 0xd0, 0x07, 0xdc, 0x1a, 0x32, 0xdf, 0xd5, 0x6d, 0x15, 0xa8, 0xfd, 0x3e, - 0x76, 0x9c, 0xb1, 0xcd, 0x0e, 0x83, 0xc8, 0x81, 0x3f, 0x3a, 0x14, 0xd6, 0x94, 0x71, 0x61, 0x4c, - 0x5d, 0x75, 0x58, 0xfb, 0x35, 0x1d, 0xc0, 0xa6, 0xae, 0x98, 0xab, 0x1f, 0xc9, 0x4b, 0xa8, 0x5f, - 0xf9, 0x03, 0xdb, 0xe2, 0x77, 0x94, 0xbd, 0xf5, 0x19, 0x17, 0xb8, 0x09, 0x25, 0xe1, 0xb8, 0x96, - 0xd9, 0x42, 0xbb, 0xa8, 0x5d, 0xa5, 0xca, 0xc0, 0xdb, 0x50, 0x98, 0xb0, 0x79, 0x2b, 0xbf, 0x8b, - 0xda, 0x35, 0x2a, 0x3f, 0x65, 0xdc, 0xbd, 0x61, 0xfb, 0xac, 0x55, 0x08, 0x7c, 0xca, 0x20, 0xb7, - 0x50, 0x5b, 0xe6, 0x73, 0xed, 0x39, 0xfe, 0x0d, 0xaa, 0xae, 0xe1, 0x09, 0x4b, 0x58, 0xce, 0x2c, - 0xc8, 0xb8, 0x45, 0x23, 0x07, 0xde, 0x81, 0xb2, 0x33, 0x1a, 0x71, 0x26, 0x82, 0xc4, 0x45, 0x1a, - 0x5a, 0x11, 0x86, 0x42, 0x0c, 0x03, 0xf9, 0x8a, 0x60, 0xfb, 0xda, 0x1f, 0x70, 0xd3, 0xb3, 0x06, - 0x2c, 0x1b, 0x6e, 0x13, 0x4a, 0x63, 0xcf, 0xf1, 0xdd, 0x20, 0x6f, 0x95, 0x2a, 0x03, 0x13, 0xa8, - 0x05, 0x1f, 0xaf, 0x99, 0xc7, 0x25, 0x9e, 0x62, 0x80, 0x27, 0xe1, 0xc3, 0x23, 0x68, 0x18, 0xbe, - 0x70, 0x2e, 0x03, 0x20, 0x94, 0x49, 0x6c, 0x12, 0x44, 0xbd, 0xf3, 0xaf, 0xfe, 0xe3, 0x21, 0xe8, - 0x69, 0x58, 0x7a, 0x37, 0x99, 0x83, 0xa6, 0x93, 0x92, 0x7d, 0x68, 0xa4, 0x62, 0x70, 0x0d, 0x36, - 0x7a, 0x5d, 0x7a, 0x71, 0xde, 0xbb, 0xbe, 0xd9, 0xce, 0x61, 0x80, 0xf2, 0x45, 0xf7, 0x46, 0x7e, - 0x23, 0xd2, 0x07, 0xe8, 0x72, 0x6e, 0x8d, 0x67, 0x53, 0x36, 0x13, 0x92, 0x53, 0xce, 0xb8, 0x44, - 0x7b, 0x3e, 0x0c, 0xdb, 0x8e, 0x1c, 0x49, 0xc6, 0xf3, 0x29, 0xc6, 0x89, 0x09, 0xf5, 0x18, 0x56, - 0x39, 0xa1, 0x3e, 0x80, 0xb1, 0xcc, 0x1d, 0xa4, 0xdb, 0xec, 0xfc, 0x99, 0xd5, 0x6b, 0x84, 0xa4, - 0x9f, 0xa3, 0xb1, 0xb3, 0xa7, 0x15, 0x28, 0x79, 0x32, 0x25, 0xf9, 0x8c, 0x00, 0xba, 0xe6, 0x64, - 0x31, 0xa2, 0xff, 0x9f, 0x5e, 0xe1, 0x34, 0xdf, 0x42, 0xf1, 0x1a, 0x8f, 0x2b, 0x23, 0x1a, 0x77, - 0x31, 0x6b, 0xdc, 0xa5, 0x47, 0xc6, 0x9d, 0x60, 0xab, 0xbc, 0xa2, 0x3e, 0xc9, 0x7b, 0x04, 0x75, - 0xca, 0x4c, 0x66, 0xdd, 0x2f, 0x75, 0xf8, 0xdf, 0xd3, 0x9b, 0x4c, 0x34, 0xd8, 0x86, 0x86, 0x6d, - 0x70, 0xf1, 0x62, 0xe6, 0xbc, 0x9b, 0x5d, 0xc6, 0x6b, 0xa7, 0xdd, 0xe4, 0x1b, 0x82, 0xda, 0x12, - 0x84, 0x9c, 0xe4, 0x39, 0x94, 0x3d, 0x66, 0x3a, 0xde, 0x30, 0x2c, 0x7f, 0x98, 0x55, 0x3e, 0x7e, - 0x52, 0x1a, 0x8e, 0x37, 0xec, 0xe7, 0x68, 0x98, 0x40, 0xfb, 0x80, 0xa0, 0xac, 0x9c, 0x31, 0x0e, - 0x50, 0xe2, 0x8e, 0xae, 0xb8, 0x11, 0xf0, 0x31, 0x54, 0x97, 0x1b, 0x29, 0x98, 0xcf, 0x66, 0x47, - 0xd3, 0xd5, 0x4a, 0xd2, 0x17, 0x2b, 0x49, 0xbf, 0x59, 0x44, 0xd0, 0x28, 0x58, 0x56, 0x96, 0x7a, - 0x32, 0xe6, 0xc1, 0xe4, 0x36, 0x68, 0x68, 0x45, 0x3a, 0x33, 0xe1, 0x97, 0x33, 0x26, 0x14, 0x1d, - 0xfc, 0x39, 0x16, 0x42, 0xe1, 0xa1, 0x42, 0xc8, 0x47, 0x04, 0x8d, 0x78, 0x15, 0xc9, 0x34, 0x85, - 0x8a, 0x62, 0x81, 0xb7, 0xd0, 0x6e, 0xa1, 0xbd, 0xd9, 0x39, 0xce, 0xa2, 0x3a, 0x75, 0x5a, 0x0f, - 0x8d, 0xde, 0x4c, 0x78, 0x73, 0xba, 0x48, 0xa4, 0x9d, 0x40, 0x2d, 0xfe, 0xc3, 0x82, 0x5f, 0xb5, - 0x33, 0x93, 0xfc, 0x2a, 0x41, 0x28, 0xe3, 0x24, 0x7f, 0x8c, 0xc8, 0x01, 0x34, 0xcf, 0x98, 0xe8, - 0xcd, 0x86, 0xab, 0x70, 0x41, 0x3e, 0x21, 0xc0, 0xa9, 0x70, 0xd9, 0xd4, 0xab, 0x74, 0x53, 0xff, - 0xfc, 0xa4, 0xa9, 0x54, 0x82, 0xe7, 0xef, 0xab, 0xf3, 0xa5, 0x08, 0xf5, 0xe4, 0x83, 0x88, 0x0d, - 0xa8, 0x84, 0x0f, 0x0c, 0xde, 0xcb, 0xc2, 0x97, 0x7c, 0xd5, 0xb4, 0xf6, 0x4a, 0xb1, 0x52, 0x54, - 0x39, 0x6c, 0x41, 0x75, 0xb9, 0x23, 0xf1, 0xc1, 0x3a, 0x6b, 0x5f, 0xdb, 0x5b, 0x31, 0x3a, 0x28, - 0x74, 0x84, 0xb0, 0x09, 0x95, 0xf0, 0x22, 0x66, 0x77, 0x93, 0x5c, 0x36, 0xd9, 0xdd, 0xc4, 0x6f, - 0x76, 0x50, 0xe4, 0x0c, 0x0a, 0x5d, 0x73, 0x82, 0xb3, 0xb7, 0xd1, 0x72, 0x5d, 0x6b, 0x3b, 0x0f, - 0x6e, 0x67, 0x4f, 0xfe, 0x61, 0x20, 0x39, 0xfc, 0x06, 0x20, 0xd2, 0x32, 0xfe, 0x6b, 0x55, 0xcd, - 0xab, 0xb4, 0xfb, 0x6b, 0x5c, 0x11, 0x92, 0xc3, 0x1c, 0xb6, 0x12, 0x12, 0xc3, 0x47, 0x6b, 0xa8, - 0x51, 0x55, 0xd4, 0xd7, 0xd3, 0x2f, 0xc9, 0x9d, 0x76, 0xe0, 0x8f, 0x8c, 0x23, 0x01, 0x1f, 0xa6, - 0x63, 0xf7, 0xd1, 0x15, 0xba, 0xad, 0x84, 0xde, 0x41, 0x39, 0x70, 0xff, 0xfd, 0x3d, 0x00, 0x00, - 0xff, 0xff, 0x25, 0xed, 0xc6, 0x17, 0xba, 0x09, 0x00, 0x00, -} - -// Reference imports to suppress errors if they are not otherwise used. -var _ context.Context -var _ grpc.ClientConn - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the grpc package it is being compiled against. -const _ = grpc.SupportPackageIsVersion4 - -// LiiklusServiceClient is the client API for LiiklusService service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. -type LiiklusServiceClient interface { - Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error) - Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LiiklusService_SubscribeClient, error) - Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (LiiklusService_ReceiveClient, error) - Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*empty.Empty, error) - GetOffsets(ctx context.Context, in *GetOffsetsRequest, opts ...grpc.CallOption) (*GetOffsetsReply, error) - GetEndOffsets(ctx context.Context, in *GetEndOffsetsRequest, opts ...grpc.CallOption) (*GetEndOffsetsReply, error) -} - -type liiklusServiceClient struct { - cc *grpc.ClientConn -} - -func NewLiiklusServiceClient(cc *grpc.ClientConn) LiiklusServiceClient { - return &liiklusServiceClient{cc} -} - -func (c *liiklusServiceClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error) { - out := new(PublishReply) - err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/Publish", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil +// Deprecated: Use GetEndOffsetsRequest.ProtoReflect.Descriptor instead. +func (*GetEndOffsetsRequest) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{10} } -func (c *liiklusServiceClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LiiklusService_SubscribeClient, error) { - stream, err := c.cc.NewStream(ctx, &_LiiklusService_serviceDesc.Streams[0], "/com.github.bsideup.liiklus.LiiklusService/Subscribe", opts...) - if err != nil { - return nil, err +func (x *GetEndOffsetsRequest) GetTopic() string { + if x != nil { + return x.Topic } - x := &liiklusServiceSubscribeClient{stream} - if err := x.ClientStream.SendMsg(in); err != nil { - return nil, err - } - if err := x.ClientStream.CloseSend(); err != nil { - return nil, err - } - return x, nil -} - -type LiiklusService_SubscribeClient interface { - Recv() (*SubscribeReply, error) - grpc.ClientStream + return "" } -type liiklusServiceSubscribeClient struct { - grpc.ClientStream -} +type GetEndOffsetsReply struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func (x *liiklusServiceSubscribeClient) Recv() (*SubscribeReply, error) { - m := new(SubscribeReply) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil + Offsets map[uint32]uint64 `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` } -func (c *liiklusServiceClient) Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (LiiklusService_ReceiveClient, error) { - stream, err := c.cc.NewStream(ctx, &_LiiklusService_serviceDesc.Streams[1], "/com.github.bsideup.liiklus.LiiklusService/Receive", opts...) - if err != nil { - return nil, err - } - x := &liiklusServiceReceiveClient{stream} - if err := x.ClientStream.SendMsg(in); err != nil { - return nil, err +func (x *GetEndOffsetsReply) Reset() { + *x = GetEndOffsetsReply{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } - if err := x.ClientStream.CloseSend(); err != nil { - return nil, err - } - return x, nil } -type LiiklusService_ReceiveClient interface { - Recv() (*ReceiveReply, error) - grpc.ClientStream +func (x *GetEndOffsetsReply) String() string { + return protoimpl.X.MessageStringOf(x) } -type liiklusServiceReceiveClient struct { - grpc.ClientStream -} +func (*GetEndOffsetsReply) ProtoMessage() {} -func (x *liiklusServiceReceiveClient) Recv() (*ReceiveReply, error) { - m := new(ReceiveReply) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err +func (x *GetEndOffsetsReply) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[11] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms } - return m, nil + return mi.MessageOf(x) } -func (c *liiklusServiceClient) Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*empty.Empty, error) { - out := new(empty.Empty) - err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/Ack", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *liiklusServiceClient) GetOffsets(ctx context.Context, in *GetOffsetsRequest, opts ...grpc.CallOption) (*GetOffsetsReply, error) { - out := new(GetOffsetsReply) - err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/GetOffsets", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil +// Deprecated: Use GetEndOffsetsReply.ProtoReflect.Descriptor instead. +func (*GetEndOffsetsReply) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{11} } -func (c *liiklusServiceClient) GetEndOffsets(ctx context.Context, in *GetEndOffsetsRequest, opts ...grpc.CallOption) (*GetEndOffsetsReply, error) { - out := new(GetEndOffsetsReply) - err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/GetEndOffsets", in, out, opts...) - if err != nil { - return nil, err +func (x *GetEndOffsetsReply) GetOffsets() map[uint32]uint64 { + if x != nil { + return x.Offsets } - return out, nil + return nil } -// LiiklusServiceServer is the server API for LiiklusService service. -type LiiklusServiceServer interface { - Publish(context.Context, *PublishRequest) (*PublishReply, error) - Subscribe(*SubscribeRequest, LiiklusService_SubscribeServer) error - Receive(*ReceiveRequest, LiiklusService_ReceiveServer) error - Ack(context.Context, *AckRequest) (*empty.Empty, error) - GetOffsets(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error) - GetEndOffsets(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error) -} +type ReceiveReply_Record struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -func RegisterLiiklusServiceServer(s *grpc.Server, srv LiiklusServiceServer) { - s.RegisterService(&_LiiklusService_serviceDesc, srv) + Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` + Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` + Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` + Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + Replay bool `protobuf:"varint,5,opt,name=replay,proto3" json:"replay,omitempty"` } -func _LiiklusService_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(PublishRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(LiiklusServiceServer).Publish(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/com.github.bsideup.liiklus.LiiklusService/Publish", +func (x *ReceiveReply_Record) Reset() { + *x = ReceiveReply_Record{} + if protoimpl.UnsafeEnabled { + mi := &file_LiiklusService_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LiiklusServiceServer).Publish(ctx, req.(*PublishRequest)) - } - return interceptor(ctx, in, info, handler) } -func _LiiklusService_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error { - m := new(SubscribeRequest) - if err := stream.RecvMsg(m); err != nil { - return err - } - return srv.(LiiklusServiceServer).Subscribe(m, &liiklusServiceSubscribeServer{stream}) +func (x *ReceiveReply_Record) String() string { + return protoimpl.X.MessageStringOf(x) } -type LiiklusService_SubscribeServer interface { - Send(*SubscribeReply) error - grpc.ServerStream -} +func (*ReceiveReply_Record) ProtoMessage() {} -type liiklusServiceSubscribeServer struct { - grpc.ServerStream +func (x *ReceiveReply_Record) ProtoReflect() protoreflect.Message { + mi := &file_LiiklusService_proto_msgTypes[12] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -func (x *liiklusServiceSubscribeServer) Send(m *SubscribeReply) error { - return x.ServerStream.SendMsg(m) +// Deprecated: Use ReceiveReply_Record.ProtoReflect.Descriptor instead. +func (*ReceiveReply_Record) Descriptor() ([]byte, []int) { + return file_LiiklusService_proto_rawDescGZIP(), []int{7, 0} } -func _LiiklusService_Receive_Handler(srv interface{}, stream grpc.ServerStream) error { - m := new(ReceiveRequest) - if err := stream.RecvMsg(m); err != nil { - return err +func (x *ReceiveReply_Record) GetOffset() uint64 { + if x != nil { + return x.Offset } - return srv.(LiiklusServiceServer).Receive(m, &liiklusServiceReceiveServer{stream}) -} - -type LiiklusService_ReceiveServer interface { - Send(*ReceiveReply) error - grpc.ServerStream + return 0 } -type liiklusServiceReceiveServer struct { - grpc.ServerStream +func (x *ReceiveReply_Record) GetKey() []byte { + if x != nil { + return x.Key + } + return nil } -func (x *liiklusServiceReceiveServer) Send(m *ReceiveReply) error { - return x.ServerStream.SendMsg(m) +func (x *ReceiveReply_Record) GetValue() []byte { + if x != nil { + return x.Value + } + return nil } -func _LiiklusService_Ack_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(AckRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(LiiklusServiceServer).Ack(ctx, in) +func (x *ReceiveReply_Record) GetTimestamp() *timestamppb.Timestamp { + if x != nil { + return x.Timestamp } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/com.github.bsideup.liiklus.LiiklusService/Ack", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LiiklusServiceServer).Ack(ctx, req.(*AckRequest)) - } - return interceptor(ctx, in, info, handler) + return nil } -func _LiiklusService_GetOffsets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(GetOffsetsRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(LiiklusServiceServer).GetOffsets(ctx, in) +func (x *ReceiveReply_Record) GetReplay() bool { + if x != nil { + return x.Replay } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/com.github.bsideup.liiklus.LiiklusService/GetOffsets", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LiiklusServiceServer).GetOffsets(ctx, req.(*GetOffsetsRequest)) - } - return interceptor(ctx, in, info, handler) + return false } -func _LiiklusService_GetEndOffsets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(GetEndOffsetsRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(LiiklusServiceServer).GetEndOffsets(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/com.github.bsideup.liiklus.LiiklusService/GetEndOffsets", +var File_LiiklusService_proto protoreflect.FileDescriptor + +var file_LiiklusService_proto_rawDesc = []byte{ + 0x0a, 0x14, 0x4c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, + 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, + 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, + 0x75, 0x73, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, + 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x22, 0x4e, 0x0a, 0x0e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, + 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, + 0x22, 0x5a, 0x0a, 0x0c, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x70, 0x6c, 0x79, + 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x0d, 0x52, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16, + 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, + 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, + 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x22, 0xf7, 0x01, 0x0a, + 0x10, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x14, 0x0a, 0x05, 0x67, 0x72, 0x6f, 0x75, 0x70, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x12, 0x22, 0x0a, + 0x0c, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, + 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x12, 0x66, 0x0a, 0x0f, 0x61, 0x75, 0x74, 0x6f, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x52, + 0x65, 0x73, 0x65, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x3c, 0x2e, 0x63, 0x6f, 0x6d, + 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, + 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, + 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x41, 0x75, 0x74, 0x6f, 0x4f, 0x66, 0x66, + 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x65, 0x74, 0x52, 0x0f, 0x61, 0x75, 0x74, 0x6f, 0x4f, 0x66, + 0x66, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x65, 0x74, 0x22, 0x2b, 0x0a, 0x0f, 0x41, 0x75, 0x74, + 0x6f, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x65, 0x74, 0x12, 0x0c, 0x0a, 0x08, + 0x45, 0x41, 0x52, 0x4c, 0x49, 0x45, 0x53, 0x54, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x4c, 0x41, + 0x54, 0x45, 0x53, 0x54, 0x10, 0x01, 0x22, 0x48, 0x0a, 0x0a, 0x41, 0x73, 0x73, 0x69, 0x67, 0x6e, + 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, + 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, + 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, + 0x22, 0x63, 0x0a, 0x0e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x70, + 0x6c, 0x79, 0x12, 0x48, 0x0a, 0x0a, 0x61, 0x73, 0x73, 0x69, 0x67, 0x6e, 0x6d, 0x65, 0x6e, 0x74, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, + 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, + 0x6c, 0x75, 0x73, 0x2e, 0x41, 0x73, 0x73, 0x69, 0x67, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x48, 0x00, + 0x52, 0x0a, 0x61, 0x73, 0x73, 0x69, 0x67, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x42, 0x07, 0x0a, 0x05, + 0x72, 0x65, 0x70, 0x6c, 0x79, 0x22, 0xde, 0x01, 0x0a, 0x0a, 0x41, 0x63, 0x6b, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x12, 0x4a, 0x0a, 0x0a, 0x61, 0x73, 0x73, 0x69, 0x67, 0x6e, 0x6d, 0x65, + 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, + 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, + 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x41, 0x73, 0x73, 0x69, 0x67, 0x6e, 0x6d, 0x65, 0x6e, 0x74, + 0x42, 0x02, 0x18, 0x01, 0x52, 0x0a, 0x61, 0x73, 0x73, 0x69, 0x67, 0x6e, 0x6d, 0x65, 0x6e, 0x74, + 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x14, 0x0a, 0x05, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x18, + 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x12, 0x22, 0x0a, 0x0c, + 0x67, 0x72, 0x6f, 0x75, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01, + 0x28, 0x0d, 0x52, 0x0c, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, + 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x06, 0x20, + 0x01, 0x28, 0x0d, 0x52, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16, + 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, + 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0x82, 0x01, 0x0a, 0x0e, 0x52, 0x65, 0x63, 0x65, 0x69, + 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x46, 0x0a, 0x0a, 0x61, 0x73, 0x73, + 0x69, 0x67, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, + 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, + 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x41, 0x73, 0x73, 0x69, 0x67, + 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x52, 0x0a, 0x61, 0x73, 0x73, 0x69, 0x67, 0x6e, 0x6d, 0x65, 0x6e, + 0x74, 0x12, 0x28, 0x0a, 0x0f, 0x6c, 0x61, 0x73, 0x74, 0x4b, 0x6e, 0x6f, 0x77, 0x6e, 0x4f, 0x66, + 0x66, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, 0x6c, 0x61, 0x73, 0x74, + 0x4b, 0x6e, 0x6f, 0x77, 0x6e, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0xff, 0x01, 0x0a, 0x0c, + 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x49, 0x0a, 0x06, + 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x63, + 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, + 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, + 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x48, 0x00, 0x52, + 0x06, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x1a, 0x9a, 0x01, 0x0a, 0x06, 0x52, 0x65, 0x63, 0x6f, + 0x72, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x04, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, + 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, + 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, + 0x75, 0x65, 0x12, 0x38, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, + 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, + 0x70, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x16, 0x0a, 0x06, + 0x72, 0x65, 0x70, 0x6c, 0x61, 0x79, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x72, 0x65, + 0x70, 0x6c, 0x61, 0x79, 0x42, 0x07, 0x0a, 0x05, 0x72, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x63, 0x0a, + 0x11, 0x47, 0x65, 0x74, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x14, 0x0a, 0x05, 0x67, 0x72, 0x6f, 0x75, + 0x70, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x12, 0x22, + 0x0a, 0x0c, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x03, + 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x56, 0x65, 0x72, 0x73, 0x69, + 0x6f, 0x6e, 0x22, 0xa1, 0x01, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, + 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x52, 0x0a, 0x07, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, + 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x38, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, + 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, + 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x52, + 0x65, 0x70, 0x6c, 0x79, 0x2e, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, + 0x79, 0x52, 0x07, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x1a, 0x3a, 0x0a, 0x0c, 0x4f, 0x66, + 0x66, 0x73, 0x65, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, + 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, + 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x76, 0x61, 0x6c, + 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x2c, 0x0a, 0x14, 0x47, 0x65, 0x74, 0x45, 0x6e, 0x64, + 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, + 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, + 0x6f, 0x70, 0x69, 0x63, 0x22, 0xa7, 0x01, 0x0a, 0x12, 0x47, 0x65, 0x74, 0x45, 0x6e, 0x64, 0x4f, + 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x55, 0x0a, 0x07, 0x6f, + 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x63, + 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, + 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x45, 0x6e, 0x64, + 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x2e, 0x4f, 0x66, 0x66, + 0x73, 0x65, 0x74, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x07, 0x6f, 0x66, 0x66, 0x73, 0x65, + 0x74, 0x73, 0x1a, 0x3a, 0x0a, 0x0c, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x45, 0x6e, 0x74, + 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, + 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x04, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x32, 0xed, + 0x04, 0x0a, 0x0e, 0x4c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, + 0x65, 0x12, 0x61, 0x0a, 0x07, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x12, 0x2a, 0x2e, 0x63, + 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, + 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, + 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, + 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, + 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x70, + 0x6c, 0x79, 0x22, 0x00, 0x12, 0x69, 0x0a, 0x09, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, + 0x65, 0x12, 0x2c, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, + 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x53, + 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x2a, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, + 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x53, 0x75, 0x62, + 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x30, 0x01, 0x12, + 0x63, 0x0a, 0x07, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x12, 0x2a, 0x2e, 0x63, 0x6f, 0x6d, + 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, + 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, + 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, + 0x6c, 0x75, 0x73, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x70, 0x6c, 0x79, + 0x22, 0x00, 0x30, 0x01, 0x12, 0x47, 0x0a, 0x03, 0x41, 0x63, 0x6b, 0x12, 0x26, 0x2e, 0x63, 0x6f, + 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, + 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x41, 0x63, 0x6b, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, + 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x00, 0x12, 0x6a, 0x0a, + 0x0a, 0x47, 0x65, 0x74, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x12, 0x2d, 0x2e, 0x63, 0x6f, + 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, + 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x4f, 0x66, 0x66, 0x73, + 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2b, 0x2e, 0x63, 0x6f, 0x6d, + 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, + 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x4f, 0x66, 0x66, 0x73, 0x65, + 0x74, 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x73, 0x0a, 0x0d, 0x47, 0x65, 0x74, + 0x45, 0x6e, 0x64, 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x12, 0x30, 0x2e, 0x63, 0x6f, 0x6d, + 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, 0x70, 0x2e, + 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x45, 0x6e, 0x64, 0x4f, 0x66, + 0x66, 0x73, 0x65, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2e, 0x2e, 0x63, + 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, 0x64, 0x65, 0x75, + 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x47, 0x65, 0x74, 0x45, 0x6e, 0x64, + 0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x73, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x42, 0x35, + 0x0a, 0x23, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x62, 0x73, 0x69, + 0x64, 0x65, 0x75, 0x70, 0x2e, 0x6c, 0x69, 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, + 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x48, 0x01, 0x50, 0x01, 0x5a, 0x0a, 0x2e, 0x2f, 0x3b, 0x6c, 0x69, + 0x69, 0x6b, 0x6c, 0x75, 0x73, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_LiiklusService_proto_rawDescOnce sync.Once + file_LiiklusService_proto_rawDescData = file_LiiklusService_proto_rawDesc +) + +func file_LiiklusService_proto_rawDescGZIP() []byte { + file_LiiklusService_proto_rawDescOnce.Do(func() { + file_LiiklusService_proto_rawDescData = protoimpl.X.CompressGZIP(file_LiiklusService_proto_rawDescData) + }) + return file_LiiklusService_proto_rawDescData +} + +var file_LiiklusService_proto_enumTypes = make([]protoimpl.EnumInfo, 1) +var file_LiiklusService_proto_msgTypes = make([]protoimpl.MessageInfo, 15) +var file_LiiklusService_proto_goTypes = []interface{}{ + (SubscribeRequest_AutoOffsetReset)(0), // 0: com.github.bsideup.liiklus.SubscribeRequest.AutoOffsetReset + (*PublishRequest)(nil), // 1: com.github.bsideup.liiklus.PublishRequest + (*PublishReply)(nil), // 2: com.github.bsideup.liiklus.PublishReply + (*SubscribeRequest)(nil), // 3: com.github.bsideup.liiklus.SubscribeRequest + (*Assignment)(nil), // 4: com.github.bsideup.liiklus.Assignment + (*SubscribeReply)(nil), // 5: com.github.bsideup.liiklus.SubscribeReply + (*AckRequest)(nil), // 6: com.github.bsideup.liiklus.AckRequest + (*ReceiveRequest)(nil), // 7: com.github.bsideup.liiklus.ReceiveRequest + (*ReceiveReply)(nil), // 8: com.github.bsideup.liiklus.ReceiveReply + (*GetOffsetsRequest)(nil), // 9: com.github.bsideup.liiklus.GetOffsetsRequest + (*GetOffsetsReply)(nil), // 10: com.github.bsideup.liiklus.GetOffsetsReply + (*GetEndOffsetsRequest)(nil), // 11: com.github.bsideup.liiklus.GetEndOffsetsRequest + (*GetEndOffsetsReply)(nil), // 12: com.github.bsideup.liiklus.GetEndOffsetsReply + (*ReceiveReply_Record)(nil), // 13: com.github.bsideup.liiklus.ReceiveReply.Record + nil, // 14: com.github.bsideup.liiklus.GetOffsetsReply.OffsetsEntry + nil, // 15: com.github.bsideup.liiklus.GetEndOffsetsReply.OffsetsEntry + (*timestamppb.Timestamp)(nil), // 16: google.protobuf.Timestamp + (*emptypb.Empty)(nil), // 17: google.protobuf.Empty +} +var file_LiiklusService_proto_depIdxs = []int32{ + 0, // 0: com.github.bsideup.liiklus.SubscribeRequest.autoOffsetReset:type_name -> com.github.bsideup.liiklus.SubscribeRequest.AutoOffsetReset + 4, // 1: com.github.bsideup.liiklus.SubscribeReply.assignment:type_name -> com.github.bsideup.liiklus.Assignment + 4, // 2: com.github.bsideup.liiklus.AckRequest.assignment:type_name -> com.github.bsideup.liiklus.Assignment + 4, // 3: com.github.bsideup.liiklus.ReceiveRequest.assignment:type_name -> com.github.bsideup.liiklus.Assignment + 13, // 4: com.github.bsideup.liiklus.ReceiveReply.record:type_name -> com.github.bsideup.liiklus.ReceiveReply.Record + 14, // 5: com.github.bsideup.liiklus.GetOffsetsReply.offsets:type_name -> com.github.bsideup.liiklus.GetOffsetsReply.OffsetsEntry + 15, // 6: com.github.bsideup.liiklus.GetEndOffsetsReply.offsets:type_name -> com.github.bsideup.liiklus.GetEndOffsetsReply.OffsetsEntry + 16, // 7: com.github.bsideup.liiklus.ReceiveReply.Record.timestamp:type_name -> google.protobuf.Timestamp + 1, // 8: com.github.bsideup.liiklus.LiiklusService.Publish:input_type -> com.github.bsideup.liiklus.PublishRequest + 3, // 9: com.github.bsideup.liiklus.LiiklusService.Subscribe:input_type -> com.github.bsideup.liiklus.SubscribeRequest + 7, // 10: com.github.bsideup.liiklus.LiiklusService.Receive:input_type -> com.github.bsideup.liiklus.ReceiveRequest + 6, // 11: com.github.bsideup.liiklus.LiiklusService.Ack:input_type -> com.github.bsideup.liiklus.AckRequest + 9, // 12: com.github.bsideup.liiklus.LiiklusService.GetOffsets:input_type -> com.github.bsideup.liiklus.GetOffsetsRequest + 11, // 13: com.github.bsideup.liiklus.LiiklusService.GetEndOffsets:input_type -> com.github.bsideup.liiklus.GetEndOffsetsRequest + 2, // 14: com.github.bsideup.liiklus.LiiklusService.Publish:output_type -> com.github.bsideup.liiklus.PublishReply + 5, // 15: com.github.bsideup.liiklus.LiiklusService.Subscribe:output_type -> com.github.bsideup.liiklus.SubscribeReply + 8, // 16: com.github.bsideup.liiklus.LiiklusService.Receive:output_type -> com.github.bsideup.liiklus.ReceiveReply + 17, // 17: com.github.bsideup.liiklus.LiiklusService.Ack:output_type -> google.protobuf.Empty + 10, // 18: com.github.bsideup.liiklus.LiiklusService.GetOffsets:output_type -> com.github.bsideup.liiklus.GetOffsetsReply + 12, // 19: com.github.bsideup.liiklus.LiiklusService.GetEndOffsets:output_type -> com.github.bsideup.liiklus.GetEndOffsetsReply + 14, // [14:20] is the sub-list for method output_type + 8, // [8:14] is the sub-list for method input_type + 8, // [8:8] is the sub-list for extension type_name + 8, // [8:8] is the sub-list for extension extendee + 0, // [0:8] is the sub-list for field type_name +} + +func init() { file_LiiklusService_proto_init() } +func file_LiiklusService_proto_init() { + if File_LiiklusService_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_LiiklusService_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PublishRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PublishReply); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SubscribeRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Assignment); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SubscribeReply); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*AckRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ReceiveRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ReceiveReply); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetOffsetsRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetOffsetsReply); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetEndOffsetsRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetEndOffsetsReply); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_LiiklusService_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ReceiveReply_Record); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + file_LiiklusService_proto_msgTypes[4].OneofWrappers = []interface{}{ + (*SubscribeReply_Assignment)(nil), } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LiiklusServiceServer).GetEndOffsets(ctx, req.(*GetEndOffsetsRequest)) + file_LiiklusService_proto_msgTypes[7].OneofWrappers = []interface{}{ + (*ReceiveReply_Record_)(nil), } - return interceptor(ctx, in, info, handler) -} - -var _LiiklusService_serviceDesc = grpc.ServiceDesc{ - ServiceName: "com.github.bsideup.liiklus.LiiklusService", - HandlerType: (*LiiklusServiceServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "Publish", - Handler: _LiiklusService_Publish_Handler, - }, - { - MethodName: "Ack", - Handler: _LiiklusService_Ack_Handler, - }, - { - MethodName: "GetOffsets", - Handler: _LiiklusService_GetOffsets_Handler, - }, - { - MethodName: "GetEndOffsets", - Handler: _LiiklusService_GetEndOffsets_Handler, - }, - }, - Streams: []grpc.StreamDesc{ - { - StreamName: "Subscribe", - Handler: _LiiklusService_Subscribe_Handler, - ServerStreams: true, - }, - { - StreamName: "Receive", - Handler: _LiiklusService_Receive_Handler, - ServerStreams: true, + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_LiiklusService_proto_rawDesc, + NumEnums: 1, + NumMessages: 15, + NumExtensions: 0, + NumServices: 1, }, - }, - Metadata: "LiiklusService.proto", + GoTypes: file_LiiklusService_proto_goTypes, + DependencyIndexes: file_LiiklusService_proto_depIdxs, + EnumInfos: file_LiiklusService_proto_enumTypes, + MessageInfos: file_LiiklusService_proto_msgTypes, + }.Build() + File_LiiklusService_proto = out.File + file_LiiklusService_proto_rawDesc = nil + file_LiiklusService_proto_goTypes = nil + file_LiiklusService_proto_depIdxs = nil } diff --git a/pkg/scalers/liiklus/LiiklusService_grpc.pb.go b/pkg/scalers/liiklus/LiiklusService_grpc.pb.go new file mode 100644 index 00000000000..7c770a8459a --- /dev/null +++ b/pkg/scalers/liiklus/LiiklusService_grpc.pb.go @@ -0,0 +1,408 @@ +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. + +package liiklus + +import ( + context "context" + grpc "google.golang.org/grpc" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" + emptypb "google.golang.org/protobuf/types/known/emptypb" +) + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the grpc package it is being compiled against. +const _ = grpc.SupportPackageIsVersion7 + +// LiiklusServiceClient is the client API for LiiklusService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. +type LiiklusServiceClient interface { + Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error) + Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LiiklusService_SubscribeClient, error) + Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (LiiklusService_ReceiveClient, error) + Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + GetOffsets(ctx context.Context, in *GetOffsetsRequest, opts ...grpc.CallOption) (*GetOffsetsReply, error) + GetEndOffsets(ctx context.Context, in *GetEndOffsetsRequest, opts ...grpc.CallOption) (*GetEndOffsetsReply, error) +} + +type liiklusServiceClient struct { + cc grpc.ClientConnInterface +} + +func NewLiiklusServiceClient(cc grpc.ClientConnInterface) LiiklusServiceClient { + return &liiklusServiceClient{cc} +} + +var liiklusServicePublishStreamDesc = &grpc.StreamDesc{ + StreamName: "Publish", +} + +func (c *liiklusServiceClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error) { + out := new(PublishReply) + err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/Publish", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +var liiklusServiceSubscribeStreamDesc = &grpc.StreamDesc{ + StreamName: "Subscribe", + ServerStreams: true, +} + +func (c *liiklusServiceClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LiiklusService_SubscribeClient, error) { + stream, err := c.cc.NewStream(ctx, liiklusServiceSubscribeStreamDesc, "/com.github.bsideup.liiklus.LiiklusService/Subscribe", opts...) + if err != nil { + return nil, err + } + x := &liiklusServiceSubscribeClient{stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +type LiiklusService_SubscribeClient interface { + Recv() (*SubscribeReply, error) + grpc.ClientStream +} + +type liiklusServiceSubscribeClient struct { + grpc.ClientStream +} + +func (x *liiklusServiceSubscribeClient) Recv() (*SubscribeReply, error) { + m := new(SubscribeReply) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + +var liiklusServiceReceiveStreamDesc = &grpc.StreamDesc{ + StreamName: "Receive", + ServerStreams: true, +} + +func (c *liiklusServiceClient) Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (LiiklusService_ReceiveClient, error) { + stream, err := c.cc.NewStream(ctx, liiklusServiceReceiveStreamDesc, "/com.github.bsideup.liiklus.LiiklusService/Receive", opts...) + if err != nil { + return nil, err + } + x := &liiklusServiceReceiveClient{stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +type LiiklusService_ReceiveClient interface { + Recv() (*ReceiveReply, error) + grpc.ClientStream +} + +type liiklusServiceReceiveClient struct { + grpc.ClientStream +} + +func (x *liiklusServiceReceiveClient) Recv() (*ReceiveReply, error) { + m := new(ReceiveReply) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + +var liiklusServiceAckStreamDesc = &grpc.StreamDesc{ + StreamName: "Ack", +} + +func (c *liiklusServiceClient) Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { + out := new(emptypb.Empty) + err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/Ack", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +var liiklusServiceGetOffsetsStreamDesc = &grpc.StreamDesc{ + StreamName: "GetOffsets", +} + +func (c *liiklusServiceClient) GetOffsets(ctx context.Context, in *GetOffsetsRequest, opts ...grpc.CallOption) (*GetOffsetsReply, error) { + out := new(GetOffsetsReply) + err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/GetOffsets", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +var liiklusServiceGetEndOffsetsStreamDesc = &grpc.StreamDesc{ + StreamName: "GetEndOffsets", +} + +func (c *liiklusServiceClient) GetEndOffsets(ctx context.Context, in *GetEndOffsetsRequest, opts ...grpc.CallOption) (*GetEndOffsetsReply, error) { + out := new(GetEndOffsetsReply) + err := c.cc.Invoke(ctx, "/com.github.bsideup.liiklus.LiiklusService/GetEndOffsets", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// LiiklusServiceService is the service API for LiiklusService service. +// Fields should be assigned to their respective handler implementations only before +// RegisterLiiklusServiceService is called. Any unassigned fields will result in the +// handler for that method returning an Unimplemented error. +type LiiklusServiceService struct { + Publish func(context.Context, *PublishRequest) (*PublishReply, error) + Subscribe func(*SubscribeRequest, LiiklusService_SubscribeServer) error + Receive func(*ReceiveRequest, LiiklusService_ReceiveServer) error + Ack func(context.Context, *AckRequest) (*emptypb.Empty, error) + GetOffsets func(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error) + GetEndOffsets func(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error) +} + +func (s *LiiklusServiceService) publish(_ interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(PublishRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return s.Publish(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: s, + FullMethod: "/com.github.bsideup.liiklus.LiiklusService/Publish", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return s.Publish(ctx, req.(*PublishRequest)) + } + return interceptor(ctx, in, info, handler) +} +func (s *LiiklusServiceService) subscribe(_ interface{}, stream grpc.ServerStream) error { + m := new(SubscribeRequest) + if err := stream.RecvMsg(m); err != nil { + return err + } + return s.Subscribe(m, &liiklusServiceSubscribeServer{stream}) +} +func (s *LiiklusServiceService) receive(_ interface{}, stream grpc.ServerStream) error { + m := new(ReceiveRequest) + if err := stream.RecvMsg(m); err != nil { + return err + } + return s.Receive(m, &liiklusServiceReceiveServer{stream}) +} +func (s *LiiklusServiceService) ack(_ interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(AckRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return s.Ack(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: s, + FullMethod: "/com.github.bsideup.liiklus.LiiklusService/Ack", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return s.Ack(ctx, req.(*AckRequest)) + } + return interceptor(ctx, in, info, handler) +} +func (s *LiiklusServiceService) getOffsets(_ interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetOffsetsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return s.GetOffsets(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: s, + FullMethod: "/com.github.bsideup.liiklus.LiiklusService/GetOffsets", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return s.GetOffsets(ctx, req.(*GetOffsetsRequest)) + } + return interceptor(ctx, in, info, handler) +} +func (s *LiiklusServiceService) getEndOffsets(_ interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetEndOffsetsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return s.GetEndOffsets(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: s, + FullMethod: "/com.github.bsideup.liiklus.LiiklusService/GetEndOffsets", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return s.GetEndOffsets(ctx, req.(*GetEndOffsetsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +type LiiklusService_SubscribeServer interface { + Send(*SubscribeReply) error + grpc.ServerStream +} + +type liiklusServiceSubscribeServer struct { + grpc.ServerStream +} + +func (x *liiklusServiceSubscribeServer) Send(m *SubscribeReply) error { + return x.ServerStream.SendMsg(m) +} + +type LiiklusService_ReceiveServer interface { + Send(*ReceiveReply) error + grpc.ServerStream +} + +type liiklusServiceReceiveServer struct { + grpc.ServerStream +} + +func (x *liiklusServiceReceiveServer) Send(m *ReceiveReply) error { + return x.ServerStream.SendMsg(m) +} + +// RegisterLiiklusServiceService registers a service implementation with a gRPC server. +func RegisterLiiklusServiceService(s grpc.ServiceRegistrar, srv *LiiklusServiceService) { + srvCopy := *srv + if srvCopy.Publish == nil { + srvCopy.Publish = func(context.Context, *PublishRequest) (*PublishReply, error) { + return nil, status.Errorf(codes.Unimplemented, "method Publish not implemented") + } + } + if srvCopy.Subscribe == nil { + srvCopy.Subscribe = func(*SubscribeRequest, LiiklusService_SubscribeServer) error { + return status.Errorf(codes.Unimplemented, "method Subscribe not implemented") + } + } + if srvCopy.Receive == nil { + srvCopy.Receive = func(*ReceiveRequest, LiiklusService_ReceiveServer) error { + return status.Errorf(codes.Unimplemented, "method Receive not implemented") + } + } + if srvCopy.Ack == nil { + srvCopy.Ack = func(context.Context, *AckRequest) (*emptypb.Empty, error) { + return nil, status.Errorf(codes.Unimplemented, "method Ack not implemented") + } + } + if srvCopy.GetOffsets == nil { + srvCopy.GetOffsets = func(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetOffsets not implemented") + } + } + if srvCopy.GetEndOffsets == nil { + srvCopy.GetEndOffsets = func(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetEndOffsets not implemented") + } + } + sd := grpc.ServiceDesc{ + ServiceName: "com.github.bsideup.liiklus.LiiklusService", + Methods: []grpc.MethodDesc{ + { + MethodName: "Publish", + Handler: srvCopy.publish, + }, + { + MethodName: "Ack", + Handler: srvCopy.ack, + }, + { + MethodName: "GetOffsets", + Handler: srvCopy.getOffsets, + }, + { + MethodName: "GetEndOffsets", + Handler: srvCopy.getEndOffsets, + }, + }, + Streams: []grpc.StreamDesc{ + { + StreamName: "Subscribe", + Handler: srvCopy.subscribe, + ServerStreams: true, + }, + { + StreamName: "Receive", + Handler: srvCopy.receive, + ServerStreams: true, + }, + }, + Metadata: "LiiklusService.proto", + } + + s.RegisterService(&sd, nil) +} + +// NewLiiklusServiceService creates a new LiiklusServiceService containing the +// implemented methods of the LiiklusService service in s. Any unimplemented +// methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. +// This includes situations where the method handler is misspelled or has the wrong +// signature. For this reason, this function should be used with great care and +// is not recommended to be used by most users. +func NewLiiklusServiceService(s interface{}) *LiiklusServiceService { + ns := &LiiklusServiceService{} + if h, ok := s.(interface { + Publish(context.Context, *PublishRequest) (*PublishReply, error) + }); ok { + ns.Publish = h.Publish + } + if h, ok := s.(interface { + Subscribe(*SubscribeRequest, LiiklusService_SubscribeServer) error + }); ok { + ns.Subscribe = h.Subscribe + } + if h, ok := s.(interface { + Receive(*ReceiveRequest, LiiklusService_ReceiveServer) error + }); ok { + ns.Receive = h.Receive + } + if h, ok := s.(interface { + Ack(context.Context, *AckRequest) (*emptypb.Empty, error) + }); ok { + ns.Ack = h.Ack + } + if h, ok := s.(interface { + GetOffsets(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error) + }); ok { + ns.GetOffsets = h.GetOffsets + } + if h, ok := s.(interface { + GetEndOffsets(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error) + }); ok { + ns.GetEndOffsets = h.GetEndOffsets + } + return ns +} + +// UnstableLiiklusServiceService is the service API for LiiklusService service. +// New methods may be added to this interface if they are added to the service +// definition, which is not a backward-compatible change. For this reason, +// use of this type is not recommended. +type UnstableLiiklusServiceService interface { + Publish(context.Context, *PublishRequest) (*PublishReply, error) + Subscribe(*SubscribeRequest, LiiklusService_SubscribeServer) error + Receive(*ReceiveRequest, LiiklusService_ReceiveServer) error + Ack(context.Context, *AckRequest) (*emptypb.Empty, error) + GetOffsets(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error) + GetEndOffsets(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error) +} From eeac536f6b86cfe032432f536f4055fd2b85795d Mon Sep 17 00:00:00 2001 From: Zbynek Roubalik Date: Tue, 12 Oct 2021 13:40:30 +0200 Subject: [PATCH 2/2] changelog Signed-off-by: Zbynek Roubalik --- CHANGELOG.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index e00971cf1ee..bd64b3b65d3 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -54,7 +54,7 @@ - API path has been changed: `github.com/kedacore/keda/v2/api/v1alpha1` -> `github.com/kedacore/keda/v2/apis/keda/v1alpha1` - Use Patch to set FallbackCondition on ScaledObject.Status ([#2037](https://github.com/kedacore/keda/pull/2037)) - Bump Golang to 1.16.9 ([#2065](https://github.com/kedacore/keda/pull/2065)|[#2186](https://github.com/kedacore/keda/pull/2186)) -- Add Makefile mockgen targets ([#2090](https://github.com/kedacore/keda/issues/2090)) +- Add Makefile mockgen targets ([#2090](https://github.com/kedacore/keda/issues/2090)|[#2184](https://github.com/kedacore/keda/pull/2184)) ## v2.4.0