From 2295fbcf40ca6e03b8792dde0fa5d2112af764db Mon Sep 17 00:00:00 2001 From: bandl <1658002533@qq.com> Date: Thu, 21 Oct 2021 15:57:31 +0800 Subject: [PATCH] chore(proto): update proto --- pkg/proto/listx.pb.go | 1471 +++++++++++++++++++++++++++++++ pkg/proto/storage.pb.go | 614 +++++++++++-- pkg/structure/const.gen.go | 37 + pkg/structure/generate/tem.yaml | 16 +- protobuf/listx.proto | 87 ++ protobuf/storage.proto | 13 + 6 files changed, 2186 insertions(+), 52 deletions(-) create mode 100644 pkg/proto/listx.pb.go create mode 100644 protobuf/listx.proto diff --git a/pkg/proto/listx.pb.go b/pkg/proto/listx.pb.go new file mode 100644 index 0000000..160ceee --- /dev/null +++ b/pkg/proto/listx.pb.go @@ -0,0 +1,1471 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.26.0 +// protoc v3.17.3 +// source: listx.proto + +package proto + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +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 LindexRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LindexRequest) Reset() { + *x = LindexRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LindexRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LindexRequest) ProtoMessage() {} + +func (x *LindexRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LindexRequest.ProtoReflect.Descriptor instead. +func (*LindexRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{0} +} + +func (x *LindexRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LindexResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LindexResponse) Reset() { + *x = LindexResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LindexResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LindexResponse) ProtoMessage() {} + +func (x *LindexResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LindexResponse.ProtoReflect.Descriptor instead. +func (*LindexResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{1} +} + +type LlenRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LlenRequest) Reset() { + *x = LlenRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LlenRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LlenRequest) ProtoMessage() {} + +func (x *LlenRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LlenRequest.ProtoReflect.Descriptor instead. +func (*LlenRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{2} +} + +func (x *LlenRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LlenResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LlenResponse) Reset() { + *x = LlenResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LlenResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LlenResponse) ProtoMessage() {} + +func (x *LlenResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LlenResponse.ProtoReflect.Descriptor instead. +func (*LlenResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{3} +} + +type LpopRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LpopRequest) Reset() { + *x = LpopRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LpopRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LpopRequest) ProtoMessage() {} + +func (x *LpopRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LpopRequest.ProtoReflect.Descriptor instead. +func (*LpopRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{4} +} + +func (x *LpopRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LpopResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LpopResponse) Reset() { + *x = LpopResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LpopResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LpopResponse) ProtoMessage() {} + +func (x *LpopResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LpopResponse.ProtoReflect.Descriptor instead. +func (*LpopResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{5} +} + +type LpushRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LpushRequest) Reset() { + *x = LpushRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LpushRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LpushRequest) ProtoMessage() {} + +func (x *LpushRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LpushRequest.ProtoReflect.Descriptor instead. +func (*LpushRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{6} +} + +func (x *LpushRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LpushResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LpushResponse) Reset() { + *x = LpushResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LpushResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LpushResponse) ProtoMessage() {} + +func (x *LpushResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LpushResponse.ProtoReflect.Descriptor instead. +func (*LpushResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{7} +} + +type LpushxRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LpushxRequest) Reset() { + *x = LpushxRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LpushxRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LpushxRequest) ProtoMessage() {} + +func (x *LpushxRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_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 mi.MessageOf(x) +} + +// Deprecated: Use LpushxRequest.ProtoReflect.Descriptor instead. +func (*LpushxRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{8} +} + +func (x *LpushxRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LpushxResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LpushxResponse) Reset() { + *x = LpushxResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LpushxResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LpushxResponse) ProtoMessage() {} + +func (x *LpushxResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LpushxResponse.ProtoReflect.Descriptor instead. +func (*LpushxResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{9} +} + +type LrangeRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LrangeRequest) Reset() { + *x = LrangeRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LrangeRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LrangeRequest) ProtoMessage() {} + +func (x *LrangeRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_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 mi.MessageOf(x) +} + +// Deprecated: Use LrangeRequest.ProtoReflect.Descriptor instead. +func (*LrangeRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{10} +} + +func (x *LrangeRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LrangeResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LrangeResponse) Reset() { + *x = LrangeResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LrangeResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LrangeResponse) ProtoMessage() {} + +func (x *LrangeResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_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 mi.MessageOf(x) +} + +// Deprecated: Use LrangeResponse.ProtoReflect.Descriptor instead. +func (*LrangeResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{11} +} + +type LremRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LremRequest) Reset() { + *x = LremRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LremRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LremRequest) ProtoMessage() {} + +func (x *LremRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_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) +} + +// Deprecated: Use LremRequest.ProtoReflect.Descriptor instead. +func (*LremRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{12} +} + +func (x *LremRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LremResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LremResponse) Reset() { + *x = LremResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[13] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LremResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LremResponse) ProtoMessage() {} + +func (x *LremResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[13] + 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) +} + +// Deprecated: Use LremResponse.ProtoReflect.Descriptor instead. +func (*LremResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{13} +} + +type LsetRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LsetRequest) Reset() { + *x = LsetRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[14] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LsetRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LsetRequest) ProtoMessage() {} + +func (x *LsetRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[14] + 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) +} + +// Deprecated: Use LsetRequest.ProtoReflect.Descriptor instead. +func (*LsetRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{14} +} + +func (x *LsetRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LsetResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LsetResponse) Reset() { + *x = LsetResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[15] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LsetResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LsetResponse) ProtoMessage() {} + +func (x *LsetResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[15] + 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) +} + +// Deprecated: Use LsetResponse.ProtoReflect.Descriptor instead. +func (*LsetResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{15} +} + +type RpopRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *RpopRequest) Reset() { + *x = RpopRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[16] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RpopRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RpopRequest) ProtoMessage() {} + +func (x *RpopRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[16] + 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) +} + +// Deprecated: Use RpopRequest.ProtoReflect.Descriptor instead. +func (*RpopRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{16} +} + +func (x *RpopRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type RpopResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *RpopResponse) Reset() { + *x = RpopResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[17] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RpopResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RpopResponse) ProtoMessage() {} + +func (x *RpopResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[17] + 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) +} + +// Deprecated: Use RpopResponse.ProtoReflect.Descriptor instead. +func (*RpopResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{17} +} + +type LtrimRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *LtrimRequest) Reset() { + *x = LtrimRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[18] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LtrimRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LtrimRequest) ProtoMessage() {} + +func (x *LtrimRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[18] + 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) +} + +// Deprecated: Use LtrimRequest.ProtoReflect.Descriptor instead. +func (*LtrimRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{18} +} + +func (x *LtrimRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type LtrimResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *LtrimResponse) Reset() { + *x = LtrimResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[19] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *LtrimResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LtrimResponse) ProtoMessage() {} + +func (x *LtrimResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[19] + 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) +} + +// Deprecated: Use LtrimResponse.ProtoReflect.Descriptor instead. +func (*LtrimResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{19} +} + +type RpushRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *RpushRequest) Reset() { + *x = RpushRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[20] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RpushRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RpushRequest) ProtoMessage() {} + +func (x *RpushRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[20] + 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) +} + +// Deprecated: Use RpushRequest.ProtoReflect.Descriptor instead. +func (*RpushRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{20} +} + +func (x *RpushRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type RpushResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *RpushResponse) Reset() { + *x = RpushResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[21] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RpushResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RpushResponse) ProtoMessage() {} + +func (x *RpushResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[21] + 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) +} + +// Deprecated: Use RpushResponse.ProtoReflect.Descriptor instead. +func (*RpushResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{21} +} + +type RpushxRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *BaseKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` +} + +func (x *RpushxRequest) Reset() { + *x = RpushxRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[22] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RpushxRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RpushxRequest) ProtoMessage() {} + +func (x *RpushxRequest) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[22] + 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) +} + +// Deprecated: Use RpushxRequest.ProtoReflect.Descriptor instead. +func (*RpushxRequest) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{22} +} + +func (x *RpushxRequest) GetKey() *BaseKey { + if x != nil { + return x.Key + } + return nil +} + +type RpushxResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *RpushxResponse) Reset() { + *x = RpushxResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_listx_proto_msgTypes[23] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RpushxResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RpushxResponse) ProtoMessage() {} + +func (x *RpushxResponse) ProtoReflect() protoreflect.Message { + mi := &file_listx_proto_msgTypes[23] + 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) +} + +// Deprecated: Use RpushxResponse.ProtoReflect.Descriptor instead. +func (*RpushxResponse) Descriptor() ([]byte, []int) { + return file_listx_proto_rawDescGZIP(), []int{23} +} + +var File_listx_proto protoreflect.FileDescriptor + +var file_listx_proto_rawDesc = []byte{ + 0x0a, 0x0b, 0x6c, 0x69, 0x73, 0x74, 0x78, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0a, 0x62, + 0x61, 0x73, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x2b, 0x0a, 0x0d, 0x4c, 0x69, 0x6e, + 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, + 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, + 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x10, 0x0a, 0x0e, 0x4c, 0x69, 0x6e, 0x64, 0x65, 0x78, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x29, 0x0a, 0x0b, 0x4c, 0x6c, 0x65, 0x6e, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x03, + 0x6b, 0x65, 0x79, 0x22, 0x0e, 0x0a, 0x0c, 0x4c, 0x6c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x22, 0x29, 0x0a, 0x0b, 0x4c, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, + 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x0e, + 0x0a, 0x0c, 0x4c, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2a, + 0x0a, 0x0c, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, + 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, + 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x0f, 0x0a, 0x0d, 0x4c, 0x70, + 0x75, 0x73, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2b, 0x0a, 0x0d, 0x4c, + 0x70, 0x75, 0x73, 0x68, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, + 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, + 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x10, 0x0a, 0x0e, 0x4c, 0x70, 0x75, 0x73, + 0x68, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2b, 0x0a, 0x0d, 0x4c, 0x72, + 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, + 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, + 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x10, 0x0a, 0x0e, 0x4c, 0x72, 0x61, 0x6e, 0x67, + 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x29, 0x0a, 0x0b, 0x4c, 0x72, 0x65, + 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, + 0x03, 0x6b, 0x65, 0x79, 0x22, 0x0e, 0x0a, 0x0c, 0x4c, 0x72, 0x65, 0x6d, 0x52, 0x65, 0x73, 0x70, + 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x29, 0x0a, 0x0b, 0x4c, 0x73, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, + 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, + 0x0e, 0x0a, 0x0c, 0x4c, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, + 0x29, 0x0a, 0x0b, 0x52, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, + 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, + 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x0e, 0x0a, 0x0c, 0x52, 0x70, + 0x6f, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2a, 0x0a, 0x0c, 0x4c, 0x74, + 0x72, 0x69, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, + 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, + 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x22, 0x0f, 0x0a, 0x0d, 0x4c, 0x74, 0x72, 0x69, 0x6d, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2a, 0x0a, 0x0c, 0x52, 0x70, 0x75, 0x73, 0x68, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x03, + 0x6b, 0x65, 0x79, 0x22, 0x0f, 0x0a, 0x0d, 0x52, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x73, 0x70, + 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x2b, 0x0a, 0x0d, 0x52, 0x70, 0x75, 0x73, 0x68, 0x78, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x0b, 0x32, 0x08, 0x2e, 0x42, 0x61, 0x73, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x03, 0x6b, 0x65, + 0x79, 0x22, 0x10, 0x0a, 0x0e, 0x52, 0x70, 0x75, 0x73, 0x68, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x42, 0x0b, 0x5a, 0x09, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_listx_proto_rawDescOnce sync.Once + file_listx_proto_rawDescData = file_listx_proto_rawDesc +) + +func file_listx_proto_rawDescGZIP() []byte { + file_listx_proto_rawDescOnce.Do(func() { + file_listx_proto_rawDescData = protoimpl.X.CompressGZIP(file_listx_proto_rawDescData) + }) + return file_listx_proto_rawDescData +} + +var file_listx_proto_msgTypes = make([]protoimpl.MessageInfo, 24) +var file_listx_proto_goTypes = []interface{}{ + (*LindexRequest)(nil), // 0: LindexRequest + (*LindexResponse)(nil), // 1: LindexResponse + (*LlenRequest)(nil), // 2: LlenRequest + (*LlenResponse)(nil), // 3: LlenResponse + (*LpopRequest)(nil), // 4: LpopRequest + (*LpopResponse)(nil), // 5: LpopResponse + (*LpushRequest)(nil), // 6: LpushRequest + (*LpushResponse)(nil), // 7: LpushResponse + (*LpushxRequest)(nil), // 8: LpushxRequest + (*LpushxResponse)(nil), // 9: LpushxResponse + (*LrangeRequest)(nil), // 10: LrangeRequest + (*LrangeResponse)(nil), // 11: LrangeResponse + (*LremRequest)(nil), // 12: LremRequest + (*LremResponse)(nil), // 13: LremResponse + (*LsetRequest)(nil), // 14: LsetRequest + (*LsetResponse)(nil), // 15: LsetResponse + (*RpopRequest)(nil), // 16: RpopRequest + (*RpopResponse)(nil), // 17: RpopResponse + (*LtrimRequest)(nil), // 18: LtrimRequest + (*LtrimResponse)(nil), // 19: LtrimResponse + (*RpushRequest)(nil), // 20: RpushRequest + (*RpushResponse)(nil), // 21: RpushResponse + (*RpushxRequest)(nil), // 22: RpushxRequest + (*RpushxResponse)(nil), // 23: RpushxResponse + (*BaseKey)(nil), // 24: BaseKey +} +var file_listx_proto_depIdxs = []int32{ + 24, // 0: LindexRequest.key:type_name -> BaseKey + 24, // 1: LlenRequest.key:type_name -> BaseKey + 24, // 2: LpopRequest.key:type_name -> BaseKey + 24, // 3: LpushRequest.key:type_name -> BaseKey + 24, // 4: LpushxRequest.key:type_name -> BaseKey + 24, // 5: LrangeRequest.key:type_name -> BaseKey + 24, // 6: LremRequest.key:type_name -> BaseKey + 24, // 7: LsetRequest.key:type_name -> BaseKey + 24, // 8: RpopRequest.key:type_name -> BaseKey + 24, // 9: LtrimRequest.key:type_name -> BaseKey + 24, // 10: RpushRequest.key:type_name -> BaseKey + 24, // 11: RpushxRequest.key:type_name -> BaseKey + 12, // [12:12] is the sub-list for method output_type + 12, // [12:12] is the sub-list for method input_type + 12, // [12:12] is the sub-list for extension type_name + 12, // [12:12] is the sub-list for extension extendee + 0, // [0:12] is the sub-list for field type_name +} + +func init() { file_listx_proto_init() } +func file_listx_proto_init() { + if File_listx_proto != nil { + return + } + file_base_proto_init() + if !protoimpl.UnsafeEnabled { + file_listx_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LindexRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LindexResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LlenRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LlenResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LpopRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LpopResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LpushRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LpushResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LpushxRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LpushxResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LrangeRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LrangeResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LremRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LremResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LsetRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LsetResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*RpopRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*RpopResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LtrimRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*LtrimResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*RpushRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*RpushResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*RpushxRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_listx_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*RpushxResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_listx_proto_rawDesc, + NumEnums: 0, + NumMessages: 24, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_listx_proto_goTypes, + DependencyIndexes: file_listx_proto_depIdxs, + MessageInfos: file_listx_proto_msgTypes, + }.Build() + File_listx_proto = out.File + file_listx_proto_rawDesc = nil + file_listx_proto_goTypes = nil + file_listx_proto_depIdxs = nil +} diff --git a/pkg/proto/storage.pb.go b/pkg/proto/storage.pb.go index 7ae6952..0d11d44 100644 --- a/pkg/proto/storage.pb.go +++ b/pkg/proto/storage.pb.go @@ -30,35 +30,66 @@ var File_storage_proto protoreflect.FileDescriptor var file_storage_proto_rawDesc = []byte{ 0x0a, 0x0d, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, - 0x0d, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x78, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32, 0xa2, - 0x03, 0x0a, 0x0a, 0x43, 0x6f, 0x6d, 0x6d, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x20, 0x0a, - 0x03, 0x53, 0x65, 0x74, 0x12, 0x0b, 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x1a, 0x0c, 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, - 0x20, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x12, 0x0b, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x0c, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, - 0x65, 0x12, 0x20, 0x0a, 0x03, 0x41, 0x64, 0x64, 0x12, 0x0b, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0c, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x12, 0x0e, 0x2e, - 0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, - 0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, - 0x0a, 0x06, 0x53, 0x65, 0x74, 0x62, 0x69, 0x74, 0x12, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, - 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, - 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, - 0x62, 0x69, 0x74, 0x12, 0x0e, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, - 0x12, 0x10, 0x2e, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x12, - 0x0e, 0x2e, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, - 0x0f, 0x2e, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, - 0x12, 0x29, 0x0a, 0x06, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e, 0x12, 0x0e, 0x2e, 0x53, 0x74, 0x72, - 0x6c, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x74, 0x72, - 0x6c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x53, - 0x65, 0x74, 0x6e, 0x78, 0x12, 0x0d, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x42, 0x0b, 0x5a, 0x09, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x0d, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x78, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0b, + 0x6c, 0x69, 0x73, 0x74, 0x78, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32, 0xff, 0x06, 0x0a, 0x0a, + 0x43, 0x6f, 0x6d, 0x6d, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x20, 0x0a, 0x03, 0x53, 0x65, + 0x74, 0x12, 0x0b, 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0c, + 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x20, 0x0a, 0x03, + 0x47, 0x65, 0x74, 0x12, 0x0b, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, + 0x1a, 0x0c, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x20, + 0x0a, 0x03, 0x41, 0x64, 0x64, 0x12, 0x0b, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x0c, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x29, 0x0a, 0x06, 0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x12, 0x0e, 0x2e, 0x52, 0x65, 0x64, + 0x75, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x52, 0x65, 0x64, + 0x75, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x53, + 0x65, 0x74, 0x62, 0x69, 0x74, 0x12, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, + 0x12, 0x0e, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, + 0x1a, 0x0f, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x12, 0x10, 0x2e, + 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x11, 0x2e, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, + 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x12, 0x0e, 0x2e, 0x47, + 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x47, + 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, + 0x06, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e, 0x12, 0x0e, 0x2e, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x53, 0x65, 0x74, 0x6e, + 0x78, 0x12, 0x0d, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, + 0x1a, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x29, 0x0a, 0x06, 0x4c, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x0e, 0x2e, 0x4c, 0x69, 0x6e, + 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x4c, 0x69, 0x6e, + 0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x4c, + 0x6c, 0x65, 0x6e, 0x12, 0x0c, 0x2e, 0x4c, 0x6c, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x0d, 0x2e, 0x4c, 0x6c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x23, 0x0a, 0x04, 0x4c, 0x70, 0x6f, 0x70, 0x12, 0x0c, 0x2e, 0x4c, 0x70, 0x6f, 0x70, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x4c, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x73, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x12, 0x0d, + 0x2e, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e, + 0x4c, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, + 0x06, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x78, 0x12, 0x0e, 0x2e, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x78, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x78, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x4c, 0x72, 0x61, 0x6e, + 0x67, 0x65, 0x12, 0x0e, 0x2e, 0x4c, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x4c, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x4c, 0x72, 0x65, 0x6d, 0x12, 0x0c, 0x2e, 0x4c, 0x72, + 0x65, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x4c, 0x72, 0x65, 0x6d, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x4c, 0x73, 0x65, 0x74, + 0x12, 0x0c, 0x2e, 0x4c, 0x73, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, + 0x2e, 0x4c, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, + 0x04, 0x52, 0x70, 0x6f, 0x70, 0x12, 0x0c, 0x2e, 0x52, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x52, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, + 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x4c, 0x74, 0x72, 0x69, 0x6d, 0x12, 0x0d, 0x2e, 0x4c, 0x74, + 0x72, 0x69, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x4c, 0x74, 0x72, + 0x69, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x52, 0x70, + 0x75, 0x73, 0x68, 0x12, 0x0d, 0x2e, 0x52, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x52, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, + 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x52, 0x70, 0x75, 0x73, 0x68, 0x78, 0x12, 0x0e, 0x2e, 0x52, + 0x70, 0x75, 0x73, 0x68, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x52, + 0x70, 0x75, 0x73, 0x68, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x0b, 0x5a, + 0x09, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x33, } var file_storage_proto_goTypes = []interface{}{ @@ -72,16 +103,40 @@ var file_storage_proto_goTypes = []interface{}{ (*GetsetRequest)(nil), // 7: GetsetRequest (*StrlenRequest)(nil), // 8: StrlenRequest (*SetnxRequest)(nil), // 9: SetnxRequest - (*SetResponse)(nil), // 10: SetResponse - (*GetResponse)(nil), // 11: GetResponse - (*AddResponse)(nil), // 12: AddResponse - (*ReduceResponse)(nil), // 13: ReduceResponse - (*SetbitResponse)(nil), // 14: SetbitResponse - (*GetbitResponse)(nil), // 15: GetbitResponse - (*GetrangeResponse)(nil), // 16: GetrangeResponse - (*GetsetResponse)(nil), // 17: GetsetResponse - (*StrlenResponse)(nil), // 18: StrlenResponse - (*SetnxResponse)(nil), // 19: SetnxResponse + (*LindexRequest)(nil), // 10: LindexRequest + (*LlenRequest)(nil), // 11: LlenRequest + (*LpopRequest)(nil), // 12: LpopRequest + (*LpushRequest)(nil), // 13: LpushRequest + (*LpushxRequest)(nil), // 14: LpushxRequest + (*LrangeRequest)(nil), // 15: LrangeRequest + (*LremRequest)(nil), // 16: LremRequest + (*LsetRequest)(nil), // 17: LsetRequest + (*RpopRequest)(nil), // 18: RpopRequest + (*LtrimRequest)(nil), // 19: LtrimRequest + (*RpushRequest)(nil), // 20: RpushRequest + (*RpushxRequest)(nil), // 21: RpushxRequest + (*SetResponse)(nil), // 22: SetResponse + (*GetResponse)(nil), // 23: GetResponse + (*AddResponse)(nil), // 24: AddResponse + (*ReduceResponse)(nil), // 25: ReduceResponse + (*SetbitResponse)(nil), // 26: SetbitResponse + (*GetbitResponse)(nil), // 27: GetbitResponse + (*GetrangeResponse)(nil), // 28: GetrangeResponse + (*GetsetResponse)(nil), // 29: GetsetResponse + (*StrlenResponse)(nil), // 30: StrlenResponse + (*SetnxResponse)(nil), // 31: SetnxResponse + (*LindexResponse)(nil), // 32: LindexResponse + (*LlenResponse)(nil), // 33: LlenResponse + (*LpopResponse)(nil), // 34: LpopResponse + (*LpushResponse)(nil), // 35: LpushResponse + (*LpushxResponse)(nil), // 36: LpushxResponse + (*LrangeResponse)(nil), // 37: LrangeResponse + (*LremResponse)(nil), // 38: LremResponse + (*LsetResponse)(nil), // 39: LsetResponse + (*RpopResponse)(nil), // 40: RpopResponse + (*LtrimResponse)(nil), // 41: LtrimResponse + (*RpushResponse)(nil), // 42: RpushResponse + (*RpushxResponse)(nil), // 43: RpushxResponse } var file_storage_proto_depIdxs = []int32{ 0, // 0: CommServer.Set:input_type -> SetRequest @@ -94,18 +149,42 @@ var file_storage_proto_depIdxs = []int32{ 7, // 7: CommServer.Getset:input_type -> GetsetRequest 8, // 8: CommServer.Strlen:input_type -> StrlenRequest 9, // 9: CommServer.Setnx:input_type -> SetnxRequest - 10, // 10: CommServer.Set:output_type -> SetResponse - 11, // 11: CommServer.Get:output_type -> GetResponse - 12, // 12: CommServer.Add:output_type -> AddResponse - 13, // 13: CommServer.Reduce:output_type -> ReduceResponse - 14, // 14: CommServer.Setbit:output_type -> SetbitResponse - 15, // 15: CommServer.Getbit:output_type -> GetbitResponse - 16, // 16: CommServer.Getrange:output_type -> GetrangeResponse - 17, // 17: CommServer.Getset:output_type -> GetsetResponse - 18, // 18: CommServer.Strlen:output_type -> StrlenResponse - 19, // 19: CommServer.Setnx:output_type -> SetnxResponse - 10, // [10:20] is the sub-list for method output_type - 0, // [0:10] is the sub-list for method input_type + 10, // 10: CommServer.Lindex:input_type -> LindexRequest + 11, // 11: CommServer.Llen:input_type -> LlenRequest + 12, // 12: CommServer.Lpop:input_type -> LpopRequest + 13, // 13: CommServer.Lpush:input_type -> LpushRequest + 14, // 14: CommServer.Lpushx:input_type -> LpushxRequest + 15, // 15: CommServer.Lrange:input_type -> LrangeRequest + 16, // 16: CommServer.Lrem:input_type -> LremRequest + 17, // 17: CommServer.Lset:input_type -> LsetRequest + 18, // 18: CommServer.Rpop:input_type -> RpopRequest + 19, // 19: CommServer.Ltrim:input_type -> LtrimRequest + 20, // 20: CommServer.Rpush:input_type -> RpushRequest + 21, // 21: CommServer.Rpushx:input_type -> RpushxRequest + 22, // 22: CommServer.Set:output_type -> SetResponse + 23, // 23: CommServer.Get:output_type -> GetResponse + 24, // 24: CommServer.Add:output_type -> AddResponse + 25, // 25: CommServer.Reduce:output_type -> ReduceResponse + 26, // 26: CommServer.Setbit:output_type -> SetbitResponse + 27, // 27: CommServer.Getbit:output_type -> GetbitResponse + 28, // 28: CommServer.Getrange:output_type -> GetrangeResponse + 29, // 29: CommServer.Getset:output_type -> GetsetResponse + 30, // 30: CommServer.Strlen:output_type -> StrlenResponse + 31, // 31: CommServer.Setnx:output_type -> SetnxResponse + 32, // 32: CommServer.Lindex:output_type -> LindexResponse + 33, // 33: CommServer.Llen:output_type -> LlenResponse + 34, // 34: CommServer.Lpop:output_type -> LpopResponse + 35, // 35: CommServer.Lpush:output_type -> LpushResponse + 36, // 36: CommServer.Lpushx:output_type -> LpushxResponse + 37, // 37: CommServer.Lrange:output_type -> LrangeResponse + 38, // 38: CommServer.Lrem:output_type -> LremResponse + 39, // 39: CommServer.Lset:output_type -> LsetResponse + 40, // 40: CommServer.Rpop:output_type -> RpopResponse + 41, // 41: CommServer.Ltrim:output_type -> LtrimResponse + 42, // 42: CommServer.Rpush:output_type -> RpushResponse + 43, // 43: CommServer.Rpushx:output_type -> RpushxResponse + 22, // [22:44] is the sub-list for method output_type + 0, // [0:22] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name 0, // [0:0] is the sub-list for extension extendee 0, // [0:0] is the sub-list for field type_name @@ -117,6 +196,7 @@ func file_storage_proto_init() { return } file_stringx_proto_init() + file_listx_proto_init() type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ @@ -158,6 +238,18 @@ type CommServerClient interface { Getset(ctx context.Context, in *GetsetRequest, opts ...grpc.CallOption) (*GetsetResponse, error) Strlen(ctx context.Context, in *StrlenRequest, opts ...grpc.CallOption) (*StrlenResponse, error) Setnx(ctx context.Context, in *SetnxRequest, opts ...grpc.CallOption) (*SetnxResponse, error) + Lindex(ctx context.Context, in *LindexRequest, opts ...grpc.CallOption) (*LindexResponse, error) + Llen(ctx context.Context, in *LlenRequest, opts ...grpc.CallOption) (*LlenResponse, error) + Lpop(ctx context.Context, in *LpopRequest, opts ...grpc.CallOption) (*LpopResponse, error) + Lpush(ctx context.Context, in *LpushRequest, opts ...grpc.CallOption) (*LpushResponse, error) + Lpushx(ctx context.Context, in *LpushxRequest, opts ...grpc.CallOption) (*LpushxResponse, error) + Lrange(ctx context.Context, in *LrangeRequest, opts ...grpc.CallOption) (*LrangeResponse, error) + Lrem(ctx context.Context, in *LremRequest, opts ...grpc.CallOption) (*LremResponse, error) + Lset(ctx context.Context, in *LsetRequest, opts ...grpc.CallOption) (*LsetResponse, error) + Rpop(ctx context.Context, in *RpopRequest, opts ...grpc.CallOption) (*RpopResponse, error) + Ltrim(ctx context.Context, in *LtrimRequest, opts ...grpc.CallOption) (*LtrimResponse, error) + Rpush(ctx context.Context, in *RpushRequest, opts ...grpc.CallOption) (*RpushResponse, error) + Rpushx(ctx context.Context, in *RpushxRequest, opts ...grpc.CallOption) (*RpushxResponse, error) } type commServerClient struct { @@ -258,6 +350,114 @@ func (c *commServerClient) Setnx(ctx context.Context, in *SetnxRequest, opts ... return out, nil } +func (c *commServerClient) Lindex(ctx context.Context, in *LindexRequest, opts ...grpc.CallOption) (*LindexResponse, error) { + out := new(LindexResponse) + err := c.cc.Invoke(ctx, "/CommServer/Lindex", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Llen(ctx context.Context, in *LlenRequest, opts ...grpc.CallOption) (*LlenResponse, error) { + out := new(LlenResponse) + err := c.cc.Invoke(ctx, "/CommServer/Llen", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Lpop(ctx context.Context, in *LpopRequest, opts ...grpc.CallOption) (*LpopResponse, error) { + out := new(LpopResponse) + err := c.cc.Invoke(ctx, "/CommServer/Lpop", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Lpush(ctx context.Context, in *LpushRequest, opts ...grpc.CallOption) (*LpushResponse, error) { + out := new(LpushResponse) + err := c.cc.Invoke(ctx, "/CommServer/Lpush", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Lpushx(ctx context.Context, in *LpushxRequest, opts ...grpc.CallOption) (*LpushxResponse, error) { + out := new(LpushxResponse) + err := c.cc.Invoke(ctx, "/CommServer/Lpushx", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Lrange(ctx context.Context, in *LrangeRequest, opts ...grpc.CallOption) (*LrangeResponse, error) { + out := new(LrangeResponse) + err := c.cc.Invoke(ctx, "/CommServer/Lrange", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Lrem(ctx context.Context, in *LremRequest, opts ...grpc.CallOption) (*LremResponse, error) { + out := new(LremResponse) + err := c.cc.Invoke(ctx, "/CommServer/Lrem", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Lset(ctx context.Context, in *LsetRequest, opts ...grpc.CallOption) (*LsetResponse, error) { + out := new(LsetResponse) + err := c.cc.Invoke(ctx, "/CommServer/Lset", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Rpop(ctx context.Context, in *RpopRequest, opts ...grpc.CallOption) (*RpopResponse, error) { + out := new(RpopResponse) + err := c.cc.Invoke(ctx, "/CommServer/Rpop", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Ltrim(ctx context.Context, in *LtrimRequest, opts ...grpc.CallOption) (*LtrimResponse, error) { + out := new(LtrimResponse) + err := c.cc.Invoke(ctx, "/CommServer/Ltrim", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Rpush(ctx context.Context, in *RpushRequest, opts ...grpc.CallOption) (*RpushResponse, error) { + out := new(RpushResponse) + err := c.cc.Invoke(ctx, "/CommServer/Rpush", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *commServerClient) Rpushx(ctx context.Context, in *RpushxRequest, opts ...grpc.CallOption) (*RpushxResponse, error) { + out := new(RpushxResponse) + err := c.cc.Invoke(ctx, "/CommServer/Rpushx", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // CommServerServer is the server API for CommServer service. type CommServerServer interface { Set(context.Context, *SetRequest) (*SetResponse, error) @@ -270,6 +470,18 @@ type CommServerServer interface { Getset(context.Context, *GetsetRequest) (*GetsetResponse, error) Strlen(context.Context, *StrlenRequest) (*StrlenResponse, error) Setnx(context.Context, *SetnxRequest) (*SetnxResponse, error) + Lindex(context.Context, *LindexRequest) (*LindexResponse, error) + Llen(context.Context, *LlenRequest) (*LlenResponse, error) + Lpop(context.Context, *LpopRequest) (*LpopResponse, error) + Lpush(context.Context, *LpushRequest) (*LpushResponse, error) + Lpushx(context.Context, *LpushxRequest) (*LpushxResponse, error) + Lrange(context.Context, *LrangeRequest) (*LrangeResponse, error) + Lrem(context.Context, *LremRequest) (*LremResponse, error) + Lset(context.Context, *LsetRequest) (*LsetResponse, error) + Rpop(context.Context, *RpopRequest) (*RpopResponse, error) + Ltrim(context.Context, *LtrimRequest) (*LtrimResponse, error) + Rpush(context.Context, *RpushRequest) (*RpushResponse, error) + Rpushx(context.Context, *RpushxRequest) (*RpushxResponse, error) } // UnimplementedCommServerServer can be embedded to have forward compatible implementations. @@ -306,6 +518,42 @@ func (*UnimplementedCommServerServer) Strlen(context.Context, *StrlenRequest) (* func (*UnimplementedCommServerServer) Setnx(context.Context, *SetnxRequest) (*SetnxResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Setnx not implemented") } +func (*UnimplementedCommServerServer) Lindex(context.Context, *LindexRequest) (*LindexResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Lindex not implemented") +} +func (*UnimplementedCommServerServer) Llen(context.Context, *LlenRequest) (*LlenResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Llen not implemented") +} +func (*UnimplementedCommServerServer) Lpop(context.Context, *LpopRequest) (*LpopResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Lpop not implemented") +} +func (*UnimplementedCommServerServer) Lpush(context.Context, *LpushRequest) (*LpushResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Lpush not implemented") +} +func (*UnimplementedCommServerServer) Lpushx(context.Context, *LpushxRequest) (*LpushxResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Lpushx not implemented") +} +func (*UnimplementedCommServerServer) Lrange(context.Context, *LrangeRequest) (*LrangeResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Lrange not implemented") +} +func (*UnimplementedCommServerServer) Lrem(context.Context, *LremRequest) (*LremResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Lrem not implemented") +} +func (*UnimplementedCommServerServer) Lset(context.Context, *LsetRequest) (*LsetResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Lset not implemented") +} +func (*UnimplementedCommServerServer) Rpop(context.Context, *RpopRequest) (*RpopResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Rpop not implemented") +} +func (*UnimplementedCommServerServer) Ltrim(context.Context, *LtrimRequest) (*LtrimResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Ltrim not implemented") +} +func (*UnimplementedCommServerServer) Rpush(context.Context, *RpushRequest) (*RpushResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Rpush not implemented") +} +func (*UnimplementedCommServerServer) Rpushx(context.Context, *RpushxRequest) (*RpushxResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Rpushx not implemented") +} func RegisterCommServerServer(s *grpc.Server, srv CommServerServer) { s.RegisterService(&_CommServer_serviceDesc, srv) @@ -491,6 +739,222 @@ func _CommServer_Setnx_Handler(srv interface{}, ctx context.Context, dec func(in return interceptor(ctx, in, info, handler) } +func _CommServer_Lindex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LindexRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Lindex(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Lindex", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Lindex(ctx, req.(*LindexRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Llen_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LlenRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Llen(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Llen", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Llen(ctx, req.(*LlenRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Lpop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LpopRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Lpop(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Lpop", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Lpop(ctx, req.(*LpopRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Lpush_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LpushRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Lpush(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Lpush", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Lpush(ctx, req.(*LpushRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Lpushx_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LpushxRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Lpushx(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Lpushx", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Lpushx(ctx, req.(*LpushxRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Lrange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LrangeRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Lrange(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Lrange", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Lrange(ctx, req.(*LrangeRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Lrem_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LremRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Lrem(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Lrem", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Lrem(ctx, req.(*LremRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Lset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LsetRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Lset(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Lset", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Lset(ctx, req.(*LsetRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Rpop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(RpopRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Rpop(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Rpop", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Rpop(ctx, req.(*RpopRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Ltrim_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LtrimRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Ltrim(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Ltrim", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Ltrim(ctx, req.(*LtrimRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Rpush_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(RpushRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Rpush(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Rpush", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Rpush(ctx, req.(*RpushRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _CommServer_Rpushx_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(RpushxRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(CommServerServer).Rpushx(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/CommServer/Rpushx", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(CommServerServer).Rpushx(ctx, req.(*RpushxRequest)) + } + return interceptor(ctx, in, info, handler) +} + var _CommServer_serviceDesc = grpc.ServiceDesc{ ServiceName: "CommServer", HandlerType: (*CommServerServer)(nil), @@ -535,6 +999,54 @@ var _CommServer_serviceDesc = grpc.ServiceDesc{ MethodName: "Setnx", Handler: _CommServer_Setnx_Handler, }, + { + MethodName: "Lindex", + Handler: _CommServer_Lindex_Handler, + }, + { + MethodName: "Llen", + Handler: _CommServer_Llen_Handler, + }, + { + MethodName: "Lpop", + Handler: _CommServer_Lpop_Handler, + }, + { + MethodName: "Lpush", + Handler: _CommServer_Lpush_Handler, + }, + { + MethodName: "Lpushx", + Handler: _CommServer_Lpushx_Handler, + }, + { + MethodName: "Lrange", + Handler: _CommServer_Lrange_Handler, + }, + { + MethodName: "Lrem", + Handler: _CommServer_Lrem_Handler, + }, + { + MethodName: "Lset", + Handler: _CommServer_Lset_Handler, + }, + { + MethodName: "Rpop", + Handler: _CommServer_Rpop_Handler, + }, + { + MethodName: "Ltrim", + Handler: _CommServer_Ltrim_Handler, + }, + { + MethodName: "Rpush", + Handler: _CommServer_Rpush_Handler, + }, + { + MethodName: "Rpushx", + Handler: _CommServer_Rpushx_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "storage.proto", diff --git a/pkg/structure/const.gen.go b/pkg/structure/const.gen.go index 76da0ab..b9555a1 100644 --- a/pkg/structure/const.gen.go +++ b/pkg/structure/const.gen.go @@ -7,6 +7,7 @@ const ( DEFAULT_KEY = iota STRING_X + LIST_X ) const ( @@ -21,6 +22,18 @@ const ( GETSET STRLEN SETNX + LINDEX + LLEN + LPOP + LPUSH + LPUSHX + LRANGE + LREM + LSET + RPOP + LTRIM + RPUSH + RPUSHX ) var CommKeyString = map[string]int{"set": STRING_X, @@ -33,6 +46,18 @@ var CommKeyString = map[string]int{"set": STRING_X, "getset": STRING_X, "strlen": STRING_X, "setnx": STRING_X, + "lindex": LIST_X, + "llen": LIST_X, + "lpop": LIST_X, + "lpush": LIST_X, + "lpushx": LIST_X, + "lrange": LIST_X, + "lrem": LIST_X, + "lset": LIST_X, + "rpop": LIST_X, + "ltrim": LIST_X, + "rpush": LIST_X, + "rpushx": LIST_X, } var CommKey = map[int]int{SET: STRING_X, @@ -45,4 +70,16 @@ var CommKey = map[int]int{SET: STRING_X, GETSET: STRING_X, STRLEN: STRING_X, SETNX: STRING_X, + LINDEX: LIST_X, + LLEN: LIST_X, + LPOP: LIST_X, + LPUSH: LIST_X, + LPUSHX: LIST_X, + LRANGE: LIST_X, + LREM: LIST_X, + LSET: LIST_X, + RPOP: LIST_X, + LTRIM: LIST_X, + RPUSH: LIST_X, + RPUSHX: LIST_X, } diff --git a/pkg/structure/generate/tem.yaml b/pkg/structure/generate/tem.yaml index 26d989f..d404084 100644 --- a/pkg/structure/generate/tem.yaml +++ b/pkg/structure/generate/tem.yaml @@ -11,4 +11,18 @@ STRING_X: - getrange - getset - strlen - - setnx \ No newline at end of file + - setnx + +LIST_X: + - lindex + - llen + - lpop + - lpush + - lpushx # 列表不存在则不插入 + - lrange + - lrem + - lset + - rpop + - ltrim # 对列表进行切片 + - rpush + - rpushx # 对已经存在的列表尾插 \ No newline at end of file diff --git a/protobuf/listx.proto b/protobuf/listx.proto new file mode 100644 index 0000000..b14c2e7 --- /dev/null +++ b/protobuf/listx.proto @@ -0,0 +1,87 @@ +syntax = "proto3"; +import "base.proto"; +option go_package = "pkg/proto"; + +message LindexRequest { + BaseKey key = 1; +} + +message LindexResponse { +} + +message LlenRequest { + BaseKey key = 1; +} + +message LlenResponse { +} + +message LpopRequest { + BaseKey key = 1; +} + +message LpopResponse { +} + +message LpushRequest { + BaseKey key = 1; +} + +message LpushResponse { +} + +message LpushxRequest { + BaseKey key = 1; +} + +message LpushxResponse { +} + +message LrangeRequest { + BaseKey key = 1; +} + +message LrangeResponse { +} + +message LremRequest { + BaseKey key = 1; +} + +message LremResponse { +} + +message LsetRequest { + BaseKey key = 1; +} + +message LsetResponse { +} + +message RpopRequest { + BaseKey key = 1; +} + +message RpopResponse { +} + +message LtrimRequest { + BaseKey key = 1; +} + +message LtrimResponse { +} + +message RpushRequest { + BaseKey key = 1; +} + +message RpushResponse { +} + +message RpushxRequest { + BaseKey key = 1; +} + +message RpushxResponse { +} diff --git a/protobuf/storage.proto b/protobuf/storage.proto index 5493bfa..6c0d976 100644 --- a/protobuf/storage.proto +++ b/protobuf/storage.proto @@ -6,6 +6,7 @@ syntax = "proto3"; option go_package = "pkg/proto"; import "stringx.proto"; +import "listx.proto"; service CommServer { @@ -19,4 +20,16 @@ service CommServer { rpc Getset (GetsetRequest) returns (GetsetResponse); rpc Strlen (StrlenRequest) returns (StrlenResponse); rpc Setnx (SetnxRequest) returns (SetnxResponse); + rpc Lindex (LindexRequest) returns (LindexResponse); + rpc Llen (LlenRequest) returns (LlenResponse); + rpc Lpop (LpopRequest) returns (LpopResponse); + rpc Lpush (LpushRequest) returns (LpushResponse); + rpc Lpushx (LpushxRequest) returns (LpushxResponse); + rpc Lrange (LrangeRequest) returns (LrangeResponse); + rpc Lrem (LremRequest) returns (LremResponse); + rpc Lset (LsetRequest) returns (LsetResponse); + rpc Rpop (RpopRequest) returns (RpopResponse); + rpc Ltrim (LtrimRequest) returns (LtrimResponse); + rpc Rpush (RpushRequest) returns (RpushResponse); + rpc Rpushx (RpushxRequest) returns (RpushxResponse); } \ No newline at end of file